ó
|
lÆ{Pc @ s¤ d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z m
|
Z
|
m Z d d l Z d d l m Z m Z e d Z d e f d
|
YZ d S( iÿÿÿÿ( t Thread( t sleep( t AsyncoreServer( t CtrlDBManager( t CommonDefinet SingletonObjectt StatN( t CommFunct mylogs Config.DBConfigt PackDispatchThreadc B s, e Z d Z d Z d Z d Z RS( c C s; t j | d d | | _ | | _ | | _ t | _ d S( Nt nameR ( R t __init__t _PackDispatchThread__servert" _PackDispatchThread__ctrlDBManagert' _PackDispatchThread__logicProcessThreadt Falset _PackDispatchThread__eleganExit( t selft servert ctrlDBManagert logicProcessThread( ( s3 .\server\db\PyMongoDataServer\PackDispatchThread.pyR s
|
c C su xUt rW| j j } t j rM | d k rr | j r: Pn t d q qr n% | d k r] Pn t j j
|
d 7_
|
| j j } t j d | j | t j k rÍ t j d t j j | q n | t j k rt j d t j j | q n | j j | r7t j d | j j | q n t j d | j j | q Wt j rqt j d n d S( Ng¹?i s pack %s dispatching...s atHeart not processed!s atDisconnect not processed!s' Further dispatch to logicProcessThread!s" Further dispatch to ctrlDBManager!s Thread exit!( t TrueR t recvQueuePopNoWaitt DBConfigt MultiThreadingt NoneR R R t GetStatt packDispatchThreadCountt getPackHeadt typeR t debugt outputStringR t atHeartt warningR t getPackPoolt freet atDisconnectR t
|
canProcesst requestPushR t dbRequestPusht info( R t packt packType( ( s3 .\server\db\PyMongoDataServer\PackDispatchThread.pyt run 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 R( t getNamet ident( R ( ( s3 .\server\db\PyMongoDataServer\PackDispatchThread.pyR, F s c C sX t j d | j t | _ x | j r< t d q# Wt j d | j d S( Ns Stoping thread %s...g¹?s Thread %s stop OK!( R R( R- R R t isAliveR ( R ( ( s3 .\server\db\PyMongoDataServer\PackDispatchThread.pyt stopK s
|
( t __name__t
|
__module__R R+ R, R0 ( ( ( s3 .\server\db\PyMongoDataServer\PackDispatchThread.pyR s , ( t threadingR t timeR t NetCoreR t LogicProcessR t DBCommonR R R t LogicProcessThreadt CommonR R t
|
__import__R R ( ( ( s3 .\server\db\PyMongoDataServer\PackDispatchThread.pyt <module> s
|
