Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(11)  |  Call(11)  |  Derive(0)  |  Import(0)

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RRQ.py   PyRQ(Download)
                        try:
                            self._doResponse(c.request, marshaller.package(Messages.CLOSED(namespace=namespace)))
                            PyRQTimeUtils.delayTime(1)
                            c.request.shutdown(socket.SHUT_WR)
                            c.request.close()
                    except Exception, _e:
                        pass
                PyRQTimeUtils.delayTime(1)
                qData.close()
                del clientData["queues"][namespace]
                                        break
                            #    Manual queue delay:
                            PyRQTimeUtils.delayTime(pollDelay)
                            if (maxTime!=None) and (PyRQTimeUtils.getTime()>=maxTime):
                                #    timeout!
                if debugger:
                    uu = debugger.delay_start(self.peerName, PyRQTimeUtils.getTime(), t, where)
            PyRQTimeUtils.delayTime(t)
            if (t!=None) and (t>0):
                if debugger:

src/p/y/PyRQ-0.4.1/Mock/mock.py   PyRQ(Download)
                            break
                if timeDelay!=None:
                    PyRQTimeUtils.delayTime(timeDelay)
        except Exception, _e:
#            self._logger.error("EEEEEEEERRRRRRRRROOOOOOOOORRRRRRRR.total: %(T)s.\r\n%(NS)s\r\n"%{"T":self._totalGot, "NS":traceback.format_exc()})
                    def closeClient(c):
                        try:
                            self._doResponse(c.request, marshaller.package(Messages.CLOSED(namespace=namespace)))
                            PyRQTimeUtils.delayTime(1)
                            c.request.shutdown(socket.SHUT_WR)
                    except Exception, _e:
                        pass
                PyRQTimeUtils.delayTime(1)
                qData.close()
                del clientData["queues"][namespace]
                                    break
                        #    Manual queue delay:
                        PyRQTimeUtils.delayTime(pollDelay)
                        if (maxTime!=None) and (PyRQTimeUtils.getTime()>=maxTime):
                            #    timeout!
                if debugger:
                    uu = debugger.delay_start(self.peerName, PyRQTimeUtils.getTime(), t, where)
            PyRQTimeUtils.delayTime(t)
            if (t!=None) and (t>0):
                if debugger:

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RQueue/RQueueImpl.py   PyRQ(Download)
                            break
                if timeDelay!=None:
                    PyRQTimeUtils.delayTime(timeDelay)
        except Exception, _e:
            raise

src/p/y/PyRQ-0.4.1/test/RRQReader/TestRRQReader.py   PyRQ(Download)
        self.logger.debug("DATA contains %(D)s items...\r\n"%{"D":numData})
        while dataQ.qsize()!=numData:
            PyRQTimeUtils.delayTime(1)
        putterThreads = []
        for i in xrange(0, numPutters):