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

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

src/p/y/PyRQ-0.4.1/Mock/mock.py   PyRQ(Download)
                            self._addClient(self, namespace)
                            self._stall("Messages.CREATE", clientData, quiet)
                            self._doResponse(self.request, marshaller.package(Messages.ACK(namespace)))
                        elif isinstance(pp, Messages.CLOSE):
                            with self.getClientLock():
            if debugger:
                uu = debugger.put_start(self.peerName, PyRQTimeUtils.getTime(), namespace, block, timeout)
            result = Messages.ACK(namespace)
            try:
                data = pp.data

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RRQ.py   PyRQ(Download)
                uu = debugger.create_end(self.peerName, PyRQTimeUtils.getTime(), namespace, uu=uu)
            if not quiet: self.logger.info("CREATE - namespace: %(R)s from %(C)s\r\n"%{"R":namespace, "C":socketDetails})
            self._doResponse(self.request, marshaller.package(Messages.ACK(namespace)))
        finally:
            if not quiet: self.logger.debug("CREATE - END @%(T)s"%{"T":PyRQTimeUtils.getTime()})
                if debugger:
                    uu = debugger.put_start(self.peerName, PyRQTimeUtils.getTime(), namespace, block, timeout, data)
                result = Messages.ACK(namespace)
                try:
                    if not quiet: self.logger.debug("PUT - %(D)s"%{"D":data})