ó
|
ç,hc @ sÜ d Z d d l m Z d d l Z d d l Z d d l m Z m Z d d l Z d d l Z d d l m
|
Z
|
m Z d d l m Z m Z m Z d d l m Z m Z m Z d d l Z e d Z d e f d
|
YZ d S( s:
|
¿ç·þÂß¼´¦ÀíÄ£¿é
|
dispatch ¹©·â°ü·Ö·¢Âß¼µ÷ÓÃ
|
iÿÿÿÿ( t ThreadN( t sleept time( t mylogt CommFunc( t SingletonObjectt CommonDefinet error( t PackCommonDeft MergeServerRecvProtocolt MergeServerSendProtocols Config.DBConfigt 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 sq t j | d | | | _ t j | _ t | _ t j | _ | j j
|
| j _ d | _ t j f | _ d S( Nt namei ( R t __init__t _LogicProcessThread__serverObjt Queuet! _LogicProcessThread__requestQueuet Falset _LogicProcessThread__elegantExitt MergeProxyClientMgrt getMergeProxyClientMgrt# _LogicProcessThread__validClientMgrt delClientt onClientDisconnectExt* _LogicProcessThread__lastHeartbeatProcTickR t
|
atMergeSyst _LogicProcessThread__type( t selft
|
threadNamet serverObj( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyR s c C s | j j | d S( N( R t
|
put_nowait( R t pack( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt requestPush& s c C s4 y | j j } Wn t j k
|
r/ d } n X| S( N( R t
|
get_nowaitR t Emptyt None( R R ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt
|
requestPop) s
|
|
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+ .\\ServersRoute\MergeServer_LogicProcess.pyR% 0 s c C sj t j d | j | j f t | _ x | j rE t d q, Wt j d | j | j f d S( Ns Stopping thread %s(%s)g¹?s Thread %s(%s) stop ok!( R R& R' R( t TrueR t isAliveR ( R ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt stop5 s
|
c C sí xæ t rè yV | j | j } | d k r2 Pn | j | rG w 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( Ns Pack %s not processed!R s" Exception %s caught!traceback = %ss' Unknown exception caught!traceback = %s( R) t processHeartbeatR$ R# t processRequestR t warningt outputStringt ExceptionR t formatMsgt ERROR_NO_28t tracebackt
|
format_exc( R R t et msg( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt run< s"
|
( " c C s$ | j | r | j | t St S( N( t
|
canProcessR R) R ( R R ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt dispatchU s c C s¾ | j } t j } t | | j k rc t j d t j d | j } t j | t
|
Sd } | j | | } | j | j | j } | rº | | t j j | t St
|
S( NR s Pack %s error!i ( t getBufferR t tagHeadt lent GetLengthR R1 t ERROR_NO_47R/ R R t ReadDatat getProcFunct Cmdt SubCmdR t getPackPoolt freeR) ( R R t buft HeadR6 t post procFunc( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyR- [ s "
|
c C s6 y t | d | | f } Wn t k
|
r1 d SX| S( Ns proc_0x%02X_0x%02X( t getattrt AttributeErrorR# ( R t cmdt subCmdRH ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyR@ m s
|
c C s) | j j | d d t j d d d d S( Ni t ( R t packSendBySessionIDR t atDisconnect( R t sessionID( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt disconnectClientBySessionIDu s c
|
C s9 d } t } | j rM | | j | k rM | j | k rF | | _ qM d Sn | | _ | j j } xÍ | D]Å } | j s ql n | j rÔ | j t j } | j j
|
| j d d t j d d | j n | j sl | j j | j } | s
|
t | _ ql n | j | j t j d | j ql ql Wd S( Ni i s Kick client sessionID = %s( R R R t getClientListt isValidt shouldSendHeartbeatt refreshSendHeartbeatTickR
|
t tagPLHeartbeatR RN RP R R t GetBuffert checkHeartbeatt FindClientBySessionIDR RQ R R& ( R t procIntervalt nowTimet
|
clientListt clientt sendPackt netClient( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyR, { s.
|
! c C s | j j | j k r t St S( N( t getPackHeadt typeR R R) ( R R ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyR8 s c C sÚ | j j t d | j j t d } t j rr d d l } t j d | j | j | j | f n t
|
j } | j | | j } | | j j t d k r¹ t St j d | | j f t S( Ni iÿÿÿÿs+ ClientGUID = %s, TimeStamp = %s, stuff = %ss result = %s;pack = %s( t
|
ClientGUIDt stript chrt TimeStampR t IsDebugt binasciiR t debugt b2a_hext md5t newt updatet hexdigestt
|
VerifyCodeR) t OutputStringR ( R t loginPackt stuffRg t md5Objt result( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt LoginVerify¦ s . , c
|
C s& | j } d } t | } t j } t j r_ d d l } t j d | j | n | j
|
| | | t j r t j d | j n t j } | j | s{d | _ d | _ t | j | _ | j j | j d d t j d d | j t j d | j | j | j f | j j | j } | sdt j d | j d S| j | j d Sd } | j j | j } | r¯| j d } n d | _ | j j | j d d t j d d | j t j d
|
| j | j j | j | j | j | d S( Ni iÿÿÿÿs buf = %ss recvPack = %ss Invalid client!s Invalid client:%s/%s %ss Client not found!sessionID = %s!RM i s Client %s login...(! R: R< R t tagLPLoginPackR Rf Rg R Rh Ri R? Ro R
|
t tagPLLoginResultRt t Resultt ErrMsgt ErrMsgLenR RN t getSessionIDR RW R& Rb t GroupIDRe RY R. RQ t addrR t updateClient(
|
R R RE RG t lengtht recvPackRg R^ R] t clientIP( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt proc_0x01_0x01µ s> 1# 1c C sF t j d | j | j j | j } | s9 d St | _ d S( Ns Client logout!sessionID = %s( R R& Rz R t findClientBySessionIDR RS ( R R t validClient( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt proc_0x01_0x02á s
|
c C sT | j } t j d | | j j | } | s9 d St j d | j d S( Ns$ sessionID = %s refreshHeartbeat recvs proc_0x01_0x03, success( Rz R Rh R R t refreshHeartbeat( R R RP R] ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt proc_0x01_0x03è s ( t __name__t
|
__module__R R R$ R% R+ R7 R9 R- R@ RQ R, R8 Rt R R R ( ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyR s $ , ( t __doc__t threadingR R R3 R R t inspectRj t CommonR R t DBCommonR R R t ProtocolR R R
|
R t
|
__import__t DBConfigR ( ( ( s+ .\\ServersRoute\MergeServer_LogicProcess.pyt <module> s
|
