ó
|
6÷ÙTc @ s{ d d l m Z d d l Z d d l m Z d d l m Z m Z m Z d d l m
|
Z
|
m Z d e j f d YZ d S( iÿÿÿÿ( t mylogN( t AsynServerClient( t SingletonObjectt CommonDefinet error( t SendPackProtocolt
|
MMORPGPackt MongoDBServerClientc B s, e Z d Z d Z d Z d Z RS( c C s< t j j | | | | | | | _ | r8 | j n d S( N( R t __init__t _MongoDBServerClient__recvQueuet notifyRouteServerDBPrepareOK( t selft sockt addrt OnCloset recvQueuet notifyPrepare( ( s8 .\server\db\PyMongoDataServer\Net\MongoDBServerClient.pyR s c C sá t j r& t j d t j | n t j j } d | j | k r t
|
j d t
|
j d } t j
|
| t j j | d S| j | j t j d | j j | j j | t j d | j j d S( s »ñµÃ²ð½âºóµÄ·â°üs buf = %siÿÿÿÿR s error in pack.readDataNs before put:recv queue cnt = %ss after put:recv queue cnt = %s( R t
|
DUMPPACKETR t debugt binasciit b2a_hexR t getPackPoolt alloct readDataR t formatMsgt ERROR_NO_135t freet setSessionIDt sessionIDR t qsizet put( R t buft packt msg( ( s8 .\server\db\PyMongoDataServer\Net\MongoDBServerClient.pyt OnGetPacket s c C sÞ t j } t j | _ t j j } | j | j j
|
d | j _ d | j _ t j | j _ t j | j _ t j | j _ | j | j | j | j t j j | t j d d S( Ni s Send OK!( R t tagDataServerInitOKR t dgDataServerPrepareOKt TypeR R R t setSendViaSocketIDt sockett filenot getPackHeadR t poolIndext atInnert typeR t stRoutet
|
dstSvrTypet stDatat
|
srcSvrTypet setBuffert GetBuffert pushSendt getPackDataR R t info( R t packDBInitOKt sendPack( ( s8 .\server\db\PyMongoDataServer\Net\MongoDBServerClient.pyR
|
' s c C sV t j } | j | | j j t j k r? | j d St j j | | d S( N(
|
R t MMORPGPacket_StackR R) R, R t atDisconnectt
|
disconnectR R3 ( R R R ( ( s8 .\server\db\PyMongoDataServer\Net\MongoDBServerClient.pyR3 7 s
|
( t __name__t
|
__module__R R" R
|
R3 ( ( ( s8 .\server\db\PyMongoDataServer\Net\MongoDBServerClient.pyR s ( t CommonR R t NetCoreR t DBCommonR R R t ProtocolR R R ( ( ( s8 .\server\db\PyMongoDataServer\Net\MongoDBServerClient.pyt <module> s
|
|
