ó
|
½ic @ s¸ d Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z e d d d g Z
|
d d d
|
YZ d d d YZ d d d YZ d S( s-
|
Îļþ¹ÜÀíÄ£¿é
|
¸ºÔðÈÕÖ¾ÎļþµÄ´´½¨¡¢Ð´ÈëºÍ¹ÜÀí
|
iÿÿÿÿN( t
|
namedtuple( t packet_logger( t
|
ClientsMgrt FileInfot server_idt
|
event_typet FileWriteStatsc B sD e Z d Z d Z d Z d Z d Z d Z d Z RS( s ÎļþдÈëͳ¼Æc C s% t j | _ d | _ d | _ d S( Ni ( t threadingt Lockt lockt success_countt
|
fail_count( t self( ( s .\\EventServerPY\file_manager.pyt __init__ s c C s# | j | j d 7_ Wd QXd S( Ni ( R R
|
( R ( ( s .\\EventServerPY\file_manager.pyt add_success s
|
c C s# | j | j d 7_ Wd QXd S( Ni ( R R ( R ( ( s .\\EventServerPY\file_manager.pyt add_fail! s
|
c C s | j | j SWd QXd S( N( R R
|
( R ( ( s .\\EventServerPY\file_manager.pyt get_success_count% s
|
c C s | j | j SWd QXd S( N( R R ( R ( ( s .\\EventServerPY\file_manager.pyt get_fail_count) s
|
c C s& | j d | _ d | _ Wd QXd S( Ni ( R R
|
R ( R ( ( s .\\EventServerPY\file_manager.pyt reset- s
|
( t __name__t
|
__module__t __doc__R R R R R R ( ( ( s .\\EventServerPY\file_manager.pyR s t WriteFilec B s; e Z d Z d Z d Z d Z d Z d Z RS( s µ¥¸öÎļþдÈëÆ÷c C s; | | _ d | _ t | _ | | _ | | _ | j d S( N( t filenamet Nonet file_handlet Falset is_readyt success_callbackt fail_callbackt open_file( R R R R ( ( s .\\EventServerPY\file_manager.pyR 6 s c C s y` t j j | j } | rA t j j | rA t j | n t | j d | _ t | _ Wn4 t
|
k
|
r } t | _ d | j t | f GHn Xd S( s ´ò¿ªÎļþt abs. [WriteFile] Failed to open file: %s, error: %sN( t ost patht dirnameR t existst makedirst openR t TrueR t ExceptionR t str( R t dir_patht e( ( s .\\EventServerPY\file_manager.pyR > s c C sà | j s# | j r | j n t SyN | d j d } | j j | | j j | j rl | j n t SWnK t k
|
r¾ } d | j
|
t | f GHt | _ | j rº | j n t SXd S( s дÈë×Ö·û´®Êý¾Ýs
|
t gbks* [WriteFile] Failed to write: %s, error: %sN( R R R t encodeR t writet flushR R& R' R R( ( R t datat lineR* ( ( s .\\EventServerPY\file_manager.pyt write_stringM s" c C s= | j r9 y | j j Wn n Xd | _ t | _ n d S( s ¹Ø±ÕÎļþN( R t closeR R R ( R ( ( s .\\EventServerPY\file_manager.pyR2 d s c C s | j d S( N( R2 ( R ( ( s .\\EventServerPY\file_manager.pyt __del__n s ( R R R R R R1 R2 R3 ( ( ( s .\\EventServerPY\file_manager.pyR 3 s
|
t FileMgrc B s_ e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z RS(
|
s
|
Îļþ¹ÜÀíÆ÷c C s | | _ t j | _ i | _ t | _ | j j | _ t j
|
j | j s y t j | j Wq t k
|
r } d | j t | f GHq Xn d S( Ns1 [FileMgr] Failed to create log dir: %s, error: %s( t configR R R t file_mapR t statst get_log_file_patht log_pathR R! R# R$ R' R( ( R R5 R* ( ( s .\\EventServerPY\file_manager.pyR u s c C sÎ t j } | j | } | d k r> t j d | d n t | | } | j r | | j k rv | j | nC | j | } | j | | s¹ | j
|
| j | =| j | n | j | SWd QXd S( s »ñÈ¡ÎļþдÈëʵÀýi s@ FileMgr: WARNING - cid=%d has no server_id set! Defaulting to S0t WARNN( R t instancet get_client_server_idR t log_textR R R6 t _create_file_writert _check_file_validR2 ( R t cidR t clients_mgrR t file_infot
|
write_file( ( s .\\EventServerPY\file_manager.pyt get_instance s
|
|
|
c C s | j j } d | j } t j j | j | } t j j j d } t j j | | } | d k r d | j
|
| f } n | d k r½ t j j j d } d | j
|
| f } nG | d k r÷ t j j j d } d | j
|
| f } n d | j
|
} t j j | | S(
|
s »ñÈ¡Îļþ·¾¶s S%ds %Y-%m-%di s %s_%s.txti s %Y-%m-%d_%Hi s %Y%m%d_%H%M%Ss %s.txt( R5 t get_write_modeR R R! t joinR9 t datetimet nowt strftimeR ( R RB t
|
write_modet server_foldert folder_patht date_strt date_folderR t date_time_str( ( s .\\EventServerPY\file_manager.pyt _get_file_path s c C s | j s t S| j j } t j j j d } | | j k rG t S| d k r | j j d } y) t j
|
j | j } | | k r t SWq q Xn t S( s ¼ì²éÎļþÊÇ·ñÓÐЧ(ÊÇ·ñÐèÒªÇл»)s %Y-%m-%di i ( R R R5 RE RG RH RI R t get_max_file_sizeR R! t getsizeR& ( R RC RB RJ t current_datet max_sizet file_size( ( s .\\EventServerPY\file_manager.pyR? µ s c C s> | j | } t | | j j | j j } | | j | <d S( s ´´½¨ÎļþдÈëÆ÷N( RP R R7 R R R6 ( R RB t filepathRC ( ( s .\\EventServerPY\file_manager.pyR> Ì s c C s | j | | } | j | S( s дÈëʼþÊý¾Ý( RD R1 ( R R@ R t
|
event_dataRC ( ( s .\\EventServerPY\file_manager.pyt write_eventÖ s c C s | j j S( s »ñÈ¡³É¹¦Ð´Èë´ÎÊý( R7 R ( R ( ( s .\\EventServerPY\file_manager.pyR Û s c C s | j j S( s »ñȡʧ°ÜдÈë´ÎÊý( R7 R ( R ( ( s .\\EventServerPY\file_manager.pyR ß s c C sE | j 6 x! | j j D] } | j q W| j j Wd QXd S( s ¹Ø±ÕËùÓÐÎļþN( R R6 t valuesR2 t clear( R RC ( ( s .\\EventServerPY\file_manager.pyt close_allã s
|
( R R R R RD RP R? R> RX R R R[ ( ( ( s .\\EventServerPY\file_manager.pyR4 r s
|
( ( ( ( R R t timeRG R t collectionsR R t clients_managerR R R R R4 ( ( ( s .\\EventServerPY\file_manager.pyt <module> s ?
|
