inputport.py 文件源码

def __init__(self):
        # number of connected senders that are not closed. incremented by
        # OutputPort.open()
        self._sender_count = 0
        # the connected InputPort
        # type: rill.engine.outputport.InputPort
        self.inport = None
        # the outport currently sending
        # type: rill.engine.outputport.OutputPort
        self.outport = None
        # all connected OutputPorts
        # type: Set[rill.engine.outputport.OutputPort]
        self.outports = set()
        # packet queue and blocking events
        self._queue = None
        self._not_empty = gevent.event.Event()
        self._not_full = gevent.event.Event()
        # properties
        self.drop_oldest = False
        self.count_packets = False
        self.metadata = {}