Show More
@@ -500,7 +500,7 b' class repowatcher(object):' | |||
|
500 | 500 | evt.fullpath) |
|
501 | 501 | sys.exit(0) |
|
502 | 502 | |
|
503 |
def handle_event(self |
|
|
503 | def handle_event(self): | |
|
504 | 504 | if self.ui.debugflag: |
|
505 | 505 | self.ui.note(_('%s readable: %d bytes\n') % |
|
506 | 506 | (self.event_time(), self.threshold.readable())) |
@@ -509,7 +509,7 b' class repowatcher(object):' | |||
|
509 | 509 | if self.ui.debugflag: |
|
510 | 510 | self.ui.note(_('%s below threshold - unhooking\n') % |
|
511 | 511 | (self.event_time())) |
|
512 |
self.master.poll.unregister( |
|
|
512 | self.master.poll.unregister(self.fileno()) | |
|
513 | 513 | self.registered = False |
|
514 | 514 | self.timeout = 250 |
|
515 | 515 | else: |
@@ -640,7 +640,7 b' class server(object):' | |||
|
640 | 640 | def answer_dbug_query(self): |
|
641 | 641 | return ['\0'.join(self.repowatcher.debug())] |
|
642 | 642 | |
|
643 |
def handle_event(self |
|
|
643 | def handle_event(self): | |
|
644 | 644 | sock, addr = self.sock.accept() |
|
645 | 645 | |
|
646 | 646 | cs = common.recvcs(sock) |
@@ -729,7 +729,7 b' class master(object):' | |||
|
729 | 729 | raise |
|
730 | 730 | if events: |
|
731 | 731 | for fd, event in events: |
|
732 |
self.table[fd].handle_event( |
|
|
732 | self.table[fd].handle_event() | |
|
733 | 733 | elif timeobj: |
|
734 | 734 | timeobj.handle_timeout() |
|
735 | 735 |
General Comments 0
You need to be logged in to leave comments.
Login now