hSrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r J r "SS5r "SS 5r "S S \R5rg) z"Writes events to disk in a logdir.N) event_pb2) RecordWriterdirectory_checkc:\rSrSrSrS SjrSrSrSrSr Sr g ) EventsWriterz1Writes `Event` protocol buffers to an event file.cUS-[[R"55SS-S-[R"5-U-UlSUl[ UR5Ul[R"5Ul [R"5URl SURl [R"5UlUR!UR5 g)zc Events files have a name of the form '/some/file/path/events.out.tfevents.[timestamp].[hostname]' z.out.tfevents.N .rz brain.Event:2)strtimesocket gethostname _file_name_num_outstanding_eventsr_py_recordio_writerrEvent_event wall_time file_version threadingLock_lock write_event)self file_prefixfilename_suffixs X/var/www/fran/franai/venv/lib/python3.13/site-packages/tensorboardX/event_file_writer.py__init__EventsWriter.__init__ s &(883tyy{;KCR;PPSVV    !#23'($#/#@ oo' $  #2  ^^%  %c[U[R5(d[S[ U535eUR UR 55$)zAppend "event" to the file.z,Expected an event_pb2.Event proto, but got ) isinstancerr TypeErrortype_write_serialized_eventSerializeToStringrevents rrEventsWriter.write_event0sO%11((,U }67 7++E,C,C,EFFr"cUR U=RS- slURRU5 SSS5 g!,(df  g=f)Nr)rrrwrite)r event_strs rr'$EventsWriter._write_serialized_event9s8 ZZ  ( (A - (  $ $ * *9 5ZZs 1A AcUR SUlURR5 SSS5 g!,(df  g=f)zFlushes the event file to disk.rNT)rrrflushrs rr1EventsWriter.flush>s: ZZ+,D (  $ $ * * ,Zs "8 AcUR5nUR URR5 SSS5 U$!,(df  U$=f)zCall self.flush().N)r1rrclose)r return_values rr5EventsWriter.closeEs?zz| ZZ  $ $ * * ,Zs A A)rrrrrN)) __name__ __module__ __qualname____firstlineno____doc__r rr'r1r5__static_attributes__r"rrrs;& G6 r"rc@\rSrSrSrS SjrSrSrSrSr Sr S r g ) EventFileWriterMaWrites `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. c|Xl[UR5 [R"U5Ul[ [ RRURS5U5Ul X0l SUl [URURU5Ul URR5 g)aDCreates 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: Args: logdir: A string. Directory where event file will be written. max_queue_size: 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. eventsFN)_logdirrmultiprocessingQueue _event_queuerospathjoin _ev_writer _flush_secs_closed_EventLoggerThread_workerstart)rlogdirmax_queue_size flush_secsrs rr EventFileWriter.__init__Us  %+11.A&rww|| LL(($%46% )$*;*;T__*46  r"cUR$)z7Returns the directory where event file will be written.)rEr2s r get_logdirEventFileWriter.get_logdirps ||r"cUR(aRSUl[URURUR5UlUR R 5 gg)zReopens the EventFileWriter. Can be called after `close()` to add more events in the same directory. The events will go into a new events file and a new write/flush worker is created. Does nothing if the EventFileWriter was not closed. FN)rNrOrHrLrMrPrQr2s rreopenEventFileWriter.reopentsL << DL-!!4??D4D4DDL LL   r"c^UR(dURRU5 gg)zMAdds an event to the event file. Args: event: An `Event` protocol buffer. N)rNrHputr)s r add_eventEventFileWriter.add_events$ ||    ! !% (r"c\UR(dURR5 gg)zrFlushes the event file to disk. Call this method to make sure that all pending events have been written to disk. N)rNrLr1r2s rr1EventFileWriter.flushs || OO ! ! #r"cUR(dtUR5 URR5 URR 5 UR R 5 SUlSUlSUlgg)zPerforms a final flush of the event file to disk, stops the write/flush worker and closes the file. Call this method when you do not need the summary writer anymore. NT)rNr1rPstoprLr5rHr2s rr5EventFileWriter.closesa || JJL LL    OO ! ! #    # # % $D DLDLr")rNrLrHrMrErPN)r xr8) r9r:r;r<r=r rWrZr^r1r5r>r?r"rrArAMs%6 !)$  r"rAc*\rSrSrSrSrSrSrSrg)rOzThread that logs events.c[RRU5 SUlXlX lX0lSUlSUl[5Ul g)zCreates an _EventLoggerThread. Args: queue: A Queue from which to dequeue data. record_writer: An data writer. Used to log brain events for the visualizer. flush_secs: How often, in seconds, to flush the pending file to disk. TrFN) rThreadr daemon_queue_record_writerrM_next_flush_time_has_pending_dataobject_shutdown_signal)rqueue record_writerrTs rr _EventLoggerThread.__init__sJ !!$'  +% !!& &r"cnURRUR5 UR5 g)N)rkr]rprKr2s rrc_EventLoggerThread.stops! --. r"cd[R"5nURU- nSnUS:aURRSU5nOURRS5n[ U5[ UR 5:XagUR RU5 SUl[R"5nXR:aEUR(a!UR R5 SUlXR-UlGM![Ra Nf=f)NTrF) rrmrkgetr&rprlrrnrqEmptyr1rM)rnowqueue_wait_durationdatas rrun_EventLoggerThread.runs ))+C"&"7"7#"= D &*;;??41DED;;??51D:d&;&;!<<##//5)-&))+C***))''--/-2D*(+.>.>(>%5;;  sA D "DD/.D/)rMrnrmrkrlrprjN) r9r:r;r<r=r rcr|r>r?r"rrOrOs")&?r"rO)r=rFrIrqrrrprotorrrrrrrArirOr?r"rrsN)  8--`R R j9?))9?r"