Module Expr Str Import alias Import alias TryExcept body Import alias identifier handlers ExceptHandler type NameLoad body Import alias ImportFrom alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Str Assign NameStore Str Assign NameStore Str Assign NameStore Str Assign NameStore Num ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults Num Num NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assert CompareIn NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr ListComp NameLoad comprehension NameStore AttributeLoad NameLoad attr CompareNotEq NameLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call NameLoad Call NameLoad BinOpSub Call NameLoad AttributeLoad NameLoad attr Num NameLoad Num Assign AttributeStore NameLoad attr Call NameLoad NameLoad Num Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body With AttributeLoad NameLoad attr body If AttributeLoad NameLoad attr body Return Assign NameStore Lambda arguments args NameParam defaults Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Call NameLoad NameLoad Assign AttributeStore NameLoad attr ListComp Call NameLoad Call NameLoad NameLoad keyword AttributeLoad NameLoad attr keyword NameLoad comprehension NameStore Call NameLoad AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Dict For NameStore AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr Str Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Call NameLoad NameLoad keyword BinOpMult Num Num keyword NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad keyword NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Assign NameStore Call NameLoad NameLoad Str Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword Str keyword NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword Str keyword NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword Str keyword NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword Str keyword NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword Str keyword NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad Num body Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Call NameLoad NameLoad BinOpSub AttributeLoad NameLoad attr Num Num Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad Num body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Lambda arguments args defaults Call NameLoad NameLoad For NameStore NameLoad body Assign NameStore Call NameLoad NameLoad Str Num Assign NameStore Call NameLoad NameLoad Str NameLoad Expr Call AttributeLoad SubscriptLoad SubscriptLoad NameLoad Index NameLoad Index NameLoad attr NameLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults Num Num body Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Call NameLoad NameLoad BinOpSub AttributeLoad NameLoad attr Num Num Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Return Call AttributeLoad NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults Num Num body Expr Str Return Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults Num body Expr Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Return Call AttributeLoad NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults Num body Expr Call AttributeLoad NameLoad attr Return Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str If CompareIn NameLoad AttributeLoad NameLoad attr body Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Call NameLoad NameLoad keyword BinOpMult Num Num keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str If CompareNotIn NameLoad AttributeLoad NameLoad attr body Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If AttributeLoad NameLoad attr body Return Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return Expr ListComp Call AttributeLoad NameLoad attr comprehension NameStore AttributeLoad NameLoad attr For NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults Num Num NameLoad NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad NameLoad NameLoad NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad Str Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad keyword NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body With AttributeLoad NameLoad attr body If AttributeLoad NameLoad attr body Return Expr Call AttributeLoad NameLoad attr If UnaryOpNot Call NameLoad NameLoad Str body Assign AttributeStore NameLoad attr Call NameLoad GeneratorExp TupleLoad NameLoad ListLoad comprehension NameStore AttributeLoad NameLoad attr If UnaryOpNot Call NameLoad NameLoad Str body Assign AttributeStore NameLoad attr Call NameLoad GeneratorExp TupleLoad NameLoad NameLoad comprehension NameStore AttributeLoad NameLoad attr If UnaryOpNot Call NameLoad NameLoad Str body Assign AttributeStore NameLoad attr Call NameLoad GeneratorExp TupleLoad NameLoad Dict comprehension NameStore AttributeLoad NameLoad attr For NameStore AttributeLoad NameLoad attr body For NameStore ListComp NameLoad comprehension NameStore AttributeLoad NameLoad attr CompareNotEq NameLoad NameLoad body Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad ListLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Return With Call NameLoad NameLoad Str NameStore body Assign TupleStore AttributeStore NameLoad attr AttributeStore NameLoad attr AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad With Call NameLoad NameLoad Str NameStore body Assign NameStore TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareIs NameLoad NameLoad body Return NameLoad orelse If BoolOpAnd Call NameLoad NameLoad NameLoad CompareEq Call NameLoad NameLoad Num body Return NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad Num body If Call AttributeLoad NameLoad attr NameLoad body Return If CompareEq NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad keyword NameLoad orelse Expr Call NameLoad NameLoad BinOpAdd AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body If Call AttributeLoad NameLoad attr NameLoad body Return If CompareEq NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse Expr Call NameLoad NameLoad BinOpAdd AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults Num Num body Assign NameStore NameLoad If CompareEq NameLoad AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad orelse Assign NameStore Call AttributeLoad NameLoad attr Call NameLoad NameLoad BinOpAdd AttributeLoad NameLoad attr Str NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad ListLoad If BoolOpAnd CompareEq NameLoad Num CompareIs NameLoad NameLoad CompareGt Call NameLoad NameLoad Num body Return Call AttributeLoad NameLoad attr Num orelse If BoolOpAnd CompareGt NameLoad Num CompareEq Call NameLoad NameLoad Num CompareGt Call NameLoad NameLoad Num body Return SubscriptLoad NameLoad Slice NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body If Call AttributeLoad NameLoad attr NameLoad body Return If CompareEq NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad keyword NameLoad orelse Expr Call NameLoad NameLoad BinOpAdd AttributeLoad NameLoad attr Str NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Expr Call AttributeLoad NameLoad attr Assign TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If CompareIs NameLoad NameLoad body For NameStore AttributeLoad NameLoad attr body If CompareNotIn NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad ListLoad If CompareNotIn NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad Dict For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad If BoolOpOr UnaryOpNot SubscriptLoad AttributeLoad NameLoad attr Index NameLoad CompareGtE Call NameLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad NameLoad NameLoad body TryExcept body Expr Call AttributeLoad NameLoad attr NameLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad ListLoad If UnaryOpNot SubscriptLoad AttributeLoad NameLoad attr Index NameLoad body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body Expr Call AttributeLoad SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad attr NameLoad Assign NameStore Call NameLoad ListComp Call NameLoad NameLoad comprehension NameStore Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr If BoolOpOr CompareGtE NameLoad NameLoad NameLoad body For TupleStore NameStore NameStore Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr body TryExcept body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad ListLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults Num Num body Expr Str Expr Call AttributeLoad NameLoad attr If CompareLt NameLoad Num body Assign NameStore Num Assign NameStore ListLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword Lambda arguments args NameParam defaults CompareEq NameLoad AttributeLoad NameLoad attr keyword NameLoad For NameStore NameLoad body Assign NameStore BinOpSub NameLoad Call NameLoad NameLoad If CompareLtE NameLoad Num body Break Assign NameStore NameLoad TryExcept body Assign NameStore Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If CompareIs NameLoad NameLoad body Continue If UnaryOpNot Call NameLoad NameLoad NameLoad body Assign NameStore ListLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad If CompareEq NameLoad Num body If CompareEq Call NameLoad NameLoad Num body Return Return SubscriptLoad NameLoad Index Num Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults Num body Return Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr ListLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareIn NameLoad AttributeLoad NameLoad attr body Return Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad ListLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Dict For NameStore AttributeLoad NameLoad attr body If CompareNotEq NameLoad NameLoad body Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad ListLoad Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad ListLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareNotIn NameLoad AttributeLoad NameLoad attr body Return Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad For NameStore AttributeLoad NameLoad attr body If CompareNotEq NameLoad NameLoad body Delete SubscriptDel SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Num Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad While CompareGt Call NameLoad NameLoad Num body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list decorator_list
N/A N/A 
Copyright (c) 2013 Qin Xuye <qin@qinxuye.me>

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Created on 2014-4-27

