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

All Samples(27)  |  Call(27)  |  Derive(0)  |  Import(0)
@summary: Raised when the PyRQ has closed.

src/p/y/PyRQ-0.4.1/PyRQ/Iface/PyRQIface.py   PyRQ(Download)
            if (self._closed==True) or (self._namespace in PyRQIface.closedQueues.keys()):
                if not self._quiet: self._logger.error("close already closed")
                raise Errors.ClosedError(namespace=self._namespace)
            c = self._connect()
            try:
            if self._closed==True:
                if not self._quiet: self._logger.error("create already closed")
                raise Errors.ClosedError(namespace=self._namespace)
            c = self._connect()
            sockDetails = self._sock.getsockname()
            if (self._closed==True) or (self._namespace in PyRQIface.closedQueues.keys()):
                if not self._quiet: self._logger.error("get already closed")
                raise Errors.ClosedError(namespace=self._namespace)
            namespace = self._namespace
            c = self._connect()
            if (self._closed==True) or (self._namespace in PyRQIface.closedQueues.keys()):
                if not self._quiet: self._logger.error("put already closed")
                raise Errors.ClosedError(namespace=self._namespace)
            namespace = self._namespace
            c = self._connect()
            if (self._closed==True) or (self._namespace in PyRQIface.closedQueues.keys()):
                if not self._quiet: self._logger.error("qsize already closed")
                raise Errors.ClosedError(namespace=self._namespace)
            namespace = self._namespace
            c = self._connect()

src/p/y/PyRQ-0.4.1/Mock/mock.py   PyRQ(Download)
    def put(self, data, block=True, timeout=None):
        self._testPickleability(data)
        with self._lock:
            if self._closed==True:
                raise Errors.ClosedError()
        finally:
            if self._closed==True:
                raise Errors.ClosedError()
        with self._lock:
            l = len(self._data)
    def qsize(self):
        with self._lock:
            if self._closed==True:
                raise Errors.ClosedError()
            return len(self._data)
    def close(self):
        with self._lock:
            if self._closed==True:
                raise Errors.ClosedError()
                                q = clientData["queues"][namespace].q()
                            except Exception, _e:
                                raise Errors.ClosedError()
                            else:
                                try:

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RRQ.py   PyRQ(Download)
                                    q = clientData["queues"][namespace].q()
                                except Exception, _e:
                                    raise Errors.ClosedError()
                                else:
                                    try:
                result = Errors.NoSuchQueue(namespace)
                if namespace in clientData["stale-queues"]:
                    result = Errors.ClosedError()
            else:
                q = clientData["queues"][namespace].q()
                        #    Now we manually close otherwise we have thread-leakage!
                        if not quiet: self.logger.info("Manual close detected, performing clean-close, propagating ClosedError back to client.\r\n")
                        result = Errors.ClosedError()
                    else:
                        result = Messages.GOT(data)
                    result = Errors.NoSuchQueue(namespace)
                    if namespace in clientData["stale-queues"]:
                        result = Errors.ClosedError()
                else:
                    size = clientData["queues"][namespace].qsize()
                    result = Errors.NoSuchQueue(namespace)
                    if namespace in clientData["stale-queues"]:
                        result = Errors.ClosedError()
                else:
                    size = clientData["queues"][namespace].maxQSize()

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueWriter/QueueWriter.py   PyRQ(Download)
            marshaller = self._marshaller
        if not target:
            raise Errors.ClosedError()
        if not marshaller:
            raise NoMarshallerError()
            if not self._quiet: sys.stderr.write("%(N)s Error sending data:\r\n%(T)s\r\n"%{"N":self._name, "T":traceback.format_exc()})
            self.close()
            raise Errors.ClosedError()
        else:
            pass

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RQueue/RQueueImpl.py   PyRQ(Download)
    def put(self, data, block=True, timeout=None):
        self._testPickleability(data)
        with self._lock:
            if self._closed==True:
                raise Errors.ClosedError()
        finally:
            if self._closed==True:
                raise Errors.ClosedError()
        with self._lock:
            l = len(self._data)
    def qsize(self):
        with self._lock:
            if self._closed==True:
                raise Errors.ClosedError()
            return len(self._data)
    def close(self):
        with self._lock:
            if self._closed==True:
                raise Errors.ClosedError()