ó
|
í³Ôdc @ sm d d l Z d d l Z d d l m Z d d l Z d d l m Z d d l Z d e j f d YZ d S( iÿÿÿÿN( t CommonDefine( t PacketDispatchert AsyncoreClientc B sY e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
RS( c C sV | j t j t j } t j j | | t j | _ | j | j _
|
d | _ d S( Nt ( t create_sockett sockett AF_INETt SOCK_STREAMt asyncoret
|
dispatchert __init__R t _AsyncoreClient__packDispatchert onGetPackt OnGetPackett _AsyncoreClient__sendBuf( t selft sock( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR
|
s
|
c C s t j d d S( s ×ÓÀàʵÏÖs
|
unhandled!N( t mylogt warning( R t buf( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR s c C s t j d | j d S( Ns connect %s ok!( R t infot addr( R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt handle_connect s c C s¹ yx | j t j } t | d k r5 | j d St j rg t j d t | t j | f n | j
|
j | Wn: t k
|
r´ } t j d | j | j f | j n Xd S( Ni s recv len = %s data = %ss get a exception: %s: %s
|
( t recvR t MAX_RECVt lent closet
|
DUMPPACKETR t debugt binasciit b2a_hexR t onRecvOrginPackett ExceptionR t errnot strerrort
|
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_write2 s c C s" t j d | j | j d S( Ns sock = %s( R R R R ( R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt handel_close5 s c C s[ | j | 7_ t | j t j k rM t j d t | j t j f n | j d S( Ns) send buf (len = %s) > (MAX_PACK_LEN = %s)( R R R t MAX_PACK_LENR R R& ( R R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt pushSend9 s &c C s" t j d | j | j d S( Ns sock = %s( R R R R ( R ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR# ? s c C s& | j | j } | j | | _ d S( N( t sendR ( R t sent( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt __processSendC s ( t __name__t
|
__module__R
|
R R R% R' R( R* R# R& ( ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyR s (
|
R R t DBCommonR R t ProtocolR R R R ( ( ( s) .\\ServersRoute\NetCore\AsyncoreClient.pyt <module>
|
s
|
