Mercurial > hg
comparison hgext/inotify/server.py @ 8608:228db070bfc4
inotify: rename handle_event to handle_pollevent to avoid confusion
event here refers to poll events, and are different from events read in
server.read_events for example, where those events are inotify events.
author | Nicolas Dumazet <nicdumz.commits@gmail.com> |
---|---|
date | Thu, 21 May 2009 19:22:29 +0900 |
parents | e17eba98c789 |
children | aeaa0bd9dc24 |
comparison
equal
deleted
inserted
replaced
8607:e17eba98c789 | 8608:228db070bfc4 |
---|---|
498 def process_unmount(self, evt): | 498 def process_unmount(self, evt): |
499 self.ui.warn(_('filesystem containing %s was unmounted\n') % | 499 self.ui.warn(_('filesystem containing %s was unmounted\n') % |
500 evt.fullpath) | 500 evt.fullpath) |
501 sys.exit(0) | 501 sys.exit(0) |
502 | 502 |
503 def handle_event(self): | 503 def handle_pollevent(self): |
504 if self.ui.debugflag: | 504 if self.ui.debugflag: |
505 self.ui.note(_('%s readable: %d bytes\n') % | 505 self.ui.note(_('%s readable: %d bytes\n') % |
506 (self.event_time(), self.threshold.readable())) | 506 (self.event_time(), self.threshold.readable())) |
507 if not self.threshold(): | 507 if not self.threshold(): |
508 if self.registered: | 508 if self.registered: |
638 ]] | 638 ]] |
639 | 639 |
640 def answer_dbug_query(self): | 640 def answer_dbug_query(self): |
641 return ['\0'.join(self.repowatcher.debug())] | 641 return ['\0'.join(self.repowatcher.debug())] |
642 | 642 |
643 def handle_event(self): | 643 def handle_pollevent(self): |
644 sock, addr = self.sock.accept() | 644 sock, addr = self.sock.accept() |
645 | 645 |
646 cs = common.recvcs(sock) | 646 cs = common.recvcs(sock) |
647 version = ord(cs.read(1)) | 647 version = ord(cs.read(1)) |
648 | 648 |
727 if err[0] == errno.EINTR: | 727 if err[0] == errno.EINTR: |
728 continue | 728 continue |
729 raise | 729 raise |
730 if events: | 730 if events: |
731 for fd, event in events: | 731 for fd, event in events: |
732 self.table[fd].handle_event() | 732 self.table[fd].handle_pollevent() |
733 elif timeobj: | 733 elif timeobj: |
734 timeobj.handle_timeout() | 734 timeobj.handle_timeout() |
735 | 735 |
736 def start(ui, repo): | 736 def start(ui, repo): |
737 def closefds(ignore): | 737 def closefds(ignore): |