ó
|
=4hc @ sO d d l 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 d d l
|
Z
|
d d l m Z m Z m Z m Z m Z m Z d d l m Z d d l m Z m Z d d l Z d d l m Z m Z m Z m Z m 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& d d l' m( Z( d d l m) Z) d d l* Z* d d l+ Z+ d d l, Z, d d l- m. Z. m/ Z/ d d l0 Z0 d d l% m1 Z1 e2 d Z3 d Z4 d Z5 y d d l6 Z6 Wn e7 k
|
rd d l8 Z6 n Xd Z9 d Z: d Z; d Z< d Z= e> d k rKe= n d S( iÿÿÿÿN( t kbhitt getch( t sleep( t mylogt ConsoleCtrlt Timert ConsolePrintMgrt CommFunct
|
CommFuncEx( t MongoDBServer( t CtrlDBManagert
|
UserCtrlDB( t CommonDefinet GlobalFunctionst SingletonObjectt EnvCheckt Stat( t RecvPackProtocolt
|
MMORPGPack( t errort GlobalVarDefine( t EventShellProxy( t CheckAndUpdateIndex( t FileLog( t Commandst ReloadModule( t EventReports Config.DBConfigi i c C s t j d t j } | j d d | j \ } } d } d j g t | D] } d ^ qT } t j r d GH| GHn d t
|
j GHd t j GHd GHt j GH| GHt j } | r d t | GHxK t t | D]4 } | | } d
|
| | j | j | j f GHqã Wn | GHt j j d } d | j GHd | j GH| GHt j } d | j | j f GHd | j | j f GHx t | j D]t } | j | }
|
d |
|
j |
|
j! |
|
j" f GHx; t |
|
j# D]' } d |
|
j | |
|
j$ | f GHqùWq°Wd t% j& j' t% j& j( f GHd t% j& j) GHd t% j& j* GHd t% j& j+ GHd t% j& j, GHd t% j& j- GHd t% j& j. GHd t% j& j/ GHd t% j& j0 GH| GHd t1 j2 j3 GHd t1 j2 j4 GHd S( Nt clsi s -t s >>>Runing Debug Version Now<<<s python version = %ss pymongo version = %ss Status:s Threads(%s):s %2s %20s(%s) %st
|
RouteSevers recv pack queue %ss send pack queue %ss %s request queue %ss %s answer queue %ss %s state %s BlockCnt %ss %s queue[%s] %ss SendBytes = %s, RecvBytes = %ss packDispatchThreadCount = %ss Merge_packDispatchCount = %ss LogicProcessCount = %ss DBProcessCount = %ss DBProcessTime = %ss asyncoreLoopTime = %ss packDispatchThreadTime = %ss logicProcessThread = %ss PackPoolCount = %ss PackPoolAllocCount = %s(5 t ost systemR t GetDCCt GotoXYt GetWindowSizet joint rangeR t IsDebugt syst version_infot pymongot versionR t getLogStaticDictt threadingt enumeratet lent getNamet identt isAliveR t getServerMgrt GetServert recvQueueCntt sendQueueSizeR
|
t
|
getCtrlMgrt dbRequestQueueCntt dbAnswerQueueCntt getCtrlDBCntt getCtrlDBt getStatet BlockCntt getPrioorityQueueCntt getPriorityQueueSizeR t GetStatt SendBytest RecvBytest packDispatchThreadCountt Merge_packDispatchCountt LogicProcessCountt DBProcessCountt DBProcessTimet asyncoreLoopTimet packDispatchThreadTimet logicProcessThreadR t getPackPoolt countt getAllocCnt( t consolet consoleWinWidtht consoleWinHeightt splitChart it splitLinet
|
threadListt threadObjt serverObjt ctrlMgrt ctrlDBt j( ( s .\\ServersRoute\main.pyt updateServerStatusG sZ (
|
+ !)!c C s t j d S( N( t PegasusCollectorProxyt ErrorReport( t msg( ( s .\\ServersRoute\main.pyt OnPythonError s c C s d } t j j | s( t j | n t j | d t j j | d } t j | d t j
|
t j d t j d | t j
|
f d S( s
|
ÈÕÖ¾³õʼ»¯s C:\ServerLogt txts MongoDBServer.txtsU -------------------------------------------------------------------------------------s- Initialize log ok!log file = %s, isdebug = %sN( R t patht existst makedirsR t
|
InitializeR# R t InitMyLogR R% t info( t logPatht logFileName( ( s .\\ServersRoute\main.pyt InitLog s c C so t j d t j d t j \ } } | sQ t j d | t d d St j d t j d d S( NsU -------------------------------------------------------------------------------------s Initializing console window...s) Disable system menu failed!errorInfo = %siÿÿÿÿs Initialize console window ok!( R Rc R t SetConsoleWindowt exit( t resultt errorInfo( ( s .\\ServersRoute\main.pyt InitConsoleWindow s
|
c C se t j t j t t j t j t j r t
|
j j t j t j t j t j t j t j } | s~ t d d St j d t j t j f n t j d t j t j d t j t t j t t _ t j d t j d t j t j f t j t j! t j" t j t j st# j$ d t# j% d t j t j t j! t j" f } t j& | t' t d d St j d t( j( t j d t j rØx( t
|
j j) sÔd
|
GHt* d q°Wn yút+ j, } t+ j+ d } | j- d | t+ j+ } | j- d | t j. } | rVt+ j+ d t/ } | j- d | n t0 j1 } t2 j2 | } | j3 | t4 j4 | } | t5 _6 t7 j7 | | | }
|
t7 j7 | | | } | rót8 j4 d | } t9 j7 d | | | } n t j t j: t j d | j; t j< d | j; t j= d | rR| j; t j> d n t? j@ t' t? jA t/ t j t jB t j d t j d tC jD jE jF d tG jG d tH t' t' } t/ } t jI tJ jK d d } xêt? jL rÐtM jN } tO jP d t/ d d tM jN | tR jS _T tM jN } |
|
jU tM jN | tR jS _V | rp| jU n | jU tM jN } | jU tM jN | tR jS _W | r¼| jU n tM jN } | jU tM jN | tR jS _X | jY | s| jZ n t[ rçt\ } | d k r,qçn t' } t j] j^ | | | 7} | j_ d d k rgqçn | j` } | ja } d } tb | d k r®| d } | d } n t? jc | | d } t/ } qçqçWWn td j# k
|
r } t# j$ d t# je d | } t jf | t? jg n@ t# j$ d t# jh d ti jj } t jf | t? jg n X| jk t j r}t
|
jl n t j t j tJ jK d d GHd } x¹ t? jm s`t[ r¨t\ } | d k rØq¨n t j] j^ | | | 7} | j_ d d k r q¨n | jn d d } | d k r8to q¨n d GHd } tJ jK d t* d q¨q¨Wd S(! Niÿÿÿÿs9 EventShellDLL InitOK,EventShellIP =%s,EventShellPort = %ds python version = %ss pymongo version = %ssU -------------------------------------------------------------------------------------s login on user db %s:%s...t DeployErrors: LoginMongoDB failed:ip = %s, port = %s, user = %s,pwd = %ss login on user db ok!s! Please start EventServer first!!!i R t GMToolt Merget mergeServerLogicProcessThreadt MergeServer_PackDispatchi s4 MongoDBServer start OK!You can open RouteServer now!t ServersRoutei R R g ð?i s i t fatals socket error!err = %ss unknown err = %ss press'exit' to ExitRh gü©ñÒMbP?(p R t setServerStateR t mssNoneRf R R t Initt DBConfigt EventShellEnableR t GetEventShellProxyt InitDllt EventShellDllLogPatht EventShellIPt EventShellPortt EventShellGroupIDt EventShellServerIDt EventShellHeartIntervalRh R Rc R& R' R( R) Rk RY t InitCollectorDllR\ t
|
USER_DB_IPt USER_DB_PORTt LoginMongoDBt userdb_usert
|
userdb_pwdR t formatMsgt ERROR_NO_13Rl t TrueR t IsConnectedR R R1 t AddServert IsMergeServert FalseR
|
R5 R t addCtrlDBt LogicProcessThreadR t g_logicProcessThreadt PackDispatchThreadt MergeServer_LogicProcessRp t
|
mssInitingt startt PyMongoDBPortt PyMongoDBPort_GMToolt MergeServerPortR t setActivet
|
setCanExitt
|
mssRunningt ctypest windllt kernel32t SetConsoleTitleAR RX t removeConsoleHandlerR R t isActivet timeitt default_timert asyncoret loopt NoneR R> RF t runRG RH RE t processAllSendQueuet TickR R t stdoutt writet findt stript splitR- t
|
processCmdt sockett ERROR_NO_16Rr t CallExitt ERROR_NO_17t tracebackt
|
format_exct stopt FreeEventShellProxyt isCanExitt replacet Exit( t isInitOKR[ t ServerMgrRT t GMToolServerObjt isMergeServert MergeServerObjt ctrlDBMgrt usrCtrlDBRH t packDispatchThreadt GMTool_packDispatchThreadRo t Merge_packDispatchThreadt tmrUpdateServerStatust pauseUpdateServerStatusTimert usrCmdt tickt hitChart cmdListt usrParamt e( ( s .\\ServersRoute\main.pyt main« s
|
|
6
|
|
$4
|
|
|
|
|
|
|
|
|
|
"
|
|
t __main__(? R& R t msvcrtR R t timeR R¢ R² R® R t CommonR R R R R R t NetR t LogicProcessR
|
R R t DBCommonR R R R R t ProtocolR R R R( R R t
|
EventShellR t CollectionsR R Rp R R t CmdShellR R RY R t
|
__import__Rv t ssClosingt ssClosedR+ t ImportErrort dummy_threadingRX R\ Rf Rk RË t __name__( ( ( s .\\ServersRoute\main.pyt <module> sN . ( F ×
|
