§
    ¡Èóc‹  ã                   ó®   — d dl mZ d dlmZ d dlmZ d dlmZ d dlm	Z	 d dl
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 | cY S w xY w||fD ]i}|j                             ¦   «         D ]M\  }}|                     d¦  «        rŒ|d         }t          |t          ¦  «        rt          ||¦  «        }|| |<   Œ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         úClib/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ØˆF3‰KˆKð		 ð €Ms    AA/ Á/BÂBc                  ó    — 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   zmultiprocessing.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ð#ð #ð #ðL0ð 0ð 0ðf Ð Ø€NÑÔÐ0Ð2Uñô ð ð Ð Ø€NÑÔÐ'Ð)Cñô ð ð ð r   