comparison hgext/inotify/server.py @ 8555:3e09bc5fee12

inotify: introduce debuginotify, which lists which paths are under watch

8554:47d7347484f5

        self.timeout = None

    def shutdown(self):
        self.watcher.close()

class server(object):
    poll_events = select.POLLIN

    def __init__(self, ui, repo, repowatcher, timeout):
        self.ui = ui

                or [],
            [],
            'c' in states and genresult('n', self.repowatcher.tree) or [],
            ]]

    def handle_event(self, fd, event):
        sock, addr = self.sock.accept()

        cs = common.recvcs(sock)
        version = ord(cs.read(1))

        type = cs.read(4)

        if type == 'STAT':
            results = self.answer_stat_query(cs)
        else:
            self.ui.warn(_('unrecognized query type: %s\n') % type)
            return

        try:

8555:3e09bc5fee12

        self.timeout = None

    def shutdown(self):
        self.watcher.close()

    def debug(self):
        """
        Returns a sorted list of relatives paths currently watched,
        for debugging purposes.
        """
        return sorted(tuple[0][len(self.wprefix):] for tuple in self.watcher)

class server(object):
    poll_events = select.POLLIN

    def __init__(self, ui, repo, repowatcher, timeout):
        self.ui = ui

                or [],
            [],
            'c' in states and genresult('n', self.repowatcher.tree) or [],
            ]]

    def answer_dbug_query(self):
        return ['\0'.join(self.repowatcher.debug())]

    def handle_event(self, fd, event):
        sock, addr = self.sock.accept()

        cs = common.recvcs(sock)
        version = ord(cs.read(1))

        type = cs.read(4)

        if type == 'STAT':
            results = self.answer_stat_query(cs)
        elif type == 'DBUG':
            results = self.answer_dbug_query()
        else:
            self.ui.warn(_('unrecognized query type: %s\n') % type)
            return

        try: