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

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

            @staticmethod
    def decode(action, args, kwargs, params=None):
        if params==None:
            params = copy.deepcopy(ActionDecoder.DEFFAULT_PARAMS__STRINGS)
        params["uu"] = kwargs.get("uu", "")
        if action in iRRQDebuggerSink._getMethods():
            if action=="handle_end":
                params["response"] = args[0]
            elif action=="create_start":
                queueType = "list(synchronized)"
                if args[0]==RRQType.MULTIPROCESSING_QUEUE:
                    queueType = "multiprocessing.Queue"
                params["data"] = "QueueType: %(QT)s, maxSize: %(MS)s, pollingInterval: %(PI)s"%{"QT":queueType, "MS":args[1], "PI":args[2]}
                params["namespace_unknown"] = "?"
            elif action=="create_end":
                params["namespace"] = args[0]
            elif action=="addClient_start":
                params["namespace"] = args[0]
            elif action=="put_start":
                params["namespace"] = args[0]
                params["block"] = args[1]
                params["timeout"] = args[2]
                params["data"] = args[3]
            elif action=="put_end":
                params["namespace"] = args[0]
                params["result"] = args[1]
            elif action=="get_start":
                params["namespace"] = args[0]
                params["block"] = args[1]
                params["timeout"] = args[2]
            elif action=="get_end":
                params["namespace"] = args[0]
                params["result"] = args[1]
            elif action=="close_start":
                params["namespace"] = args[0]
            elif action=="close_end":
                params["namespace"] = args[0]
            elif action=="closeClients_start":
                params["namespace"] = args[0]
            elif action=="qsize_start":
                params["namespace"] = args[0]
            elif action=="qsize_end":
                params["namespace"] = args[0]
                params["result"] = args[1]
            elif action=="maxqsize_start":
                params["namespace"] = args[0]
            elif action=="maxqsize_end":
                params["namespace"] = args[0]
                params["result"] = args[1]
            elif action=="delay_start":
                params["where"] = args[0]
                params["duration"] = args[1]
            elif action=="query":
                namespaces = args[0]
                staleNamespaces = args[1]
                params["query"] = (namespaces, staleNamespaces)
        return params
        


src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RRQTab.py   PyRQ(Download)
    def _extractDecode(self, action, args, kwargs, decoderParams=None):
        params = ActionDecoder.decode(action, args, kwargs, params=decoderParams)
        ns = params["namespace"]
        nsId = ""
        if ns and len(ns)>0: