Current Dir: /snap/core22/2955/usr/lib/python3.10/__pycache__/

[FILE] abc.cpython-310.pyc [ edit | delete | rename ]
[FILE] aifc.cpython-310.pyc [ edit | delete | rename ]
[FILE] antigravity.cpython-310.pyc [ edit | delete | rename ]
[FILE] argparse.cpython-310.pyc [ edit | delete | rename ]
[FILE] ast.cpython-310.pyc [ edit | delete | rename ]
[FILE] asynchat.cpython-310.pyc [ edit | delete | rename ]
[FILE] asyncore.cpython-310.pyc [ edit | delete | rename ]
[FILE] base64.cpython-310.pyc [ edit | delete | rename ]
[FILE] bdb.cpython-310.pyc [ edit | delete | rename ]
[FILE] binhex.cpython-310.pyc [ edit | delete | rename ]
[FILE] bisect.cpython-310.pyc [ edit | delete | rename ]
[FILE] bz2.cpython-310.pyc [ edit | delete | rename ]
[FILE] calendar.cpython-310.pyc [ edit | delete | rename ]
[FILE] cgi.cpython-310.pyc [ edit | delete | rename ]
[FILE] cgitb.cpython-310.pyc [ edit | delete | rename ]
[FILE] chunk.cpython-310.pyc [ edit | delete | rename ]
[FILE] cmd.cpython-310.pyc [ edit | delete | rename ]
[FILE] code.cpython-310.pyc [ edit | delete | rename ]
[FILE] codecs.cpython-310.pyc [ edit | delete | rename ]
[FILE] codeop.cpython-310.pyc [ edit | delete | rename ]
[FILE] colorsys.cpython-310.pyc [ edit | delete | rename ]
[FILE] compileall.cpython-310.pyc [ edit | delete | rename ]
[FILE] configparser.cpython-310.pyc [ edit | delete | rename ]
[FILE] contextlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] contextvars.cpython-310.pyc [ edit | delete | rename ]
[FILE] copy.cpython-310.pyc [ edit | delete | rename ]
[FILE] copyreg.cpython-310.pyc [ edit | delete | rename ]
[FILE] cProfile.cpython-310.pyc [ edit | delete | rename ]
[FILE] crypt.cpython-310.pyc [ edit | delete | rename ]
[FILE] csv.cpython-310.pyc [ edit | delete | rename ]
[FILE] dataclasses.cpython-310.pyc [ edit | delete | rename ]
[FILE] datetime.cpython-310.pyc [ edit | delete | rename ]
[FILE] decimal.cpython-310.pyc [ edit | delete | rename ]
[FILE] difflib.cpython-310.pyc [ edit | delete | rename ]
[FILE] dis.cpython-310.pyc [ edit | delete | rename ]
[FILE] doctest.cpython-310.pyc [ edit | delete | rename ]
[FILE] enum.cpython-310.pyc [ edit | delete | rename ]
[FILE] filecmp.cpython-310.pyc [ edit | delete | rename ]
[FILE] fileinput.cpython-310.pyc [ edit | delete | rename ]
[FILE] fnmatch.cpython-310.pyc [ edit | delete | rename ]
[FILE] fractions.cpython-310.pyc [ edit | delete | rename ]
[FILE] ftplib.cpython-310.pyc [ edit | delete | rename ]
[FILE] functools.cpython-310.pyc [ edit | delete | rename ]
[FILE] genericpath.cpython-310.pyc [ edit | delete | rename ]
[FILE] getopt.cpython-310.pyc [ edit | delete | rename ]
[FILE] getpass.cpython-310.pyc [ edit | delete | rename ]
[FILE] gettext.cpython-310.pyc [ edit | delete | rename ]
[FILE] glob.cpython-310.pyc [ edit | delete | rename ]
[FILE] graphlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] gzip.cpython-310.pyc [ edit | delete | rename ]
[FILE] hashlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] heapq.cpython-310.pyc [ edit | delete | rename ]
[FILE] hmac.cpython-310.pyc [ edit | delete | rename ]
[FILE] imaplib.cpython-310.pyc [ edit | delete | rename ]
[FILE] imghdr.cpython-310.pyc [ edit | delete | rename ]
[FILE] imp.cpython-310.pyc [ edit | delete | rename ]
[FILE] inspect.cpython-310.pyc [ edit | delete | rename ]
[FILE] io.cpython-310.pyc [ edit | delete | rename ]
[FILE] ipaddress.cpython-310.pyc [ edit | delete | rename ]
[FILE] keyword.cpython-310.pyc [ edit | delete | rename ]
[FILE] linecache.cpython-310.pyc [ edit | delete | rename ]
[FILE] locale.cpython-310.pyc [ edit | delete | rename ]
[FILE] lzma.cpython-310.pyc [ edit | delete | rename ]
[FILE] mailbox.cpython-310.pyc [ edit | delete | rename ]
[FILE] mailcap.cpython-310.pyc [ edit | delete | rename ]
[FILE] mimetypes.cpython-310.pyc [ edit | delete | rename ]
[FILE] modulefinder.cpython-310.pyc [ edit | delete | rename ]
[FILE] netrc.cpython-310.pyc [ edit | delete | rename ]
[FILE] nntplib.cpython-310.pyc [ edit | delete | rename ]
[FILE] ntpath.cpython-310.pyc [ edit | delete | rename ]
[FILE] nturl2path.cpython-310.pyc [ edit | delete | rename ]
[FILE] numbers.cpython-310.pyc [ edit | delete | rename ]
[FILE] opcode.cpython-310.pyc [ edit | delete | rename ]
[FILE] operator.cpython-310.pyc [ edit | delete | rename ]
[FILE] optparse.cpython-310.pyc [ edit | delete | rename ]
[FILE] os.cpython-310.pyc [ edit | delete | rename ]
[FILE] pathlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] pdb.cpython-310.pyc [ edit | delete | rename ]
[FILE] pickle.cpython-310.pyc [ edit | delete | rename ]
[FILE] pickletools.cpython-310.pyc [ edit | delete | rename ]
[FILE] pipes.cpython-310.pyc [ edit | delete | rename ]
[FILE] pkgutil.cpython-310.pyc [ edit | delete | rename ]
[FILE] platform.cpython-310.pyc [ edit | delete | rename ]
[FILE] plistlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] poplib.cpython-310.pyc [ edit | delete | rename ]
[FILE] posixpath.cpython-310.pyc [ edit | delete | rename ]
[FILE] pprint.cpython-310.pyc [ edit | delete | rename ]
[FILE] profile.cpython-310.pyc [ edit | delete | rename ]
[FILE] pstats.cpython-310.pyc [ edit | delete | rename ]
[FILE] pty.cpython-310.pyc [ edit | delete | rename ]
[FILE] pyclbr.cpython-310.pyc [ edit | delete | rename ]
[FILE] pydoc.cpython-310.pyc [ edit | delete | rename ]
[FILE] py_compile.cpython-310.pyc [ edit | delete | rename ]
[FILE] queue.cpython-310.pyc [ edit | delete | rename ]
[FILE] quopri.cpython-310.pyc [ edit | delete | rename ]
[FILE] random.cpython-310.pyc [ edit | delete | rename ]
[FILE] re.cpython-310.pyc [ edit | delete | rename ]
[FILE] reprlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] rlcompleter.cpython-310.pyc [ edit | delete | rename ]
[FILE] runpy.cpython-310.pyc [ edit | delete | rename ]
[FILE] sched.cpython-310.pyc [ edit | delete | rename ]
[FILE] secrets.cpython-310.pyc [ edit | delete | rename ]
[FILE] selectors.cpython-310.pyc [ edit | delete | rename ]
[FILE] shelve.cpython-310.pyc [ edit | delete | rename ]
[FILE] shlex.cpython-310.pyc [ edit | delete | rename ]
[FILE] shutil.cpython-310.pyc [ edit | delete | rename ]
[FILE] signal.cpython-310.pyc [ edit | delete | rename ]
[FILE] site.cpython-310.pyc [ edit | delete | rename ]
[FILE] sitecustomize.cpython-310.pyc [ edit | delete | rename ]
[FILE] smtpd.cpython-310.pyc [ edit | delete | rename ]
[FILE] smtplib.cpython-310.pyc [ edit | delete | rename ]
[FILE] sndhdr.cpython-310.pyc [ edit | delete | rename ]
[FILE] socket.cpython-310.pyc [ edit | delete | rename ]
[FILE] socketserver.cpython-310.pyc [ edit | delete | rename ]
[FILE] sre_compile.cpython-310.pyc [ edit | delete | rename ]
[FILE] sre_constants.cpython-310.pyc [ edit | delete | rename ]
[FILE] sre_parse.cpython-310.pyc [ edit | delete | rename ]
[FILE] ssl.cpython-310.pyc [ edit | delete | rename ]
[FILE] stat.cpython-310.pyc [ edit | delete | rename ]
[FILE] statistics.cpython-310.pyc [ edit | delete | rename ]
[FILE] string.cpython-310.pyc [ edit | delete | rename ]
[FILE] stringprep.cpython-310.pyc [ edit | delete | rename ]
[FILE] struct.cpython-310.pyc [ edit | delete | rename ]
[FILE] subprocess.cpython-310.pyc [ edit | delete | rename ]
[FILE] sunau.cpython-310.pyc [ edit | delete | rename ]
[FILE] symtable.cpython-310.pyc [ edit | delete | rename ]
[FILE] sysconfig.cpython-310.pyc [ edit | delete | rename ]
[FILE] tabnanny.cpython-310.pyc [ edit | delete | rename ]
[FILE] tarfile.cpython-310.pyc [ edit | delete | rename ]
[FILE] telnetlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] tempfile.cpython-310.pyc [ edit | delete | rename ]
[FILE] textwrap.cpython-310.pyc [ edit | delete | rename ]
[FILE] this.cpython-310.pyc [ edit | delete | rename ]
[FILE] threading.cpython-310.pyc [ edit | delete | rename ]
[FILE] timeit.cpython-310.pyc [ edit | delete | rename ]
[FILE] token.cpython-310.pyc [ edit | delete | rename ]
[FILE] tokenize.cpython-310.pyc [ edit | delete | rename ]
[FILE] trace.cpython-310.pyc [ edit | delete | rename ]
[FILE] traceback.cpython-310.pyc [ edit | delete | rename ]
[FILE] tracemalloc.cpython-310.pyc [ edit | delete | rename ]
[FILE] tty.cpython-310.pyc [ edit | delete | rename ]
[FILE] turtle.cpython-310.pyc [ edit | delete | rename ]
[FILE] types.cpython-310.pyc [ edit | delete | rename ]
[FILE] typing.cpython-310.pyc [ edit | delete | rename ]
[FILE] uu.cpython-310.pyc [ edit | delete | rename ]
[FILE] uuid.cpython-310.pyc [ edit | delete | rename ]
[FILE] warnings.cpython-310.pyc [ edit | delete | rename ]
[FILE] wave.cpython-310.pyc [ edit | delete | rename ]
[FILE] weakref.cpython-310.pyc [ edit | delete | rename ]
[FILE] webbrowser.cpython-310.pyc [ edit | delete | rename ]
[FILE] xdrlib.cpython-310.pyc [ edit | delete | rename ]
[FILE] zipapp.cpython-310.pyc [ edit | delete | rename ]
[FILE] zipfile.cpython-310.pyc [ edit | delete | rename ]
[FILE] zipimport.cpython-310.pyc [ edit | delete | rename ]
[FILE] _aix_support.cpython-310.pyc [ edit | delete | rename ]
[FILE] _bootsubprocess.cpython-310.pyc [ edit | delete | rename ]
[FILE] _collections_abc.cpython-310.pyc [ edit | delete | rename ]
[FILE] _compat_pickle.cpython-310.pyc [ edit | delete | rename ]
[FILE] _compression.cpython-310.pyc [ edit | delete | rename ]
[FILE] _distutils_system_mod.cpython-310.pyc [ edit | delete | rename ]
[FILE] _markupbase.cpython-310.pyc [ edit | delete | rename ]
[FILE] _osx_support.cpython-310.pyc [ edit | delete | rename ]
[FILE] _pydecimal.cpython-310.pyc [ edit | delete | rename ]
[FILE] _pyio.cpython-310.pyc [ edit | delete | rename ]
[FILE] _py_abc.cpython-310.pyc [ edit | delete | rename ]
[FILE] _sitebuiltins.cpython-310.pyc [ edit | delete | rename ]
[FILE] _strptime.cpython-310.pyc [ edit | delete | rename ]
[FILE] _sysconfigdata__linux_x86_64-linux-gnu.cpython-310.pyc [ edit | delete | rename ]
[FILE] _sysconfigdata__x86_64-linux-gnu.cpython-310.pyc [ edit | delete | rename ]
[FILE] _threading_local.cpython-310.pyc [ edit | delete | rename ]
[FILE] _weakrefset.cpython-310.pyc [ edit | delete | rename ]
[FILE] __future__.cpython-310.pyc [ edit | delete | rename ]
[FILE] __phello__.foo.cpython-310.pyc [ edit | delete | rename ]

Viewing: /snap/core22/2955/usr/lib/python3.10/__pycache__/asyncore.cpython-310.pyc

o

�9j,O�@sx
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZm	Z	m
Z
mZmZm
Z
mZmZmZmZmZmZmZ
ejdedd�
eee
eeeeh�
Zze
WneyY


iZYn
wdd�ZGd	d
�d
e�ZeeefZ dd�Z!d
d�Z"dd�Z#dd�Z$d)dd�
Z%d)dd�
Z&e&Z'd*dd�
Z(Gdd�d�Z)Gdd�de)�Z*d d!�Z+d+d"d#�
Z,ej-d$kr�Gd%d&�d&�Z.Gd'd(�d(e)�Z/dSdS),a�Basic infrastructure for asynchronous socket service clients and servers.

There are only two ways to have a program on a single processor do "more
than one thing at a time".  Multi-threaded programming is the simplest and
most popular way to do it, but there is another very different technique,
that lets you have nearly all the advantages of multi-threading, without
actually using multiple threads. it's really only practical if your program
is largely I/O bound. If your program is CPU bound, then pre-emptive
scheduled threads are probably what you really need. Network servers are
rarely CPU-bound, however.

If your operating system supports the select() system call in its I/O
library (and nearly all do), then you can use it to juggle multiple
communication channels at once; doing other work while your I/O is taking
place in the "background."  Although this strategy can seem strange and
complex, especially at first, it is in many ways easier to understand and
control than multi-threaded programming. The module documented here solves
many of the difficult problems for you, making the task of building
sophisticated high-performance network servers and clients a snap.
�N)
�EALREADY�EINPROGRESS�EWOULDBLOCK�
ECONNRESET�EINVAL�ENOTCONN�	ESHUTDOWN�EISCONN�EBADF�ECONNABORTED�EPIPE�EAGAIN�	errorcodezlThe asyncore module is deprecated and will be removed in Python 3.12. The recommended replacement is asyncio�)
�
stacklevelc


