ó
|
PºÆgc @ 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 m Z d d l Z d d l 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 GMToolCommandMgr( t CtrlDBManagert 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 d Z d Z d Z RS( c C sk t j | d d | | _ t j 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 gstSendDBMergeClientListMsgt' _LogicProcessThread__processRequestTypet Queuet! _LogicProcessThread__requestQueuet Falset _LogicProcessThread__elegantExit( t selft serverObj( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\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" ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt
|
canProcess( s c C s | j j | d S( N( R t put( R R( ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt requestPush7 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( ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt requestPopNoWait: 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 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!s4 onInnerServerPack gstSendDBMergeClientListMsg start!s2 onInnerServerPack gstSendDBMergeClientListMsg end!(# R R% R& R R R t debugR
|
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 t OnMergeMsgToClientListR ( R R( R) R" t sendPack( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt onInnerServerPackA sR *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 t infot getNamet ident( R ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyRD m 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 RE RF R' R t isAliveR ( R ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt stopr 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' R0 t DBConfigt MultiThreadingR/ R R R t GetStatt LogicProcessCountR! R" R R# RC R t getPackPoolt freeR t warningt outputStringt ExceptionR t formatMsgt ERROR_NO_28t tracebackt
|
format_exc( R R( t packTypet et msg( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt runy s4
|
( " c C s' | s' t | d s' t | d r+ d St j | j } | j d d } | j d i } | t j k rî | j d d } | j d d } | sË t j j d } | j
|
| } | | d <n t j d
|
| | t | f n d S| | d <t j | d | _ t | j | _ d S( Nt Datat DataLent MsgTypeiÿÿÿÿt playerIDi t packDatat t
|
UserCtrlDBs/ ·¢ËÍ×Ó·þ´øÉÏÍæ¼Ò´ò°üÊý¾Ý: %s,playerID=%s,len=%si ( t hasattrt cPicklet loadsR[ t getR t! CrossServerMsg_PushPlayerPackDataR t
|
getCtrlMgrt getCtrlDBByNamet getPlayerPackDataR R1 t lent dumpsR\ ( R t toMergeClientPackt msgDictt msgTypet msgDataR^ R_ t
|
userCtrlDB( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt __sendToMergeClientWithPackData s$ ' #
|
c C sà t j j d } | s d St j } | j | j d t j | _ t
|
j j } x] | D]U } | j | j | j j | j j t j | j j | j j | j qf Wd S( Nt Mergei ( R t getServerMgrt GetServerR t tagGDBroadcastMergeClientt ReadDataR& R t dgBroadcastMergeClientR4 t MergeProxyClientMgrt getMergeProxyClientMgrt getClientListR5 R7 R! R8 t atMergeLogicR9 R: R; ( R R( R t broadcastPackt
|
clientListt client( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyR? ³ s c C sð t j j d } | s d St j } | j | j d t j j | j
|
} | sc d St j } | j t j | _ | j | _ | j | _ | j | j | j j | j j t j | j j | j j | j d S( NRr i ( R Rs Rt R t tagGDMergeMsgToClientRv R& Rx Ry t findClientByCompoundKeyt GroupIDRu t ClearR Rw R4 R[ R\ R5 R7 R! R8 R{ R9 R: R; ( R R( R t toMergeClientMsgR~ R| ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyR@ Ô s*
|
c C s) t j j d } | s d St j } | j | j d t j | j } t
|
j d | t | d k r | j | n x | D] } t | t k rö t | d k rö xg t | d | d d D] } | j | | | | qÓ Wq t | t k r | j | | | | q q Wd S( NRr i s" OnMergeMsgToClientListÏò×Ó·þ×é %s i i ( R Rs Rt R t tagGDMergeMsgToClientListRv R& Rc Rd t GroupsR R1 Rj t2 _LogicProcessThread__sendToMergeClientWithPackDataR" t tuplet xranget! _LogicProcessThread__SendMergeMsgt int( R R( R R t groupListt memt groupID( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyRA ó s $" c C s¬ t j j | } | s d St j } | j t j | _ | j | _ | j
|
| _
|
| j | j | j j | j j t j | j j | j j | j d S( N( Rx Ry R R Ru R R Rw R4 R[ R\ R5 R7 R! R8 R{ R9 R: R; ( R R R( R R R~ R| ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt __SendMergeMsg
|
s
|
c C s3 t j j d } | d k r% d S| j d k r` t j d t j d } t j | d St
|
j r d d l } t j d | j | j n | 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 Rs Rt R/ t GetClientCntR RS t ERROR_NO_173R t DeployErrorR t IsDebugt binasciiR1 t b2a_hexR& R6 R t tagGMCommandRv t
|
g_GMCMDMgrt AddPairt OrderIdR R R< t ERROR_NO_172RU RV ( R R( t GmToolServerRY R R7 t recvPack( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\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 = %dR` s7 SendToGMToolCommandResult Fail, No Client in GMToolPorts SendToGMToolCommandResult Done( R
|
t tagGMCommandResultRv R& R R= R RS R RU RV R R t PopPairR RE RP R Rs R5 R R# R t stGMToolt stDataR; ( R R( t SendPackRY t sendViaSessionIDt SessionIDt PoolIndext ServerMgr( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyR= A 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 RS R RU RV R ( R R( RY ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyR> ` s "( t __name__t
|
__module__R R* R, R0 RC RD RI RZ R R? R@ RA R R< R= R> ( ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyR s , ! (! t threadingR R t timeR t DBCommonR R R R t CommonR R t ProtocolR R R
|
t
|
__import__RJ t NetR RU t GMToolLogicProcessR R t LogicProcessR Rx t jsonRc t GetGMOrderMgrR R ( ( ( sN .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcessThread.pyt <module> s "
|
