def __init__(self, *args, **kwargs):
    global _identNext
    _identLock.acquire()
    ioID = _identNext
    _identNext += 1
    _identLock.release()
    if _debug:
        IOCB._debug('__init__(%d) %r %r', ioID, args, kwargs)
    self.ioID = ioID
    self.args = args
    self.kwargs = kwargs
    self.ioState = IDLE
    self.ioResponse = None
    self.ioError = None
    self.ioController = None
    self.ioServerRef = None
    self.ioControllerRef = None
    self.ioClientID = None
    self.ioClientAddr = None
    self.ioComplete = threading.Event()
    self.ioComplete.clear()
    self.ioCallback = []
    self.ioQueue = None
    self.ioPriority = kwargs.get('_priority', 0)
    if ('_priority' in kwargs):
        if _debug:
            IOCB._debug('    - ioPriority: %r', self.ioPriority)
        del kwargs['_priority']
    self.ioTimeout = None
def __init__(self, *args, **kwargs):
    global _identNext
    _identLock.acquire()
    ioID = _identNext
    _identNext += 1
    _identLock.release()
    if _debug:
        IOCB._debug('__init__(%d) %r %r', ioID, args, kwargs)
    self.ioID = ioID
    self.args = args
    self.kwargs = kwargs
    self.ioState = IDLE
    self.ioResponse = None
    self.ioError = None
    self.ioController = None
    self.ioServerRef = None
    self.ioControllerRef = None
    self.ioClientID = None
    self.ioClientAddr = None
    self.ioComplete = threading.Event()
    self.ioComplete.clear()
    self.ioCallback = []
    self.ioQueue = None
    self.ioPriority = kwargs.get('_priority', 0)
    if ('_priority' in kwargs):
        if _debug:
            IOCB._debug('    - ioPriority: %r', self.ioPriority)
        del kwargs['_priority']
    self.ioTimeout = None