ó
|
±ýî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 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
|
namedtuplet OrderedDict( 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 .\file_manager.pyt __init__ s c C s# | j | j d 7_ Wd QXd S( Ni ( R
|
R ( R ( ( s .\file_manager.pyt add_success s
|
c C s# | j | j d 7_ Wd QXd S( Ni ( R
|
R ( R ( ( s .\file_manager.pyt add_fail! s
|
c C s | j | j SWd QXd S( N( R
|
R ( R ( ( s .\file_manager.pyt get_success_count% s
|
c C s | j | j SWd QXd S( N( R
|
R ( R ( ( s .\file_manager.pyt get_fail_count) s
|
c C s& | j d | _ d | _ Wd QXd S( Ni ( R
|
R R ( R ( ( s .\file_manager.pyt reset- s
|
( t __name__t
|
__module__t __doc__R R R R R R ( ( ( s .\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 sJ | | _ d | _ t | _ | | _ | | _ t j | _ | j d S( N(
|
t filenamet Nonet file_handlet Falset is_readyt success_callbackt fail_callbackt timet last_accesst open_file( R R R R ( ( s .\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 .\file_manager.pyR! ? s c C sÒ | j s# | j r | j n t Sy] | d j d } | j j | | j j | j rl | j n t j | _ 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 R+ ( R t datat lineR- ( ( s .\file_manager.pyt write_stringN 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 .\file_manager.pyR5 f s c C s | j d S( N( R5 ( R ( ( s .\file_manager.pyt __del__p s ( R R R R R! R4 R5 R6 ( ( ( s .\file_manager.pyR 3 s
|
t FileMgrc B sq e Z d Z d 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 | _ t | _ t | _ | j j | _ | j j
|
| _ | 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
|
R t file_mapR t statst get_log_file_patht log_patht get_max_open_filest max_open_filest get_idle_timeoutt idle_timeoutR# R$ R& R' R* R+ ( R R8 R- ( ( s .\file_manager.pyR w s c C s t j } g } xC | j j D]2 \ } } | | j | j k r" | j | q" q" Wx) | D]! } | j | j | j | =q_ Wd S( s ¹Ø±Õ³¬¹ý¿ÕÏÐʱ¼äµÄÎļþ£¬Êͷžä±úN( R R9 t itemsR R@ t appendR5 ( R t nowt to_removet file_infot
|
write_file( ( s .\file_manager.pyt _cleanup_idle_files s c C sh xa t | j | j k rc | j j d t \ } } | j t j d | j | j f d q Wd S( ss
|
È·±£´ò¿ªµÄÎļþÊý²»³¬¹ý×î´óÏÞÖÆ¡£
|
Èç¹ûµ½´ïÉÏÏÞ£¬¹Ø±Õ×î¾ÃδʹÓõÄÎļþ£¨OrderedDict Ê×룩¡£
|
t lastsB FileMgr: Reached max open files limit (%d), closed oldest file: %st WARNN( t lenR9 R> t popitemR R5 R t log_textR ( R t oldest_infot oldest_writer( ( s .\file_manager.pyt _enforce_max_open_limit s
|
c C s t j } | j | } | d k r> t j d | d n t | | } | j ¥ | j | | j k r | j | j
|
| nb | j | } | j | | sÍ | j | j | =| j
|
| n | j j | } | | j | <| j | SWd QXd S( s »ñÈ¡ÎļþдÈëʵÀýi s@ FileMgr: WARNING - cid=%d has no server_id set! Defaulting to S0RI N( R t instancet get_client_server_idR RL R R
|
RG R9 RO t _create_file_writert _check_file_validR5 t pop( R t cidR t clients_mgrR RE RF t value( ( s .\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( R8 t get_write_modeR R# R$ t joinR< t datetimeRC t strftimeR ( R RE t
|
write_modet server_foldert folder_patht date_strt date_folderR t date_time_str( ( s .\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 R8 RY R[ RC R\ R t get_max_file_sizeR# R$ t getsizeR) ( R RF RE R] t current_datet max_sizet file_size( ( s .\file_manager.pyRS à s c C s> | j | } t | | j j | j j } | | j | <d S( s ´´½¨ÎļþдÈëÆ÷N( Rc R R: R R R9 ( R RE t filepathRF ( ( s .\file_manager.pyRR ÷ s c C s | j | | } | j | S( s дÈëʼþÊý¾Ý( RX R4 ( R RU R t
|
event_dataRF ( ( s .\file_manager.pyt write_event s c C s | j j S( s »ñÈ¡³É¹¦Ð´Èë´ÎÊý( R: R ( R ( ( s .\file_manager.pyR s c C s | j j S( s »ñȡʧ°ÜдÈë´ÎÊý( R: R ( R ( ( s .\file_manager.pyR
|
s c C sE | j 6 x! | j j D] } | j q W| j j Wd QXd S( s ¹Ø±ÕËùÓÐÎļþN( R
|
R9 t valuesR5 t clear( R RF ( ( s .\file_manager.pyt close_all s
|
( R R R R RG RO RX Rc RS RR Rk R R Rn ( ( ( s .\file_manager.pyR7 t s $
|
( ( ( ( R R# R R[ R t collectionsR R R t clients_managerR R R R R7 ( ( ( s .\file_manager.pyt <module> s A
|