CsBzt�
|�
WStttfy 


|tvrt|YSd
|YSw)NzUnknown error %s)�os�strerror�
ValueError�
OverflowError�	NameErrorr)
�err�r�/usr/lib/python3.10/asyncore.py�	_strerrorKs





�rc
@seZ
dZd
S)�ExitNowN)�__name__�
__module__�__qualname__rrrrrSs
rc

C�2z|��
WdSt
y


�


|��
YdS�
N)�handle_read_event�_reraised_exceptions�handle_error�
�objrrr�readX�





r%c

Crr)�handle_write_eventr!r"r#rrr�write`r&r(c

Crr)�handle_expt_eventr!r"r#rrr�
_exceptionhr&r*c
Cs�z0|
tj
@r
|��
|
tj@r|��
|
tj@r|��
|
tjtjBtj	B@r.|�
�
WdSWdStyX
}
z|jt
v
rB|��
n|�
�
WYd}~dSWYd}~dSd}~w
ty_


�


|��
YdSr)�select�POLLINr �POLLOUTr'�POLLPRIr)�POLLHUP�POLLERR�POLLNVAL�handle_close�OSError�errno�
_DISCONNECTEDr"r!)r$�flags�
errr�	readwriteps(











�



��


r8�c	Cs6
|
durt}
|
r�g}g}g}t
|
���
D]&\}}|��}|��}|r'|�|�

