ó
|
v-9hc @ s/ 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. e/ d Z0 d Z1 d Z2 y d d l3 Z3 Wn e4 k
|
rçd d l5 Z3 n Xd Z6 d Z7 d Z8 d Z9 d Z: e; d k r+e: 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 updateServerStatusK 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 s¨ 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 yút j } t j d } | j! d
|
| t j } | j! d | t j" } | r¯t j d t# } | j! d | n t$ j% } t& j& | } | j' | t( j( | } | t) _* t+ j+ | | | } t+ j+ | | | }
|
| rLt, j( d | } t- j+ d | | | } n t j t j. t j d | j/ t j0 d | j/ t j1 d | r«| j/ t j2 d n t3 j4 t t3 j5 t# t j t j6 t j d t j d t7 j8 j9 j: d t; j; d t< t t } t# } t j= t> j? d d } xêt3 j@ r)tA jB } tC jD d t# d d tA jB | tF jG _H tA jB } | jI tA jB | tF jG _J | rÉ| jI n |
|
jI tA jB } | jI tA jB | tF jG _K | r| jI n tA jB } | jI tA jB | tF jG _L | jM | sa| jN n tO r@tP } | d k r
q@n t } t
|
jQ jR | | | 7} | jS d d k rÀq@n | jT } | jU } d } tV | d k r| d } | d } n t3 jW | | d } t# } q@q@WWn tX j k
|
rv} t j d t jY d | } t jZ | t3 j[ n@ t j d t j\ d t] j^ } t jZ | t3 j[ n X| j_ t j t j t> j? d d GHd } x¹ t3 j` s£tO rëtP } | d k rqën t
|
jQ jR | | | 7} | jS d d k rPqën | ja d d } | d k r{tb qën d GHd } t> j? d tc d qëqëWd 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_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?(d 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 IsMergeServert FalseR
|
R3 R t addCtrlDBt LogicProcessThreadR t g_logicProcessThreadt PackDispatchThreadt MergeServer_LogicProcessRn t
|
mssInitingt startt PyMongoDBPortt PyMongoDBPort_GMToolt MergeServerPortR t setActivet
|
setCanExitt
|
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_16Rp 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 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 t
|
__import__Ru t ssClosingt ssClosedR) t ImportErrort dummy_threadingRV RZ Rd Ri R½ t __name__( ( ( s .\\ServersRoute\main.pyt <module> sJ . ( F Æ
|
