ó
|
Ôíhc @ s d d l Z d d l m Z d d l m Z m Z d d l Z d d l m Z d d l Z d d l
|
Z
|
d e j f d YZ d S( iÿÿÿÿN( t mylog( t CommonDefinet Stat( t PacketDispatchert AsyncoreClientc B sb e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z RS(
|
c C sZ t j j | | j t j t j t j | _ | j | j _
|
d | _ t | _ d S( Nt ( t asyncoret
|
dispatchert __init__t create_sockett sockett AF_INETt SOCK_STREAMR t _AsyncoreClient__packDispatchert onGetPackt OnGetPackett _AsyncoreClient__sendBuft Truet _AsyncoreClient__active( t self( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR s c C s t j d d S( s ×ÓÀàʵÏÖs
|
unhandled!N( R t warning( R t buf( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR s c C s! t | _ t j d | j d S( Ns connect %s ok!( R R R t infot addr( R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt handle_connect" s c C s | | _ d S( N( R ( R t _active( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt SetActive' s c C sÉ | j s d Syx | j t j } t | d k rB | j d St j rt t j d t | t j
|
| f n | j j | Wn= t k
|
rÄ } t j d | j t j f | j n Xd S( Ni s recv len = %s data = %ss get a exception: %s: %s
|
( R t recvR t MAX_RECVt lent closet
|
DUMPPACKETR t debugt binasciit b2a_hexR t onRecvOrginPackett ExceptionR t messaget tracebackt
|
format_exct
|
disconnect( R R t e( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt handle_read* s
|
) c C s | j d S( N( t _AsyncoreClient__processSend( R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt handle_write? s c C s7 t j d | j t | _ | j r3 | j n d S( Ns sock = %s( R R R
|
t FalseR R ( R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt handle_closeB s c C sm | j j | } | j | 7_ t | j t j k r_ t j d t | j t j f n | j d S( Ns) send buf (len = %s) > (MAX_PACK_LEN = %s)( R t packDataR R R t MAX_PACK_LENR R R+ ( R R t packBuf( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt pushSendI s
|
&c C s7 t j d | j t | _ | j r3 | j n d S( Ns disconnect sock = %s( R R R
|
R- R R ( R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR( P s c C s | j s t | j d k r# d St j r[ d d l } t j d | j | j n | j | j } | j | | _ t
|
j j | 7_ d S( Ni iÿÿÿÿs buf = %s( R R R R t IsDebugR! R R R" t sendR t GetStatt SendBytes( R R! t sent( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt __processSendV s ( t __name__t
|
__module__R R R R R* R, R. R2 R( R+ ( ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR s
|
( R t CommonR t DBCommonR R R! t ProtocolR R
|
R& R R ( ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt <module>
|
s
|