|r1|js1|�|�

|s5|r:|�|�

qg|krJ|krJ|krSn
nt�|�

dSt	�	||||�\}}}|D]}|
�
|�
}|durlq`t|�

q`|D]}|
�
|�
}|durqst|�

qs|D]}|
�
|�
}|dur�q�t
|�

q�dSdSr)�
socket_map�list�items�readable�writable�append�	accepting�time�sleepr+�getr%r(r*)	�timeout�map�
r�
wr7�fdr$�is_r�is_wrrr�poll�sF















�"





















�rKcCs�|
durt}
|du
rt
|d
�
}t��}|
r^t|
���
D]&\}}d}|��r.|tjtjBO}|�	�r:|j
s:|tjO}|rB|�||�
q|�|�
}|D]\}}|
�
|�
}|durXqJt||�
qJdSdS)Ni�r
)r:�intr+rKr;r<r=r,r.r>r@r-�registerrCr8)rDrE�pollsterrHr$r6rFrrr�poll2�s.











�






�rO�>@FcCs�|durt}|
rt
td
�rt}nt}|dur#|r!|||�
|sdSdS|r:|dkr>|||�
|d}|r<|dks)dSdSdSdS)NrKr
�
)r:�hasattrr+rOrK)rD�use_pollrE�count�poll_funrrr�loop�s





