Show More
@@ -500,7 +500,7 b' class repowatcher(object):' | |||
|
500 | 500 | evt.fullpath) |
|
501 | 501 | sys.exit(0) |
|
502 | 502 | |
|
503 | def handle_pollevent(self): | |
|
503 | def handle_pollevents(self, events): | |
|
504 | 504 | if self.ui.debugflag: |
|
505 | 505 | self.ui.note(_('%s readable: %d bytes\n') % |
|
506 | 506 | (self.event_time(), self.threshold.readable())) |
@@ -640,6 +640,10 b' class server(object):' | |||
|
640 | 640 | def answer_dbug_query(self): |
|
641 | 641 | return ['\0'.join(self.repowatcher.debug())] |
|
642 | 642 | |
|
643 | def handle_pollevents(self, events): | |
|
644 | for e in events: | |
|
645 | self.handle_pollevent() | |
|
646 | ||
|
643 | 647 | def handle_pollevent(self): |
|
644 | 648 | sock, addr = self.sock.accept() |
|
645 | 649 | |
@@ -728,8 +732,13 b' class master(object):' | |||
|
728 | 732 | continue |
|
729 | 733 | raise |
|
730 | 734 | if events: |
|
735 | by_fd = {} | |
|
731 | 736 | for fd, event in events: |
|
732 |
|
|
|
737 | by_fd.setdefault(fd, []).append(event) | |
|
738 | ||
|
739 | for fd, events in by_fd.iteritems(): | |
|
740 | self.table[fd].handle_pollevents(events) | |
|
741 | ||
|
733 | 742 | elif timeobj: |
|
734 | 743 | timeobj.handle_timeout() |
|
735 | 744 |
General Comments 0
You need to be logged in to leave comments.
Login now