OwlCyberSecurity - MANAGER
Edit File: brain_multiprocessing.cpython-311.pyc
� ��bg� � � � d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dl m Z d� Z d� Z e e � � d e � � e e � � d e � � d S ) � )� BoundMethod)�register_module_extender��parse)�InferenceError)�AstroidManager)� FunctionDefc �� � t d� � } t d� � } t |d � � � � � }t |d � � � � � }n# t t f$ r | cY S w xY w||fD ]i}|j � � � D ]M\ }}|� d� � r�|d }t |t � � rt ||� � }|| |< �N�j| S )Nzj from multiprocessing.managers import SyncManager def Manager(): return SyncManager() z� from multiprocessing.context import DefaultContext, BaseContext default = DefaultContext() base = BaseContext() �default�base�_r ) r �next�inferr � StopIteration�locals�items� startswith� isinstancer r )�module�node�contextr �key�values �t/builddir/build/BUILD/cloudlinux-venv-1.0.7/venv/lib/python3.11/site-packages/astroid/brain/brain_multiprocessing.py�_multiprocessing_transformr s& � � � �� �F� � � � �D���t�I��,�,�.�.�/�/���D��L�&�&�(�(�)�)���� �M� *� � � �� � � ����� �$�� � �� �+�+�+�-�-� � �J�C���~�~�c�"�"� ���!�H�E��%��-�-� 1� $�E�4�0�0�� �F�3�K�K� � �Ms �AA/ �/B�Bc � � t d� � S )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 r � � r �#_multiprocessing_managers_transformr 3 s � � �- �/ � / � /r zmultiprocessing.managers�multiprocessingN)� astroid.basesr �astroid.brain.helpersr �astroid.builderr �astroid.exceptionsr �astroid.managerr �astroid.nodes.scoped_nodesr r r r r r �<module>r' s� �� &� %� %� %� %� %� :� :� :� :� :� :� !� !� !� !� !� !� -� -� -� -� -� -� *� *� *� *� *� *� 2� 2� 2� 2� 2� 2�#� #� #�L0� 0� 0�f � ��N���0�2U�� � � � ��N���'�)C�� � � � r