FM / ndb

/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/

/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb

Name	Size	Mode	Actions
objects/	-	0755	rm
__pycache__/	-	0755	rm
auth_manager.py	2647	0644	edit dl rm
cli.py	2305	0644	edit dl rm
cluster.py	1003	0644	edit dl rm
compat.py	2254	0644	edit dl rm
events.py	2067	0644	edit dl rm
main.py	21460	0644	edit dl rm
messages.py	246	0644	edit dl rm
noipdb.py	5147	0644	edit dl rm
query.py	4867	0644	edit dl rm
report.py	12148	0644	edit dl rm
schema.py	32812	0644	edit dl rm
source.py	16959	0644	edit dl rm
task_manager.py	9808	0644	edit dl rm
transaction.py	11314	0644	edit dl rm
transport.py	6350	0644	edit dl rm
view.py	16900	0644	edit dl rm
__init__.py	0	0644	edit dl rm

Edit: /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/events.py (2067B)

import threading
import time

class SyncStart(Exception):
    pass

class SchemaFlush(Exception):
    pass

class SchemaReadLock(Exception):
    pass

class SchemaReadUnlock(Exception):
    pass

class SchemaGenericRequest(object):
    def __init__(self, response, *argv, **kwarg):
        self.response = response
        self.argv = argv
        self.kwarg = kwarg

class MarkFailed(Exception):
    pass

class DBMExitException(Exception):
    pass

class ShutdownException(Exception):
    pass

class RescheduleException(Exception):
    pass

class InvalidateHandlerException(Exception):
    pass

class State(object):
    events = None

def __init__(self, prime=None, log=None, wait_list=None):
        wait_list = wait_list or []
        self.events = []
        self.log = log
        self.wait_list = {x: threading.Event() for x in wait_list}
        if prime is not None:
            self.load(prime)

def wait(self, state, *argv, **kwarg):
        return self.wait_list[state].wait(*argv, **kwarg)

def load(self, prime):
        self.events = []
        for state in prime.events:
            self.events.append(state)

def transition(self):
        if len(self.events) < 2:
            return None
        return (self.events[-2][1], self.events[-1][1])

def get(self):
        if not self.events:
            return None
        return self.events[-1][1]

def set(self, state):
        for key in self.wait_list:
            if key == state:
                self.wait_list[key].set()
            else:
                self.wait_list[key].clear()
        if self.log is not None:
            self.log.debug(state)
        if self.events and self.events[-1][1] == state:
            self.events.pop()
        self.events.append((time.time(), state))
        return state

def __eq__(self, other):
        if not self.events:
            return False
        return self.events[-1][1] == other

def __ne__(self, other):
        if not self.events:
            return True
        return self.events[-1][1] != other

cmd: