ó
|
SÂhc @ 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( ( s% .\\ServersRoute\PackDispatchThread.pyR s
|
c C s' x t r"| j j } | 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 rÍ t j
|
d t j j | q n | j j | rt j
|
d | j j | q n t j
|
d | j j | q Wd S( Ni s pack %s dispatching...s atHeart not processed!s atDisconnect not processed!s' Further dispatch to logicProcessThread!s" Further dispatch to ctrlDBManager!( t TrueR t recvQueuePopNoWaitt NoneR t GetStatt packDispatchThreadCountt getPackHeadt typeR t debugt outputStringR t atHeartR t getPackPoolt freet atDisconnectR t
|
canProcesst requestPushR t dbRequestPush( R t packt packType( ( s% .\\ServersRoute\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 t infot getNamet ident( R ( ( s% .\\ServersRoute\PackDispatchThread.pyR( > 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 ( ( s% .\\ServersRoute\PackDispatchThread.pyt stopC s
|
( t __name__t
|
__module__R R' R( R- ( ( ( s% .\\ServersRoute\PackDispatchThread.pyR s $ ( t threadingR t timeR t NetCoreR t LogicProcessR t DBCommonR R R t LogicProcessThreadt CommonR R t
|
__import__t DBConfigR ( ( ( s% .\\ServersRoute\PackDispatchThread.pyt <module> s
|
