- ;cs2dkZdkZdkZdkZdkZdkZ"dfdYZUdefdYZdkZei Z dei fdYZ dei fdYZ d fd YZ d fd YZd fdYZdZdfdYZdS(Ns file_loggercsw"%dddZ0dZ3dZ7dZ;dZ?dZCd ZFd ZId ZRS( Nisacs%&t|tdjoH'|djo(dk})|i|_n+t|||_n -||_.||_dS(Nss-( stypesfilessyssstdoutsselfsopensmodesflushsdo_flush(sselfsfilesflushsmodessys((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__%s  cs01d|iSdS(Ns(sselfsfile(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__repr__0scs'34|ii|5|idS(N(sselfsfileswritesdatas maybe_flush(sselfsdata((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyswrite3scs'78|ii|9|idS(N(sselfsfiles writelineslines maybe_flush(sselfsline((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys writeline7scs';<|ii|=|idS(N(sselfsfiles writelinessliness maybe_flush(sselfslines((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys writelines;scs(?@|ioA|iindS(N(sselfsdo_flushsfilesflush(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys maybe_flush?s csCD|iidS(N(sselfsfilesflush(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pysflushCscs FGdS(N((sselfsargs((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys softspaceFscsIIJ|dddfjoK|i|dnM|i|dS(Nis s (smessagesselfswrite(sselfsmessage((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyslogIs( s__init__s__repr__swrites writelines writeliness maybe_flushsflushs softspaceslog(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys file_logger"s       srotating_file_loggercsYUZeedddZcdZgdZrdZwdZdZRS( NisacspZ[||_\||_]t|||_^||__||_`|i|i|_a||_ dS(N( sfilesselfsfilenamesmodesopensfreqsmaxsizes next_backups rotate_whensflushsdo_flush(sselfsfilesfreqsmaxsizesflushsmode((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__Zs    cscdd|iSdS(Ns(sselfsfile(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__repr__csc sghtiti\ } }}}}} }}}i|djo0jti | ||ddddddd Snk|djo4lti | |||ddddddd SnHm|djo0nti | |dddddddd Snpt SdS(Nsdailyiiisweeklyismonthly(stimes localtimesyrsmosdayshrsminssecswdsjdaysdstsfreqsmktimesNone( sselfsfreqswdsmosminshrsdstsdaysjdayssecsyr((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys next_backupgs3040cs5rs|it|iou|iindS(N(sselfs maybe_rotatesdo_flushsfilesflush(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys maybe_flushrs  cswx|ioti|ijo)y|iz|i|i|_ny{|iok|y;}ti|i ti |ijo~|inWn&ti j o|inXndS(N( sselfsfreqstimes rotate_whensrotates next_backupsmaxsizesossstatsfilenamesST_SIZEserror(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys maybe_rotatews#  &c stiti\ } }}}}} }}}y|i i d|i| ||f}y4t|di |d||| f}Wn nXti|i|t|i|i|_ Wn nXdS(Ns%s.ends%04d%02d%02dsrs -%02d%02d%02d(stimes localtimesyrsmosdayshrsminssecswdsjdaysdstsselfsfilesclosesfilenamesnewnamesopensossrenamesmode( sselfswdsmosminshrsdstsdaysjdaysnewnamessecsyr((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pysrotates3(sNones__init__s__repr__s next_backups maybe_flushs maybe_rotatesrotate(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pysrotating_file_loggerUs    s syslog_loggercs,ddZdZdZRS(Nsusercs<tii||ti||_||_dS(N(sm_syslogs syslog_clients__init__sselfsaddresssfacility_namessfacility(sselfsaddresssfacility((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__scsdt|iSdS(Ns(sreprsselfsaddress(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__repr__scs8tii||d|idtidS(Nsfacilityspriority(sm_syslogs syslog_clientslogsselfsmessagesfacilitysLOG_INFO(sselfsmessage((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyslogs (s__init__s__repr__slog(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys syslog_loggers s socket_loggercs)dZdZdZRS(Ncsut|tdjo|ititin|ititi|i|||_dS(Ns( stypesaddresssselfs create_socketssocketsAF_UNIXs SOCK_STREAMsAF_INETsconnect(sselfsaddress((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__s csd|iSdS(Ns(sselfsaddress(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__repr__scsI|ddjo|ii|dn|ii|dS(Nis (smessagesselfssocketspush(sselfsmessage((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyslogs(s__init__s__repr__slog(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys socket_loggers s multi_loggercs)dZdZdZRS(Ncs||_dS(N(sloggerssself(sselfsloggers((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__scsdt|iSdS(Ns(sreprsselfsloggers(sself((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__repr__scs1x$|iD]}|i|qWdS(N(sselfsloggerssloggerslogsmessage(sselfsmessageslogger((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyslogs (s__init__s__repr__slog(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys multi_loggers  sresolving_loggercs<dZdZdfdYZdZRS(sFeed (ip, message) combinations into this logger to get a resolved hostname in front of the message. The message will not be logged until the PTR request finishes (or fails).cs||_||_dS(N(sresolversselfslogger(sselfsresolverslogger((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__s s logger_thunkcsdZdZRS(Ncs||_||_dS(N(smessagesselfslogger(sselfsmessageslogger((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__s cs?| o |}n|iid||ifdS(Ns%s:%s(sanswershostsselfsloggerslogsmessage(sselfshoststtlsanswer((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__call__s  (s__init__s__call__(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys logger_thunks cs2|ii||i||idS(N(sselfsresolvers resolve_ptrsips logger_thunksmessageslogger(sselfsipsmessage((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyslogs (s__doc__s__init__s logger_thunkslog(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pysresolving_loggers   sunresolving_loggercs&dZdZdZRS(s&Just in case you don't want to resolvecs||_dS(N(sloggersself(sselfslogger((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__scs$|iid||fdS(Ns%s:%s(sselfsloggerslogsipsmessage(sselfsipsmessage((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyslogs(s__doc__s__init__slog(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pysunresolving_loggers  csAx-|o|ddjo|d }q W|SdS(Nis (sline(sline((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys strip_eolss tail_loggercs)dZddZdZRS(s*Keep track of the last log messagesics+||_||_g|_dS(N(ssizesselfsloggersmessages(sselfsloggerssize((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys__init__s  cs`|iit|t|i|ijo|id=n|ii|dS(Ni( sselfsmessagessappends strip_eolsmessageslenssizesloggerslog(sselfsmessage((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pyslogs(s__doc__s__init__slog(((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys tail_loggers (sasynchatssocketsstringstimesossstats file_loggersrotating_file_loggersm_syslogs syslog_clients syslog_loggers async_chats socket_loggers multi_loggersresolving_loggersunresolving_loggers strip_eols tail_logger(sstatsasynchatsrotating_file_loggerssockets tail_loggers syslog_loggerstimes strip_eolsm_syslogsunresolving_loggersresolving_loggers socket_loggers file_loggersoss multi_loggersstring((sE/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/logger.pys?s      3E