�


�rVc@s2
eZ
dZd
Zd
Zd
Zd
Zd
ZdZe	dh
�
Z
dAdd�
Zdd�ZdBdd	�
Z
dBd
d�
Zejejfdd
�
ZdBdd�
Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�ZdCd'd(�
Zd)d*�Z d+d,�Z!d-d.�Z"d/d0�Z#d1d2�Z$d3d4�Z%d5d6�Z&d7d8�Z'd9d:�Z(d;d<�Z)d=d>�Z*d?d@�Z+dS)D�
dispatcherFN�warningc
Cs�|durt|_
n||_
d|_|
rK|
�d
�

|�|
|�
d|_z|
��|_WdStyJ
}
z|j	t
tfvr9d
|_n|�|�

�WYd}~dSd}~w
wd|_
dS)NFT)r:�_map�_fileno�setblocking�
set_socket�	connected�getpeername�addrr3r4rr�del_channel�socket)�self�sockrErrrr�__init__�s&









���
zdispatcher.__init__c
Cs�|jj
d
|jjg
}
|jr|jr|
�d�

n|jr|
�d�

|jdu
r@z
|
�d|j�

Wnty?


|
�t|j�
�

Yn
wdd�	|
�
t
|�
fS)N�
.�	listeningr]z%s:%dz<%s at %#x>�
 )�	__class__rrr@r_r?r]�	TypeError�repr�join�id)rb�statusrrr�__repr__
s











�zdispatcher.__repr__cCs|
dur|j}
||
|j
<dSr)rYrZ)rbrErrr�add_channel
s

