ž
¨ÿ fé c @ ss d d d g Z d d l m Z d
g Z Gd d „ d e ƒ Z d d „ Z d d d „ Z Gd d „ d e ƒ Z
d
S( u Clientu Listeneru Pipei ( u Queuec B sk | Ee Z d Z d d d d d „ Z d d „ Z d d „ Z e d d „ ƒ Z d
d „ Z d d
„ Z
d S( u Listeneri c C s t | ƒ | _ d S( N( u Queueu _backlog_queue( u selfu addressu familyu backlog( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __init__- s u Listener.__init__c C s t | j j ƒ Œ S( N( u
Connectionu _backlog_queueu get( u self( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu accept0 s u Listener.acceptc C s
d | _ d S( N( u Noneu _backlog_queue( u self( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu close3 s u Listener.closec C s | j S( N( u _backlog_queue( u self( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu 6 s u Listener.c C s | S( N( ( u self( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __enter__8 s u Listener.__enter__c C s | j ƒ d S( N( u close( u selfu exc_typeu exc_valueu exc_tb( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __exit__; s u Listener.__exit__N( u __name__u
__module__u __qualname__u Noneu __init__u acceptu closeu propertyu addressu __enter__u __exit__( u
__locals__( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu Listener+ s c C s3 t ƒ t ƒ } } | j | | f ƒ t | | ƒ S( N( u Queueu putu
Connection( u addressu _inu _out( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu Client? s c C s/ t ƒ t ƒ } } t | | ƒ t | | ƒ f S( N( u Queueu
Connection( u duplexu au b( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu PipeE s c B sS | Ee Z d Z d d „ Z d d d „ Z d d „ Z d d „ Z d
d „ Z d S(
u
Connectionc C s< | | _ | | _ | j | _ | _ | j | _ | _ d S( N( u _outu _inu putu sendu
send_bytesu getu recvu
recv_bytes( u selfu _inu _out( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __init__L s u Connection.__init__g c C so | j j ƒ d k r d S| d k r) d S| j j j ƒ | j j j | ƒ | j j j ƒ | j j ƒ d k S( Ni g TF( u _inu qsizeu Trueu Falseu not_emptyu acquireu waitu release( u selfu timeout( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu pollR s u Connection.pollc C s d S( N( ( u self( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu close\ s u Connection.closec C s | S( N( ( u self( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __enter___ s u Connection.__enter__c C s | j ƒ d S( N( u close( u selfu exc_typeu exc_valueu exc_tb( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __exit__b s u Connection.__exit__N( u __name__u
__module__u __qualname__u __init__u pollu closeu __enter__u __exit__( u
__locals__( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu
ConnectionJ s
u
ConnectionNT( u __all__u queueu Queueu Noneu familiesu objectu Listeneru Clientu Trueu Pipeu
Connection( ( ( uE /opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu # s