§
    ñyIf¼  ã                   ój   — 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d	e	d
dfd„Z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         úW/var/www/piapp/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    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   ÚmanagerÚreturnNc                 ó^   — t          | dt          ¦  «         t          | dt          ¦  «         d S )Nzmultiprocessing.managersÚmultiprocessing)r   r   r   )r    s    r   Úregisterr$   f   s9   € ÝØÐ+Õ-Pñô ð õ ˜WÐ&7Õ9SÑTÔTÐTÐTÐTr   )Úastroid.basesr   Úastroid.brain.helpersr   Úastroid.builderr   Úastroid.exceptionsr   Úastroid.managerr   Úastroid.nodes.scoped_nodesr	   r   r   r$   r   r   r   ú<module>r+      sÇ   ðð
 &Ð %Ð %Ð %Ð %Ð %Ø :Ð :Ð :Ð :Ð :Ð :Ø !Ð !Ð !Ð !Ð !Ð !Ø -Ð -Ð -Ð -Ð -Ð -Ø *Ð *Ð *Ð *Ð *Ð *Ø 2Ð 2Ð 2Ð 2Ð 2Ð 2ð#ð #ð #ðL0ð 0ð 0ðfU�nð U¨ð Uð Uð Uð Uð Uð Ur   