e hddlmZddlmZddlmZddlmZddlm Z ddl m Z dZ dZ d e d d fd Zy ) ) BoundMethod)register_module_extenderparse)InferenceError)AstroidManager) FunctionDefctd}td} t|dj}t|dj}||fD]\}|j j D]=\}}|jdr|d}t|tr t||}|||<?^|S#ttf$r|cYSwxYw)Nzj from multiprocessing.managers import SyncManager def Manager(): return SyncManager() z from multiprocessing.context import DefaultContext, BaseContext default = DefaultContext() base = BaseContext() defaultbase_r) rnextinferr StopIterationlocalsitems startswith isinstancer r)modulenodecontextr keyvalues E/usr/lib/python3/dist-packages/astroid/brain/brain_multiprocessing.py_multiprocessing_transformr s  F   DtI,,./DL&&()$  ++++- JC~~c"!HE%-$E40F3K    M M * s8B55C C ctdS)Na import array import threading import multiprocessing.pool as pool import queue class Namespace(object): pass class Value(object): def __init__(self, typecode, value, lock=True): self._typecode = typecode self._value = value def get(self): return self._value def set(self, value): self._value = value def __repr__(self): return '%s(%r, %r)'%(type(self).__name__, self._typecode, self._value) value = property(get, set) def Array(typecode, sequence, lock=True): return array.array(typecode, sequence) class SyncManager(object): Queue = JoinableQueue = queue.Queue Event = threading.Event RLock = threading.RLock Lock = threading.Lock BoundedSemaphore = threading.BoundedSemaphore Condition = threading.Condition Barrier = threading.Barrier Pool = pool.Pool list = list dict = dict Value = Value Array = Array Namespace = Namespace __enter__ = lambda self: self __exit__ = lambda *args: args def start(self, initializer=None, initargs=None): pass def shutdown(self): pass rr#_multiprocessing_managers_transformr3s - / /rmanagerreturnNcHt|dtt|dty)Nzmultiprocessing.managersmultiprocessing)rrr)r s rregisterr$fs#+-PW&79STr) astroid.basesrastroid.brain.helpersrastroid.builderrastroid.exceptionsrastroid.managerrastroid.nodes.scoped_nodesr rrr$rrrr+s; &:!-*2#L0fUnUUr