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

PyRQ.Core.Messages.QSIZE.QSIZE

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