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

All Samples(2)  |  Call(1)  |  Derive(0)  |  Import(1)

src/p/y/PyRQ-0.4.1/PyRQ/Iface/PyRQIface.py   PyRQ(Download)
from PyRQ.Core.Messages.MAXQSIZE import MAXQSIZE
from PyRQ.Core.Messages.PUT import PUT
from PyRQ.Core.Messages.QSIZE import QSIZE
from PyRQ.Core.Utils.PyRQTimeUtils import PyRQTimeUtils
from PyRQ.Iface.iPyRQIface import iPyRQIface
            c = self._connect()
            sockDetails = self._sock.getsockname()
            msg = QSIZE()
            try:
                qSize = c._write(msg, timeout=timeout)
                                    if not self._quiet: self._logger.debug("received ACK from: %(W)s"%{"W":sockDetails})
                                    return p
                                elif isinstance(p, (QSIZE, MAXQSIZE)):
                                    if not self._quiet: self._logger.debug("received %(P)s from: %(W)s"%{"P":p, "W":sockDetails})
                                    return p.size