BVh(dZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZGddZGd d ej ZGd d ZGd deZy)z"Writes events to disk in a logdir.N)_pywrap_events_writer)gfile) tf_logging)compatcLeZdZdZ d dZdZdZdZdZdZ d Z d Z d Z y) EventFileWritera<Writes `Event` protocol buffers to an event file. The `EventFileWriter` class creates an event file in the specified directory, and asynchronously writes Event protocol buffers to the file. The Event file is encoded using the tfrecord format, which is similar to RecordIO. This class is not thread-safe. Nc$t||_tj|j||_||_t j|_t|_ t|_ tjtjt j"j%|jd|_|r.|j&j)tj||j+d|_y)aCreates a `EventFileWriter` and an event file to write to. On construction the summary writer creates a new event file in `logdir`. This event file will contain `Event` protocol buffers, which are written to disk via the add_event method. The other arguments to the constructor control the asynchronous writes to the event file: * `flush_secs`: How often, in seconds, to flush the added summaries and events to disk. * `max_queue`: Maximum number of summaries or events pending to be written to disk before one of the 'add' calls block. Args: logdir: A string. Directory where event file will be written. max_queue: Integer. Size of the queue for pending events and summaries. flush_secs: Number. How often, in seconds, to flush the pending events and summaries to disk. filename_suffix: A string. Every event file's name is suffixed with `filename_suffix`. eventsFN)str_logdirrMakeDirs _max_queue _flush_secs threadingEvent_flush_completeobject_flush_sentinel_close_sentinelr EventsWriterras_bytesospathjoin _ev_writerInitWithSuffix _initialize_closed)selflogdir max_queue flush_secsfilename_suffixs b/home/dcms/DCMS/lib/python3.12/site-packages/tensorflow/python/summary/writer/event_file_writer.py__init__zEventFileWriter.__init__'s0v;DL NN4<< DO!D$??,D!8D!8D+88 T\\8<=?DO oo$$V___%EFDLct|j|_t|j|j|j |j |j|j|_ |jjy)zInitializes or re-initializes the queue and writer thread. The EventsWriter itself does not need to be re-initialized explicitly, because it will auto-initialize itself if used after being closed. N) CloseableQueuer _event_queue_EventLoggerThreadrrrrr_workerstartrs r$rzEventFileWriter._initializeMsd 't7D%d&7&7&*&6&68L8L&*&:&:&*&:&:
rs`)  :,<)FFR=))=@A"A"HLyLr&