zdispatcher.add_channelcCs,|j}|
dur
|j
}
||
vr|
|=d|_dSr)rZrY)rbrErHrrrr`
s





zdispatcher.del_channelcCs.|
|f|_t
�
|
|�}|�d
�

|�|�

dS�NF)�family_and_typerar[r\)rb�family�typercrrr�
create_socket
s





zdispatcher.create_socketcCs|
|_|
�
�|_|�|�

dSr)ra�filenorZro�rbrcrErrrr\%
s



zdispatcher.set_socketc

CsBz|j�
tjtj|j�tjtj�d
B�
WdSty 


YdSw)NrQ)ra�
setsockopt�
SOL_SOCKET�SO_REUSEADDR�
getsockoptr3�
rbrrr�set_reuse_addr*
s




�
�
�
�zdispatcher.set_reuse_addrc


C�d
S�NTrr{rrrr=;
�
zdispatcher.readablec


Cr}r~rr{rrrr>>
rzdispatcher.writablecCs(d
|_t
jdkr|
dkrd}
|j�|
�
S)NT�nt�)r@r�namera�listen)rb�numrrrr�E
s



zdispatcher.listencCs|
|_|j
�|
�
Sr)r_ra�bind)rbr_rrrr�K
s

zdispatcher.bindcCsnd
|_d|_
|j�|
�
}|tttfvs|tkr!tj	dkr!|
|_
dS|dtfvr0|
|_
|��
dSt
|t|��
)NFTr�r
)r]�
connectingra�
connect_exrrrrrr�r_r	�handle_connect_eventr3r)rb�addressrrrr�connectO
s









zdispatcher.connectc

Csdz|j�
�\}
}W|
|fSty


YdSty1
}
z|jtttfvr,WYd}~dS�d}~w
wr)ra�acceptrir3r4rrr
)rb�connr_�whyrrrr�]
s
	�



��zdispatcher.acceptc
Csfz	|j�
|
�
}|WSty2
}
z|jtkrWYd}~d
S|jtvr-|��
WYd}~d
S�d}~w
w�Nr
)ra�sendr3r4rr5r2)rb�data�resultr�rrrr�k
s










��zdispatcher.sendc
Cs`z|j�
|
�
}|s|��
Wd
S|WSty/
}
z|jtvr*|��
WYd}~d
S�d}~w
w�N�)ra�recvr2r3r4r5)rb�buffer_sizer�r�rrrr�x
s







��zdispatcher.recvc

Cspd
|_d
|_
d
|_|��
|jdu
r6z|j��
WdSty5
}

z|
jtt	fv
r*�WYd}
~
dSd}
~
w
wdSrp)
r]r@r�r`ra�closer3r4rr
)rbr�rrrr��
s










����zdispatcher.closecCstj
�d
t|
�
�

dS)Nzlog: %s
)�sys�stderrr(�str)rb�messagerrr�log�
s
zdispatcher.log�infocCs"||jv
rt
d
||
f�

dSdS)Nz%s: %s)�ignore_log_types�print)rbr�rsrrr�log_info�
s


�zdispatcher.log_infoc

Cs>|jr	|�
�
dS|js|jr|��
|��
dS|��
dSr)r@�
handle_acceptr]r�r��handle_readr{rrrr �
s




zdispatcher.handle_read_eventc
Cs@|j�
tjtj�}
|
d
krt|
t|
�
��
|��
d|_d|_dS)Nr
TF)	rarzrx�SO_ERRORr3r�handle_connectr]r��rbrrrrr��
s






zdispatcher.handle_connect_eventc

Cs*|jrdS|j
s|jr|��
|��
dSr)r@r]r�r��handle_writer{rrrr'�
s



zdispatcher.handle_write_eventc
Cs2|j�
tjtj�}
|
d
kr|��
dS|��
dSr�)rarzrxr�r2�handle_exptr�rrrr)�
s
zdispatcher.handle_expt_eventc
CsTt�\}
}}}zt
|�
}Wn



d
t|�
}Y|�d||||fd�
|��
dS)Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)�error)�compact_tracebackrjrlr�r2)rb�nil�
t�
v�tbinfo�	self_reprrrrr"�
s








��	zdispatcher.handle_errorc

C�|�d
d�
dS)Nz!unhandled incoming priority eventrX�
r�r{rrrr��
�
zdispatcher.handle_exptc

Cr�)Nzunhandled read eventrXr�r{rrrr��
r�zdispatcher.handle_readc

Cr�)Nzunhandled write eventrXr�r{rrrr��
r�zdispatcher.handle_writec

Cr�)Nzunhandled connect eventrXr�r{rrrr��
r�zdispatcher.handle_connectc
Cs"|��}
|
du
r|j
|
�
dSdSr)r��handle_accepted)rb�pairrrrr��
s


�zdispatcher.handle_acceptcCs|
��
|�
d
d�
dS)Nzunhandled accepted eventrX)r�r�)rbrcr_rrrr��
s

zdispatcher.handle_acceptedc

Cs|�d
d�
|�
�
dS)Nzunhandled close eventrX)r�r�r{rrrr2�
s

zdispatcher.handle_close�NNr)
r�),rrr�debugr]r@r��closingr_�	frozensetr�rdrnror`ra�AF_INET�SOCK_STREAMrtr\r|r=r>r�r�r�r�r�r�r�r�r�r r�r'r)r"r�r�r�r�r�r�r2rrrrrW�sL







 

	


