ó
|
æñíhc @ sG 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( 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 l0 Z0 e1 d Z2 d Z3 d Z4 y d d l5 Z5 Wn e6 k
|
rÿd d l7 Z5 n Xd Z8 d Z9 d Z: d Z; d Z< e= d k rCe< 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 CheckAndUpdateIndex( t FileLog( t Commandst ReloadModules 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 RouteServers 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 updateServerStatusO 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 Ra 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 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 s t 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 yt j } t j d } | j! d
|
| t j } | j! d | t j" } | r¬t j d } | j! d | n t# j$ } t% j% | } | j& | t' j' | } | t( _) t* j* | | | } t* j* | | | }
|
| rLt+ j' d | } t, j* d | | | | } n^ t j- rªt. j. t j- t j/ } t. j0 | t1 j' d | } t, j* d | | | | } n t j t j2 t j d | j3 t j4 d | j3 t j5 d | r | j3 t j/ d n t6 j7 t t6 j8 t9 t j t j: t j d t j d t; j< j= j> d t? j? d t@ t t } t9 } t jA tB jC d d } xt6 jD r³tE jF } tG jH d t9 d d tE jF | tJ jK _L tE jF } | jM tE jF | tJ jK _N | r'| jM n t j- r=| jM n |
|
jM tE jF } | jM tE jF | tJ jK _O | r| jM n t j- r| jM n tE jF } | jM tE jF | tJ jK _P | jQ | së| jR n tS rtT } | d k rqn t } t
|
jU jV | | | 7} | jW d d k rJqn | jX } | jY } d } tZ | d k r| d } | d } n t6 j[ | | d } t9 } qqWWn t\ j k
|
r } t j d t j] d | } t j^ | t6 j_ n@ t j d t j` d ta jb } t j^ | t6 j_ n X| jc | s]| jc n t j t j tB jC d d GHd } x¹ t6 jd s@tS rtT } | d k r¸qn t
|
jU jV | | | 7} | jW d d k ríqn | je d d } | d k rtf qn d GHd } tB jC d tg d qqWd S(! Ns python version = %ss pymongo version = %ssU -------------------------------------------------------------------------------------s login on user db %s:%s...t DeployErrors: LoginMongoDB failed:ip = %s, port = %s, user = %s,pwd = %siÿÿÿÿs login on user db ok!i R t GMToolt Merget mergeServerLogicProcessThreadt MergeServer_PackDispatcht mergeChildLogicProcessThreadt MergeChild_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 ExitRf gü©ñÒMbP?(h R t setServerStateR t mssNoneRd R R t InitR Ra R$ R% R& R' Ri RW t InitCollectorDllRZ t DBConfigt
|
USER_DB_IPt USER_DB_PORTt LoginMongoDBt userdb_usert
|
userdb_pwdR t formatMsgt ERROR_NO_13Rj t TrueRf R R R/ t AddServert IsMsgFowardHubR
|
R3 R t addCtrlDBt LogicProcessThreadR t g_logicProcessThreadt PackDispatchThreadt MergeServer_LogicProcessRn t MsgFowardHubIPt ServerRouteClientt MsgFowardHubPortt SetServersRouteChildt MergeServer_ChildLogicProcesst
|
mssInitingt startt PyMongoDBPortt PyMongoDBPort_GMToolR t setActivet
|
setCanExitt Falset
|
mssRunningt ctypest windllt kernel32t SetConsoleTitleAR RV t removeConsoleHandlerR R t isActivet timeitt default_timert asyncoret loopt NoneR R< RD t runRE RF RC 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 isCanExitt replacet ExitR ( RY t ServerMgrRR t GMToolServerObjt isMergeServert MergeServerObjt ctrlDBMgrt usrCtrlDBRF t packDispatchThreadt GMTool_packDispatchThreadRm t Merge_packDispatchThreadt serverRouteClientRo t MergeChild_packDispatchThreadt tmrUpdateServerStatust pauseUpdateServerStatusTimert usrCmdt tickt hitChart cmdListt usrParamt e( ( s .\\ServersRoute\main.pyt main³ s"
|
|
|
$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 CollectionsR R Rn R R t CmdShellR R RW R R t
|
__import__Rw t ssClosingt ssClosedR) t ImportErrort dummy_threadingRV RZ Rd Ri RÅ t __name__( ( ( s .\\ServersRoute\main.pyt <module> sN . ( F Ú
|