@author: chine
 N/A os N/A threading N/A N/A N/A cPickle pickle N/A N/A N/A ImportError N/A N/A pickle collections defaultdict N/A socket cola.core.rpc client_call cola.core.utils get_rpc_prefix cola.core.mq.store Store cola.core.mq.distributor Distributor N/A MQ_STATUS_FILENAME mq.status N/A PRIORITY_STORE_FN store N/A BACKUP_STORE_FN backup N/A INCR_STORE_FN inc N/A CACHE_SIZE 20 LocalMessageQueueNode N/A object N/A N/A 
    Message queue node which only handle local mq operations
    can also be in charge of handling the remote call.
    This node includes several storage such as priority storage
    for each priority, incremental storage as well as the
    backup storage. Each storage is an instance of
    :class:`~cola.core.mq.store.Store`.
     __init__ N/A N/A self base_dir rpc_server addr addrs copies n_priorities deduper app_name N/A 1 3 None None N/A N/A N/A self dir_ base_dir N/A N/A self rpc_server rpc_server N/A N/A addr addrs N/A N/A self addr addr N/A N/A self addrs addrs N/A N/A self other_addrs N/A n N/A n N/A self addrs N/A n N/A self addr N/A N/A self copies N/A max N/A min N/A N/A len N/A self addrs 1 copies 0 N/A N/A self n_priorities N/A max n_priorities 1 N/A N/A self deduper deduper N/A N/A self app_name app_name N/A N/A self _lock N/A N/A threading Lock N/A N/A N/A self _register_rpc N/A N/A self inited False N/A init N/A N/A self N/A N/A N/A N/A self _lock N/A N/A N/A self inited N/A N/A N/A get_priority_store_dir N/A N/A N/A priority N/A N/A N/A N/A os path join N/A self dir_ PRIORITY_STORE_FN N/A str priority N/A N/A self priority_stores N/A N/A Store N/A get_priority_store_dir i deduper N/A self deduper mkdirs True N/A i N/A range N/A self n_priorities N/A backup_store_dir N/A N/A N/A os path join N/A self dir_ BACKUP_STORE_FN N/A N/A self backup_stores N/A N/A backup_addr N/A self other_addrs N/A N/A backup_node_dir N/A N/A backup_addr replace : _ N/A backup_path N/A N/A N/A os path join backup_store_dir backup_node_dir N/A N/A N/A self backup_stores N/A backup_addr N/A Store backup_path size N/A 512 1024 mkdirs True N/A inc_store_dir N/A N/A N/A os path join N/A self dir_ INCR_STORE_FN N/A N/A self inc_store N/A Store inc_store_dir mkdirs True N/A N/A self inited True N/A _register_rpc N/A N/A self N/A N/A N/A N/A self rpc_server N/A N/A N/A N/A self register_rpc self N/A self rpc_server app_name N/A self app_name N/A register_rpc N/A N/A cls node rpc_server app_name N/A None N/A N/A prefix N/A get_rpc_prefix app_name mq N/A N/A N/A rpc_server register_function N/A node put_proxy name put prefix prefix N/A N/A N/A rpc_server register_function N/A node batch_put_proxy name batch_put prefix prefix N/A N/A N/A rpc_server register_function N/A node put_backup_proxy name put_backup prefix prefix N/A N/A N/A rpc_server register_function N/A node get_proxy name get prefix prefix N/A N/A N/A rpc_server register_function N/A node exist name exist prefix prefix N/A classmethod put N/A N/A self objs force priority N/A False 0 N/A N/A N/A N/A self init N/A priority N/A max N/A min priority N/A N/A self n_priorities 1 0 N/A priority_store N/A N/A self priority_stores N/A priority N/A N/A N/A priority_store put objs force force N/A put_proxy N/A N/A self pickled_objs force priority N/A False 0 N/A N/A 
        The objects from remote call should be pickled to
        avoid the serialization error.

        :param pickled_objs: the pickled objects to put into mq
        :param force: if set to True will be directly put into mq without
               checking the duplication
        :param priority: the priority queue to put into
         N/A objs N/A N/A pickle loads pickled_objs N/A N/A N/A self put objs force force priority priority N/A batch_put N/A N/A self objs N/A N/A N/A N/A N/A self init N/A puts N/A defaultdict N/A N/A N/A N/A N/A defaultdict list N/A obj objs N/A N/A priority N/A getattr obj priority 0 N/A force N/A getattr obj force False N/A N/A N/A N/A N/A puts N/A priority N/A force append obj N/A N/A priority m N/A N/A puts iteritems N/A N/A N/A force obs N/A N/A m iteritems N/A N/A N/A N/A self put obs force force priority priority N/A batch_put_proxy N/A N/A self pickled_objs N/A N/A N/A 
        Unlike the :func:`put`, this method will check the ``priority``
        of a single object to decide which priority queue to put into.
         N/A objs N/A N/A pickle loads pickled_objs N/A N/A N/A self batch_put objs N/A put_backup N/A N/A self addr objs force N/A False N/A N/A N/A N/A self init N/A backup_store N/A N/A self backup_stores N/A addr N/A N/A N/A backup_store put objs force force N/A put_backup_proxy N/A N/A self addr pickled_objs force N/A False N/A N/A 
        In the Cola backup mechanism, an object will not only be
        put into a hash ring node, and also be put into the next
        hash ring node which marked as a backup node. To the backup node,
        it will remember the previous node's name.

        :param addr: the node address to backup
        :param pickled_objs: pickled objects
        :param force: if True will be put into queue without checking duplication
         N/A objs N/A N/A pickle loads pickled_objs N/A N/A N/A self put_backup addr objs force force N/A put_inc N/A N/A self objs force N/A True N/A N/A N/A N/A self init N/A N/A N/A N/A self inc_store put objs force force N/A get N/A N/A self size priority N/A 1 0 N/A N/A N/A N/A self init N/A priority N/A max N/A min priority N/A N/A self n_priorities 1 0 N/A priority_store N/A N/A self priority_stores N/A priority N/A N/A N/A priority_store get size size N/A get_proxy N/A N/A self size priority N/A 1 0 N/A N/A 
        Get the objects from the specific priority queue.

        :param size: if size == 1 will be the right object,
               else will be the objects list
        :param priority:
        :return: unpickled objects
         N/A N/A N/A pickle dumps N/A N/A self get size size priority priority N/A get_backup N/A N/A self addr size N/A 1 N/A N/A N/A N/A self init N/A backup_store N/A N/A self backup_stores N/A addr N/A N/A N/A backup_store get size size N/A get_inc N/A N/A self size N/A 1 N/A N/A N/A N/A self init N/A N/A N/A N/A self inc_store get size size N/A add_node N/A N/A self addr N/A N/A N/A 
        When a new message queue node is in, firstly will add the address
        to the known queue nodes, then a backup for this node will be created.
         N/A N/A addr N/A self addrs N/A N/A N/A N/A N/A N/A self addrs append addr N/A backup_store_dir N/A N/A N/A os path join N/A self dir_ BACKUP_STORE_FN N/A backup_node_dir N/A N/A addr replace : _ N/A backup_path N/A N/A N/A os path join backup_store_dir backup_node_dir N/A N/A N/A self backup_stores N/A addr N/A Store backup_path size N/A 512 1024 mkdirs True N/A remove_node N/A N/A self addr N/A N/A N/A 
        For the removed node, this method is for the cleaning job including
        shutting down the backup storage for the removed node.
         N/A N/A addr N/A self addrs N/A N/A N/A N/A N/A N/A self addrs remove addr N/A N/A N/A N/A N/A self backup_stores N/A addr shutdown N/A N/A N/A self backup_stores N/A addr N/A exist N/A N/A self obj N/A N/A N/A N/A self deduper N/A N/A N/A N/A N/A self deduper exist N/A str obj N/A False N/A shutdown N/A N/A self N/A N/A N/A N/A N/A self inited N/A N/A N/A N/A N/A N/A store shutdown N/A store N/A self priority_stores N/A backup_store N/A N/A N/A self backup_stores values N/A N/A N/A N/A backup_store shutdown N/A N/A N/A N/A self inc_store shutdown N/A N/A MessageQueueNodeProxy N/A object N/A N/A 
    This class maintains an instance of :class:`~cola.core.mq.node.LocalMessageQueueNode`,
    and provide `PUT` and `GET` relative method.
    In each mq operation, it will execute a local or remote call by judging the address.
    The Remote call will actually send a RPC to the destination worker's instance which
    execute the method provided by :class:`~cola.core.mq.node.LocalMessageQueueNode`.

    Besides, this class also maintains an instance of :class:`~cola.core.mq.distributor.Distributor`
    which holds a hash ring. To an object of `PUT` operation, the object should be distributed to
    the destination according to the mechanism of the hash ring. Remember, a cache will be created
    to avoid the frequent write operations which may cause high burden of a message queue node.
    To `GET` operation, the mq will just fetch an object from the local node,
    or request from other nodes if local one's objects are exhausted.
     __init__ N/A N/A self base_dir rpc_server addr addrs copies n_priorities deduper app_name logger N/A 1 3 None None None N/A N/A N/A self dir_ base_dir N/A N/A self addr_ addr N/A N/A self addrs N/A list addrs N/A N/A self mq_node N/A LocalMessageQueueNode base_dir rpc_server addr addrs copies copies n_priorities n_priorities deduper deduper app_name app_name N/A N/A self distributor N/A Distributor addrs copies copies N/A N/A self logger logger N/A N/A self prefix N/A get_rpc_prefix app_name mq N/A N/A self _lock N/A N/A threading Lock N/A N/A self inited False N/A register_rpc N/A N/A cls node rpc_server app_name N/A None N/A N/A N/A N/A LocalMessageQueueNode register_rpc N/A node mq_node rpc_server app_name app_name N/A classmethod init N/A N/A self N/A N/A N/A N/A self _lock N/A N/A N/A self inited N/A N/A N/A N/A N/A self load N/A N/A N/A hasattr self caches N/A N/A N/A self caches N/A dict N/A N/A addr N/A N/A addr N/A self addrs N/A N/A N/A hasattr self caches_inited N/A N/A N/A self caches_inited N/A dict N/A N/A addr False N/A addr N/A self addrs N/A N/A N/A hasattr self backup_caches N/A N/A N/A self backup_caches N/A dict N/A N/A addr N/A N/A addr N/A self addrs N/A addr N/A self addrs N/A N/A other_addr N/A n N/A n N/A self addrs N/A addr n N/A N/A N/A N/A N/A self backup_caches N/A addr N/A other_addr N/A N/A N/A N/A N/A self mq_node init N/A N/A self inited True N/A load N/A N/A self N/A N/A N/A save_file N/A N/A N/A os path join N/A self dir_ MQ_STATUS_FILENAME N/A N/A N/A N/A N/A os path exists save_file N/A N/A N/A N/A open save_file r f N/A N/A N/A N/A self caches N/A self caches_inited N/A self backup_caches N/A N/A pickle load f N/A save N/A N/A self N/A N/A N/A N/A N/A self inited N/A N/A N/A save_file N/A N/A N/A os path join N/A self dir_ MQ_STATUS_FILENAME N/A N/A open save_file w f N/A N/A t N/A N/A self caches N/A self caches_inited N/A self backup_caches N/A N/A N/A pickle dump t f N/A _check_empty N/A N/A self objs N/A N/A N/A N/A objs None N/A N/A True N/A N/A N/A N/A isinstance objs list N/A N/A len objs 0 N/A N/A True N/A False N/A _remote_or_local_put N/A N/A self addr objs force priority N/A False 0 N/A N/A N/A N/A self _check_empty objs N/A N/A N/A N/A addr N/A self addr_ N/A N/A N/A N/A N/A self mq_node put objs force force priority priority N/A N/A N/A client_call addr N/A N/A self prefix put N/A N/A pickle dumps objs force priority N/A _remote_or_local_batch_put N/A N/A self addr objs N/A N/A N/A N/A N/A self _check_empty objs N/A N/A N/A N/A addr N/A self addr_ N/A N/A N/A N/A N/A self mq_node batch_put objs N/A N/A N/A client_call addr N/A N/A self prefix batch_put N/A N/A pickle dumps objs N/A _remote_or_local_get N/A N/A self addr size priority N/A 1 0 N/A N/A objs None N/A N/A addr N/A self addr_ N/A N/A objs N/A N/A N/A self mq_node get size size priority priority N/A N/A objs N/A N/A pickle loads N/A client_call addr N/A N/A self prefix get size priority N/A addr_caches N/A N/A N/A self caches get addr N/A N/A N/A N/A size 1 N/A objs None N/A N/A len addr_caches 0 N/A N/A N/A N/A addr_caches pop 0 N/A N/A N/A N/A size 1 N/A N/A len objs 0 N/A N/A len addr_caches 0 N/A N/A N/A addr_caches N/A size N/A objs N/A _remote_or_local_put_backup N/A N/A self addr backup_addr objs force N/A False N/A N/A N/A N/A self _check_empty objs N/A N/A N/A N/A addr N/A self addr_ N/A N/A N/A N/A N/A self mq_node put_backup backup_addr objs force force N/A N/A N/A client_call addr N/A N/A self prefix put_backup backup_addr N/A N/A pickle dumps objs force N/A put N/A N/A self objects flush N/A False N/A N/A 
        Put a bunch of objects into the mq. The objects will be distributed
        to different mq nodes according to the instance of
        :class:`~cola.core.mq.distributor.Distributor`.
        There also exists a cache which will not flush out unless the parameter flush
        is true or a single destination cache is full.

        :param objects: objects to put into mq, an object is mostly the instance of
               :class:`~cola.core.unit.Url` or :class:`~cola.core.unit.Bundle`
        :param flush: flush out the cache all if set to true
         N/A N/A N/A self init N/A N/A addrs_objs backup_addrs_objs N/A N/A N/A self distributor distribute objects N/A N/A flush True N/A N/A addr N/A self addrs N/A N/A N/A addr addrs_objs N/A N/A N/A addrs_objs N/A addr N/A N/A N/A addr backup_addrs_objs N/A N/A N/A backup_addrs_objs N/A addr N/A N/A N/A addr objs N/A N/A addrs_objs iteritems N/A N/A N/A N/A N/A N/A self caches N/A addr extend objs N/A N/A N/A N/A N/A self caches_inited N/A addr N/A N/A len N/A N/A self caches N/A addr CACHE_SIZE flush N/A N/A N/A N/A N/A N/A self _remote_or_local_batch_put addr N/A N/A self caches N/A addr N/A N/A N/A N/A socket error N/A e N/A N/A N/A self logger N/A N/A N/A N/A N/A self logger exception e N/A N/A N/A N/A self caches N/A addr N/A N/A N/A N/A N/A self caches_inited N/A addr N/A N/A N/A N/A self caches_inited N/A addr True N/A N/A addr m N/A N/A backup_addrs_objs iteritems N/A N/A N/A backup_addr objs N/A N/A m iteritems N/A N/A N/A N/A N/A N/A N/A self backup_caches N/A addr N/A backup_addr extend objs N/A size N/A sum N/A N/A len obs N/A obs N/A N/A N/A N/A self backup_caches N/A addr values N/A N/A N/A size CACHE_SIZE flush N/A N/A N/A backup_addr objs N/A N/A N/A N/A self backup_caches N/A addr iteritems N/A N/A N/A N/A N/A N/A self _remote_or_local_put_backup addr backup_addr objs N/A N/A N/A N/A socket error N/A e N/A N/A N/A self logger N/A N/A N/A N/A N/A self logger exception e N/A N/A N/A N/A N/A self backup_caches N/A addr N/A backup_addr N/A N/A get N/A N/A self size priority N/A 1 0 N/A N/A 
        Get a bunch of objects from the message queue.
        This method will try to fetch objects from local node as much as wish.
        If not enough, will try to fetch from the other nodes.

        :param size: the objects wish to fetch
        :param priority: the priority queue which wants to fetch from
        :return: the objects which to handle
         N/A N/A N/A self init N/A N/A size 1 N/A N/A size 1 N/A results N/A N/A _addrs N/A sorted N/A self addrs key N/A N/A N/A k N/A N/A k N/A self addr_ reverse True N/A addr _addrs N/A N/A left N/A size N/A len results N/A N/A left 0 N/A N/A N/A objs None N/A N/A N/A objs N/A N/A self _remote_or_local_get addr size left priority priority N/A N/A N/A N/A socket error N/A e N/A N/A N/A self logger N/A N/A N/A N/A N/A self logger exception e N/A N/A objs None N/A N/A N/A N/A N/A isinstance objs list N/A N/A objs N/A objs N/A N/A N/A results extend objs N/A N/A size 1 N/A N/A N/A N/A len results 0 N/A N/A N/A N/A results N/A 0 N/A results N/A put_inc N/A N/A self objs N/A N/A N/A N/A N/A N/A self mq_node put_inc objs N/A get_inc N/A N/A self size N/A 1 N/A N/A N/A N/A N/A self mq_node get_inc size size N/A flush N/A N/A self N/A N/A N/A N/A N/A self put N/A flush True N/A add_node N/A N/A self addr N/A N/A N/A N/A addr N/A self addrs N/A N/A N/A N/A N/A self init N/A N/A N/A N/A self distributor add_node addr N/A N/A N/A N/A self addrs append addr N/A N/A N/A self caches N/A addr N/A N/A N/A N/A self caches_inited N/A addr False N/A N/A N/A self backup_caches N/A addr N/A N/A o_addr N/A self addrs N/A N/A N/A o_addr addr N/A N/A N/A N/A N/A self backup_caches N/A addr N/A o_addr N/A N/A N/A N/A N/A self backup_caches N/A o_addr N/A addr N/A N/A N/A N/A N/A self mq_node add_node addr N/A remove_node N/A N/A self addr N/A N/A N/A N/A addr N/A self addrs N/A N/A N/A N/A N/A self init N/A N/A N/A N/A self distributor remove_node addr N/A N/A N/A N/A self addrs remove addr N/A N/A N/A N/A self mq_node batch_put N/A N/A self caches N/A addr N/A N/A N/A self caches N/A addr N/A N/A N/A self caches_inited N/A addr N/A N/A N/A self backup_caches N/A addr N/A o_addr N/A self addrs N/A N/A N/A o_addr addr N/A N/A N/A N/A N/A self backup_caches N/A o_addr N/A addr N/A N/A N/A self flush N/A BATCH_SIZE 10 N/A objs N/A N/A N/A self mq_node get_backup addr size BATCH_SIZE N/A N/A N/A len objs 0 N/A N/A N/A N/A N/A self mq_node batch_put objs N/A objs N/A N/A N/A self mq_node get_backup addr size BATCH_SIZE N/A N/A N/A N/A self mq_node remove_node addr N/A exist N/A N/A self obj N/A N/A N/A N/A N/A N/A self mq_node exist obj N/A shutdown N/A N/A self N/A N/A N/A N/A N/A self inited N/A N/A N/A N/A N/A N/A self mq_node shutdown N/A N/A N/A self save N/A __enter__ N/A N/A self N/A N/A N/A self N/A __exit__ N/A N/A self type_ value traceback N/A N/A N/A N/A N/A self shutdown N/A N/A