rWc@s6eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zd
S)
�dispatcher_with_sendNcCst�
||
|�
d
|_dSr�)rWrd�
out_bufferrvrrrrds


zdispatcher_with_send.__init__c
Cs.d
}
t�
||jdd��}
|j|
d�|_dS)Nr
i
)rWr�r�)rb�num_sentrrr�
initiate_sends


z"dispatcher_with_send.initiate_sendc

Cs|��
dSr)
r�r{rrrr�s
z!dispatcher_with_send.handle_writec

Cs|jpt
|j�
Sr)r]�lenr�r{rrrr>s
zdispatcher_with_send.writablecCs0|jr|�
d
t|
�
�

|j|
|_|��
dS)Nz
sending %s)r�r�rjr�r�)rbr�rrrr�s



zdispatcher_with_send.sendr�)rrrrdr�r�r>r�rrrrr�
s
r�cCs�t�
�\}}
}g}|std
�
�
|r'|�|jjj|jjjt|j	�
f�

|j
}|s~|d\}}}d�dd�|D�
�
}|||f||
|fS)Nztraceback does not exist���rgc
Ssg|]}
d|
�qS)
z
[%s|%s|%s]r)�.0�
xrrr�
<listcomp>-sz%compact_traceback.<locals>.<listcomp>)r��exc_info�AssertionErrorr?�tb_frame�f_code�co_filename�co_namer��	tb_lineno�tb_nextrk)r�r��tbr��file�function�liner�rrrr�s 








��	

r�cCs�|durt}t
|���
D]1}z|��
Wqty/
}
z|jtkr"n|
s%�WYd}~qd}~w
ty6


�


|
s<�Yq|��
dSr)	r:r;�valuesr�r3r4r
r!�clear)rE�
ignore_allr�rrr�	close_all0s$










�




�r��posixc@sNeZ
dZd
d�Zdd�Zdd�Zdd�Zdd
d�
ZeZeZ	dd
�Z
dd�Zd	S)�file_wrappercCst�
|
�
|_dSr)r�duprH�rbrHrrrrdUr�zfile_wrapper.__init__c

Cs*|jd
krt
jd|t|d�
|��
dS)Nr
zunclosed file %r)
�source)rH�warnings�warn�ResourceWarningr�r{rrr�__del__Xs




�zfile_wrapper.__del__c
G�tj
|jg
|
�
R�Sr)rr%rH�rb�argsrrrr�^�
zfile_wrapper.recvc
Gr�r)rr(rHr�rrrr�ar�zfile_wrapper.sendNcCs$|
tj
kr|tjkr|sd
Std�
�
)Nr
z-Only asyncore specific behaviour implemented.)rarxr��NotImplementedError)rb�level�optname�buflenrrrrzds




�
zfile_wrapper.getsockoptc
Cs(|jd
krdS|j}
d|_t
�|
�

dS)Nr
r�)rHrr�r�rrrr�os






zfile_wrapper.closec


Cs|jSr)
rHr{rrrruvs
zfile_wrapper.filenor)rrrrdr�r�r�rzr%r(r�rurrrrr�Ps

r�c@seZ
dZddd�
Zdd�Zd
S)�file_dispatcherNcCsNt�
|d|�
d
|_z|
��}
Wn	ty


Yn
w|�|
�

t�|
d�
dS)NTF)rWrdr]ru�AttributeError�set_filer�set_blocking)rbrHrErrrrd{s





�
zfile_dispatcher.__init__cCs"t|
�
|_
|j
��|_|��
dSr)r�rarurZror�rrrr��s



zfile_dispatcher.set_filer)rrrrdr�rrrrr�ys
r�)r9N)rPFNNrp)0�__doc__r+rar�rAr�rr4rrrrrrrr	r
rrr
rr��DeprecationWarningr�r5r:rr�	Exceptionr�KeyboardInterrupt�
SystemExitr!r%r(r*r8rKrO�poll3rVrWr�r�r�r�r�r�rrrr�<module>
sT



<


�
�


�


'
*


)�

Upload File: 



    CMD: