ó
|
Eî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
|
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 MongoDBServer( 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 .\\MergeServer_LogicProcess.pyR s c C s | j j | d S( N( R t
|
put_nowait( R t pack( ( s .\\MergeServer_LogicProcess.pyt requestPush( s c C s> y | j j } Wn$ t j k
|
r9 d } t d n X| S( Ngü©ñÒMb`?( R t
|
get_nowaitR t Emptyt NoneR ( R R ( ( s .\\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 .\\MergeServer_LogicProcess.pyR& 3 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 .\\MergeServer_LogicProcess.pyt stop8 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 .\\MergeServer_LogicProcess.pyt run? s"
|
( " c C s$ | j | r | j | t St S( N( t
|
canProcessR! R* R ( R R ( ( s .\\MergeServer_LogicProcess.pyt dispatchX 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 R2 t ERROR_NO_47R0 R R t ReadDatat getProcFunct Cmdt SubCmdR t getPackPoolt freeR* ( R R t buft HeadR7 t post procFunc( ( s .\\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 subCmdRI ( ( s .\\MergeServer_LogicProcess.pyRA p s
|
c C s | j d S( N( t
|
disconnect( R t netClient( ( s .\\MergeServer_LogicProcess.pyt disconnectClientBySessionIDx s c C sã d } t } | j rM | | j | k rM | j | k rF | | _ qM d Sn | | _ | j j } xw | D]o } | j s ql n | j sl | j j | j } | s· t | _ ql n | j
|
| t j d | j ql ql Wd S( Ni s Kick client sessionID = %s( R R R t getClientListt isValidt checkHeartbeatR t FindClientBySessionIDt sessionIDR RP R R' ( R t procIntervalt nowTimet
|
clientListt clientRO ( ( s .\\MergeServer_LogicProcess.pyR- ~ s$ c C s | j j | j k r t St S( N( t getPackHeadt typeR R R* ( R R ( ( s .\\MergeServer_LogicProcess.pyR9 s c C sÅ | j j t d | j j t d } t j r] t j d | j | j | f n t j } | j
|
| | j } | | j j t d k r¤ t St j d | | j f t S( Ni s+ ClientGUID = %s, TimeStamp = %s, stuff = %ss result = %s;pack = %s( t
|
ClientGUIDt stript chrt TimeStampR t IsDebugR t debugt md5t newt updatet hexdigestt
|
VerifyCodeR* t OutputStringR ( R t loginPackt stufft md5Objt result( ( s .\\MergeServer_LogicProcess.pyt LoginVerify£ s . # c C sh | 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 | sud | _ 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 | 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 | s8| r4| j | n d S| j j! | j }
|
|
|
sZd S|
|
j" d S( Ni iÿÿÿÿs buf = %ss recvPack = %ss Invalid client!s Invalid client:%s/%s %ss Client not found!sessionID = %s!t i s Client %s login...(# R; R= R
|
t tagLPLoginPackR R` t binasciiR Ra t b2a_hexR@ Rg R t tagPLLoginResultRl t Resultt ErrMsgt ErrMsgLenR t packSendBySessionIDt getSessionIDR t GetBufferR' R\ t GroupNameR_ RT R/ RP t addrR t updateClientt findClientBySessionIDt refreshHeartbeat( R R RF RH t lengtht recvPackRo t sendPackRY t clientIPt validClient( ( s .\\MergeServer_LogicProcess.pyt proc_0x01_0x01² sL 1# 1'c C sF t j d | j | j j | j } | s9 d St | _ d S( Ns Client logout!sessionID = %s( R R' Rv R R{ R RR ( R R R ( ( s .\\MergeServer_LogicProcess.pyt proc_0x01_0x02æ s
|
c C s | j } t j d | | j j | } | s9 d St j d | j t j } | j j | j
|
d d t j d d | j d S( Ns$ sessionID = %s refreshHeartbeat recvs proc_0x01_0x03, successi ( Rv R Ra R R{ R| R t tagPLHeartbeatR Ru RU R R Rw ( R R RU RY R ( ( s .\\MergeServer_LogicProcess.pyt proc_0x01_0x03î s
|
!( t __name__t
|
__module__R R! R% R& R, R8 R: R. RA RP R- R9 Rl R R R
( ( ( s .\\MergeServer_LogicProcess.pyR s 4 ( t __doc__t threadingR R R4 R R t inspectRb t NetR t CommonR R t DBCommonR R R t ProtocolR R
|
R R t
|
__import__t DBConfigR ( ( ( s .\\MergeServer_LogicProcess.pyt <module> s
|
