ó
|
ÚÜ/ic @ 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 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 d d l Z d d l Z d d
|
l 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 SendPackProtocolt MergeServerRecvProtocols Config.DBConfig( t MongoDBServer( t ProjSpecialProcesst GMToolCommandMgr( t ServersConfigt 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 s t j | d d | | _ t j t j t j t j f | _ t j | _
|
t | _ d | _ t j t j } | j | _ | j j d S( Nt nameR iÿÿÿÿ( R t __init__t _LogicProcessThread__serverR t lsdDataServerPreparedAskt gstGMToolCommandt gstGMToolCommandResultt gstCrossServerToServerPackt' _LogicProcessThread__processRequestTypet Queuet! _LogicProcessThread__requestQueuet Falset _LogicProcessThread__elegantExitt& _LogicProcessThread__battleServerIndexR t GetServerDictByTheGroupNammet serverType_Battlet keyst' _LogicProcessThread__battleServerIDListt sort( t selft serverObjt serverIDMapDict( ( s" .\н¨Îļþ¼Ð\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' ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt
|
canProcess+ s c C s | j j | d S( N( R t put( R# R- ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt requestPush: 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- ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt requestPopNoWait= s
|
c C sv 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 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! Ends3 onInnerServerPack gstCrossServerToServerPack start!s1 onInnerServerPack gstCrossServerToServerPack 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 OnCrossServerToServerPackR ( R# R- R. R' t sendPack( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt onInnerServerPackD s4 *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# ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyRF b 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 RG RH R, R t isAliveR ( R# ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt stopg s
|
c C s, x%t r'y | j } | 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( Ni s pack %s not processed!R s" Exception %s caught!traceback = %ss' Unknown exception caught!traceback = %s( R, R5 R4 R t GetStatt LogicProcessCountR& R' R R( RE R t getPackPoolt freeR t warningt outputStringt ExceptionR t formatMsgt ERROR_NO_28t tracebackt
|
format_exc( R# R- t packTypet et msg( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt runn s( ( " c C s t j } | j | j | j t j k rÚ | j sK t j d d S| j
|
d 7_
|
| j
|
t | j k r~ d | _
|
n | j | j
|
} t | g | _ t | j | _ t j d | | j | j d St j | j | j } t j | k rOt | t j | _ t | j | _ | j | j | j t j n t | d k red S| j | | | t j d d S( Ns ±¾»ú×ÓûÓÐÅäÖÃÕ½¶·µØͼi i s recvPack battleReq toServerID=%sRC ( R t tagLPStringDatat ReadDataR+ t DirTypeR t dirType_BattleR! R R R t lent strt
|
ServerListt ServerLenR6 t sendMapStringR@ R t FilterServerListt DBConfigt GroupNamet popt! _LogicProcessThread__SendMergeMsg( R# R- t recvPackt
|
toServerIDt serverGroupDic( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyRC s4 c
|
C sí t j r{ t j r{ t j } | s) d St | | _ t | j | _ | j | j
|
| j | t j d d St j j d } | s d Sd | k r» t j | j } n x | j D]\ } } t | | _ t | j | _ | t j k r | j | j
|
qÈ n t j j | } | sUt j d | | f qÈ n t | | _ t | j | _ | j | j
|
| j | j | j j | j j t j | j j | j j! | j" qÈ Wt j d d S( Ns forward to serversroute Hubt Merget AllServers Ïò×Ó·þ%s·¢ËÍÏûϢʧ°Ü %s s forward to serversroute Child(# Re t IsMsgFowardHubt MsgFowardHubIPt ServerRouteClientt GetServersRouteChildR` Ra R_ Rb t setBufferR@ t SendPackR R6 R t getServerMgrt GetServerR t GetAllServerR] t iteritemsRf Rc t MergeProxyClientMgrt getMergeProxyClientMgrt findClientByCompoundKeyR: R< R& R= R R( R> R? R+ ( R# R- Ri Rk t serverRouteClientR$ t groupNamet
|
serverListt client( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt __SendMergeMsg² sJ 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 St
|
j r d d l } t j d | j | j n | j } t j } | j | j t j | j | t k rå d St j | j | j } t j | k ryO t | t j | _ t | j | _ | j! | j" t# j$ | | Wqt j d t j% d t& j' } t j | qXn | j( t j t | d k r½d S| j) | | | d 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 Rt Ru R4 t GetClientCntR RS t ERROR_NO_173R t DeployErrorR t IsDebugt binasciiR6 t b2a_hexR+ R; R t tagGMCommandR\ t
|
g_GMCMDMgrt AddPairt OrderIdR R Rd Ra R] Re Rf R` R_ Rb Rr R@ R RA t ERROR_NO_172RU RV Rg Rh ( R# R- t GmToolServerRY R
R< Ri Rk ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyRA ê 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 RB R RS R RU RV R R t PopPairR RG RP R Rt R: R R( R t stGMToolt stCenterGateR@ ( R# R- Rs RY t sendViaSessionIDt SessionIDt PoolIndext ServerMgr( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyRB s( " c C sV t j } | j d d } d } d } | j | | | t j t j t j | d S( Nt RouteServeri iÿÿÿÿ( R Rt t getClientSessionIDByNameR: R t atWorldLogicR t stRouteR ( R# t bufR R R R ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyRc : s ( t __name__t
|
__module__R R/ R1 R5 RE RF RK RZ RC Rh RA RB Rc ( ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyR s * 8 - #(# t threadingR R t timeR t DBCommonR R R R t CommonR R t ProtocolR R R
|
R t
|
__import__Re t NetR RU t GMToolLogicProcessR R Rx t jsont cPicklet ConfigR Rp t GetGMOrderMgrR R ( ( ( s" .\н¨Îļþ¼Ð\LogicProcessThread.pyt <module> s ""
|
