ó
|
hÐ\c @ sð d d l m Z d d l Z d d l m Z d d l m Z m Z m Z m Z d d l
|
m Z m Z d d l m Z m Z m Z e d Z d d l m Z d d l Z d d l m Z m Z d d l Z e j a d
|
e f d YZ d S( iÿÿÿÿ( t ThreadN( t sleep( t CommonDefinet errort Statt SingletonObject( t CommFunct mylog( t
|
MMORPGPackt RecvPackProtocolt SendPackProtocols Config.DBConfig( t MongoDBServer( t ProjSpecialProcesst GMToolCommandMgrt LogicProcessThreadc B s} e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z d
|
Z d Z d Z RS( c C se t j | d d | | _ t j t j t j t j t j t j f | _
|
t j | _ t | _ d S( Nt nameR ( R t __init__t _LogicProcessThread__serverR t lsdDataServerPreparedAskt gstGMToolCommandt gstGMToolCommandResultt gstGMToolCmdLogicProcessRequestt gstBroadcastMergeClientt gstSendDBMergeClientMsgt' _LogicProcessThread__processRequestTypet Queuet! _LogicProcessThread__requestQueuet Falset _LogicProcessThread__elegantExit( t selft serverObj( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyR s c C sl | j j t j k r1 | j d k r1 t Sn d } t j | j | \ } } | | j k rh t
|
St S( Ni i ( t getPackHeadt typeR t atInnert getLengthR R t ReadBYTEt getBufferR t True( R t packt posR ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyt
|
canProcess% s c C s | j j | d S( N( R t put( R R& ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyt requestPush4 s c C s/ y | j j } Wn t j k
|
r* d SX| S( N( R t
|
get_nowaitR t Emptyt None( R R& ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyt requestPopNoWait7 s
|
c C sê d } t j | j | \ } } | t j k rÄ t j d t j } t j | _
|
| j j | j | j j | j j | j j | j j | j j | j t j d t S| t j k rþ t j d | j | t j d t S| t j k r8t j d | j | t j d t S| t j k rrt j d | j | t j d t S| t j k r¬t j d
|
| j | t j d t S| t j k ræt j d | j | t j d t St S( Ni s Return data server prepared!s Return data server prepared!!!s# onInnerServerPack gstGMToolCommand!s' onInnerServerPack gstGMToolCommand! Ends) onInnerServerPack gstGMToolCommandResult!s- onInnerServerPack gstGMToolCommandResult! Ends2 onInnerServerPack gstGMToolCmdLogicProcessRequest!s6 onInnerServerPack gstGMToolCmdLogicProcessRequest! Ends0 onInnerServerPack gstBroadcastMergeClient start!s. onInnerServerPack gstBroadcastMergeClient end!s0 onInnerServerPack gstSendDBMergeClientMsg start!s. onInnerServerPack gstSendDBMergeClientMsg end!(! R R# R$ R R R t infoR
|
t tagDataServerInitOKt dgDataServerPrepareOKt TypeR t packSendBySessionIDt getSessionIDR t sessionIDt poolIndexR t
|
srcSvrTypet
|
dstSvrTypet GetBufferR% R t OnGMToolCommandR t OnGMToolCommandResultR t OnGMToolCmdLogicProcessRequestR t OnBroadcastMergeClientR t OnMergeMsgToClientR ( R R& R' R t sendPack( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyt onInnerServerPack> sH *1 c C s: t | _ t j | t j d | j | j f d S( Ns Thread %s(%s) start...( R R R t startR R/ t getNamet ident( R ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyRA f s c C sX t j d | j t | _ x | j r< t d q# Wt j d | j d S( Ns Stopping thread %s...g¹?s Thread %s stop ok!( R R/ RB R% R t isAliveR ( R ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyt stopk s
|
c C sa xZt r\yÊ | j } t j rM | d k rr | j r: Pn t d w qr n% | d k r] Pn t j j d 7_ | j
|
j } | t j k r» | j | r» t j j | w q» n t j d | j Wq t k
|
r } t j d t j d | t j f } t j | q q t j d t j d t j } t j | q q Xq Wd S( Ng¹?i s pack %s not processed!R s" Exception %s caught!traceback = %ss' Unknown exception caught!traceback = %s( R% R. t DBConfigt MultiThreadingR- R R R t GetStatt LogicProcessCountR R R R! R@ R t getPackPoolt freeR t warningt outputStringt ExceptionR t formatMsgt ERROR_NO_28t tracebackt
|
format_exc( R R& t packTypet et msg( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyt runr s4
|
( " c C s t j j d } | s d St j } | j | j d t j | _ | j
|
| j | j d t j | j _ | j | d S( Nt Mergei ( R t getServerMgrt GetServerR t tagGDBroadcastMergeClientt ReadDataR$ R t dgBroadcastMergeClientR2 t setBufferR9 t setSessionIDt atMergeLogicR R t pushSend( R R& R t broadcastPack( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyR= s c C sú t j j d } | s d St j } | j | j d t j j | j
|
} | sz t j d | j d St j } | j t j | _ | j | _ | j | _ | j | j | j | j t j | j _ | j | d S( NRW i s Ïò×Ó·þ·¢ËÍÏûϢʧ°Ü %s ( R RX RY R t tagGDMergeMsgToClientR[ R$ t MergeProxyClientMgrt getMergeProxyClientMgrt findClientByCompoundKeyt GroupIDR RL t OutputStringRZ t ClearR R\ R2 t Datat DataLenR] R9 R^ R5 R_ R R R` ( R R& R t toMergeClientMsgt clientRa ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyR> s&
|
c C s$ t j j d } | d k r% d S| j d k r` t j d t j d } t j | d Sd d l
|
} t j d | j | j | j } t j } | j | j t j | j | t k rÖ d Sy t j | Wn6 t j d t j d t j } t j | n Xd S( Nt GMTooli R sI LogicProcessThread::OnGMToolCommand Recv Cmd, but no Client in GMToolPortiÿÿÿÿs buf = %ssM LogicProcessThread::OnGMToolCommand Catch a unexpetcted exception, error = %s( R RX RY R- t GetClientCntR RO t ERROR_NO_173R t DeployErrort binasciiR/ t b2a_hexR$ R4 R t tagGMCommandR[ t
|
g_GMCMDMgrt AddPairt OrderIdR R R: t ERROR_NO_172RQ RR ( R R& t GmToolServerRU Rq R5 t recvPack( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyR: ¸ s& "c C s t j } | j | j y t j | } Wn6 t j d t j d t j
|
} t j | n Xt j | j } d } d } t j d | | | f | d k rÀ t j d d St j } | j | | | t j t j t j | j t j d d S( NR sS LogicProcessThread::OnGMToolCommandResult Catch a unexpetcted exception, error = %si iÿÿÿÿsM SendToGMToolCommandResult sendViaSessionID = %s,SessionID = %d,PoolIndex = %dt s7 SendToGMToolCommandResult Fail, No Client in GMToolPorts SendToGMToolCommandResult Done( R
|
t tagGMCommandResultR[ R$ R R; R RO Rw RQ RR R Rt t PopPairRv R/ RL R RX R3 R R! R t stGMToolt stDataR9 ( R R& t SendPackRU t sendViaSessionIDt SessionIDt PoolIndext ServerMgr( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyR; Õ s( " c C sN y t j | Wn6 t j d t j d t j } t j | n Xd S( NR s\ LogicProcessThread::OnGMToolCmdLogicProcessRequest Catch a unexpetcted exception, error = %s( R R< R RO Rw RQ RR R ( R R& RU ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyR< ô s "( t __name__t
|
__module__R R( R* R. R@ RA RE RV R= R> R: R; R< ( ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyR s ( ( t threadingR R t timeR t DBCommonR R R R t CommonR R t ProtocolR R R
|
t
|
__import__RF t NetR RQ t GMToolLogicProcessR R Rc t GetGMOrderMgrRt R ( ( ( sK .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\LogicProcessThread.pyt <module> s "
|
