PyRQ.RRQ.RRQType.RRQType.LOCKED_LIST

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

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/GlobalActionsModel.py PyRQ(Download)

        qType = None
        if index==0:
            qType = RRQType.LOCKED_LIST
        elif index==1:
            qType = RRQType.MULTIPROCESSING_QUEUE
        elif index==2:
            qType = NoChoice()
        elif index==3:
            qType = random.choice([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE])

            qType = random.choice([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE])
        else:
            qType = RandomChoice([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE])
        params["queueType"] = qType
        params["queueCount"] = int(self.spinBox_CreateCount.value())

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/QueueActionDialog.py PyRQ(Download)

        iface = self.parent.getIface()
        typeMap = {
                   0:RRQType.LOCKED_LIST,
                   1:RRQType.MULTIPROCESSING_QUEUE,
                   2:None,

            queueType = typeMap[self.comboBox_CreateQueueType.currentIndex()]
            if queueType==-1:
                queueType = ran.sample([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE], 1)[0]
            ns.append(iface.create(maxsize=maxSize, timeout=timeout, queueType=queueType))
        result = ", ".join(ns)

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RQueue/RQueueWrapper.py PyRQ(Download)

    def __init__(self, queueType, getLogger, namespace, maxsize=0, pollInterval=None, quiet=True):
        self.namespace = namespace
        self.maxsize = maxsize
        if queueType==RRQType.LOCKED_LIST:
            q = RQueueImpl(namespace, getLogger, maxsize=maxsize, pollInterval=pollInterval, quiet=quiet)

src/p/y/PyRQ-0.4.1/PyRQ/Core/Messages/CREATE.py PyRQ(Download)

    def __init__(self, maxsize=0, queueType=None, pollInterval=None):
        self.maxsize = maxsize
        if queueType==None:
            queueType = RRQType.LOCKED_LIST
        self.queueType = queueType

src/p/y/PyRQ-0.4.1/PyRQ/Iface/PyRQIface.py PyRQ(Download)

    NOT_CONNECTED = "NOT_CONNECTED"
    MINIMUM_SOCKET_LATENCY = 3
    DEFAULT_QUEUETYPE = RRQType.LOCKED_LIST
    def __init__(self,
                 namespace=None,

src/p/y/PyRQ-0.4.1/Mock/mock.py PyRQ(Download)

    def __init__(self, queueType, getLogger, namespace, maxsize=0, pollInterval=None, quiet=True):
        self.namespace = namespace
        self.maxsize = maxsize
        if queueType==RRQType.LOCKED_LIST:
            q = MockQueue(namespace, getLogger, maxsize=maxsize, pollInterval=pollInterval, quiet=quiet)