def request_io(self, iocb, urgent=False):
    'Called by a client to start processing a request.'
    if _debug:
        IOProxy._debug('request_io %r urgent=%r', iocb, urgent)
    global _proxy_server
    iocb.ioServerRef = self.ioServerRef
    iocb.ioControllerRef = self.ioControllerRef
    if (not self.ioBind):
        if (not self.ioServerRef):
            self.ioBind = _local_controllers.get(self.ioControllerRef, None)
            if (not self.ioBind):
                iocb.abort(('no local controller %s' % (self.ioControllerRef,)))
                return
            if _debug:
                IOProxy._debug('    - local bind successful')
        else:
            if (not _proxy_server):
                _proxy_server = IOProxyServer()
            self.ioBind = _proxy_server
            if _debug:
                IOProxy._debug('    - proxy bind successful: %r', self.ioBind)
    if ((not urgent) and self.ioRequestLimit):
        iocb.add_callback(self._proxy_trigger)
        if (len(self.ioPending) < self.ioRequestLimit):
            if _debug:
                IOProxy._debug('    - cleared for launch')
            self.ioPending.add(iocb)
            self.ioBind.request_io(iocb)
        else:
            if _debug:
                IOProxy._debug('    - save for later')
            self.ioBlocked.append(iocb)
    else:
        self.ioBind.request_io(iocb)
Called by a client to start processing a request.
def request_io(self, iocb, urgent=False):
    
    if _debug:
        IOProxy._debug('request_io %r urgent=%r', iocb, urgent)
    global _proxy_server
    iocb.ioServerRef = self.ioServerRef
    iocb.ioControllerRef = self.ioControllerRef
    if (not self.ioBind):
        if (not self.ioServerRef):
            self.ioBind = _local_controllers.get(self.ioControllerRef, None)
            if (not self.ioBind):
                iocb.abort(('no local controller %s' % (self.ioControllerRef,)))
                return
            if _debug:
                IOProxy._debug('    - local bind successful')
        else:
            if (not _proxy_server):
                _proxy_server = IOProxyServer()
            self.ioBind = _proxy_server
            if _debug:
                IOProxy._debug('    - proxy bind successful: %r', self.ioBind)
    if ((not urgent) and self.ioRequestLimit):
        iocb.add_callback(self._proxy_trigger)
        if (len(self.ioPending) < self.ioRequestLimit):
            if _debug:
                IOProxy._debug('    - cleared for launch')
            self.ioPending.add(iocb)
            self.ioBind.request_io(iocb)
        else:
            if _debug:
                IOProxy._debug('    - save for later')
            self.ioBlocked.append(iocb)
    else:
        self.ioBind.request_io(iocb)