o b$ @sZddlZddlZddlmZejdkZddZddZeejdeeejd edS) N) exceptions)cCstd}ts |Std}zt|d}t|d}Wn tjy,|YSw||fD]&}|jD]\}}| drBq8|d}t |tj rRt ||}|||<q8q1|S)Nzj from multiprocessing.managers import SyncManager def Manager(): return SyncManager() z from multiprocessing.context import DefaultContext, BaseContext default = DefaultContext() base = BaseContext() defaultbase_r) astroidparsePY34nextZinferrZInferenceErrorlocalsitems startswith isinstance FunctionDefZ BoundMethod)modulenodecontextrkeyvaluerb/var/www/secure340b-portal/env/lib/python3.10/site-packages/astroid/brain/brain_multiprocessing.py_multiprocessing_transforms0      rcCs tdS)Na import array import threading import multiprocessing.pool as pool import six 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 = six.moves.queue.Queue Event = threading.Event RLock = threading.RLock 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 rrrr#_multiprocessing_managers_transform8srzmultiprocessing.managersmultiprocessing) sysrr version_infor rrZregister_module_extenderZMANAGERrrrrs  )3