^ j-*>dZddddggdgddddggdgdd dd ggd gdd dd ggddgddgdggdddddgdgdgddddggdgddddggdgdddggdgddgdgd d!gdd"dggd#gdd$ Zhd%ZGd&d'ZGd(d)Zd*Zd+ZGd,d-Zd.S)/a# Responsibilities Defines the events that modify media_player state Defines which events are potential defects Gives the low level support to extract info from the recorded data For new code here, keep accepting and returning only data structures, never paths or files. g?zmedia_player crashed.evnamesample)crash small.mp4)desc update_names other_fields test_casesPlay)mp.imrz Start playing wall_time)p.P._spGz?Seek seek_to_time)p.P.skr)rNzEnter update_texture)r pyglet_dt current_time audio_timer )) p.P.ut.1.0{Gz?{Gz@= ףp=@\(\?)rrNrr)rNrrrzDiscard video frame too old, video_timer) p.P.ut.1.5rzCurrent video frame,) p.P.ut.1.6rzCEarly return doing nothing because video_time is None (likely EOV),rescheduling_time) p.P.ut.1.7rzImage frame is None (?)) p.P.ut.1.8zRe-scheduling,)rrnext_video_time) p.P.ut.1.9rN)r"rg@z >>> play ends)p.P.oe) versionrr rrrrrrr r"r#>rrrr cVeZdZdZdddddddddddddd ZedfdZdZdZd Z d Z dS) MediaPlayerStateIteratoraExposes for analysis the sequence of media_player states Typical use mp_states = MediaPlayerStateIterator() for st in mp_states: do something with st, the current media_player state. If desired a callback can be called just before processing an event, the signature is fn_pre_event(event, state_before_event) The mp state is handled as a dict, with keys in cls.fields N) revnumrr rrrrrrr! pyglet_time frame_numc||_t|j|_||_t ||_t|j}|d|jdfksJdS)Nr$) fn_pre_eventdictfieldsstateevents_definitioniter iter_eventsnext)selfrecorded_eventsr1r- version_argss W/home/agentuser/manim-venv/lib/python3.11/site-packages/pyglet/media/instrumentation.py__init__z!MediaPlayerStateIterator.__init__sg($+&& !200D,--  4+A)+LMMMMMMMc|SN)r5s r8__iter__z!MediaPlayerStateIterator.__iter__s r:ct|j}|j|||j||}|||jSr<)r4r3r-r0 event_as_dictupdate)r5event event_dicts r8__next__z!MediaPlayerStateIterator.__next__s`T%&&   (   eTZ 0 0 0''..  Jzr:cl|j|dd}dt||D}|S)Nr(rci|]\}}|| Sr=r=).0abs r8 z:MediaPlayerStateIterator.event_as_dict..s666DAq1a666r:)r1zip)r5rBnamesupdateds r8r@z&MediaPlayerStateIterator.event_as_dicts:&uQx0@66Cu$5$5666r:c|j||jdxxdz cc<|d}|dkr|jdxx|dz cc<dS|dks|dkr|jd xxdz cc<dSdS) Nr)rrr*rrr"r+)r0rA)r5rCrs r8rAzMediaPlayerStateIterator.updates *%%% 7q H% \ ! ! J} % % %K)@ @ % % % % % | # #v'='= J{ # # #q ( # # # # #(>'=r:) __name__ __module__ __qualname____doc__r/ mp_eventsr9r>rDr@rAr=r:r8r&r&gs  !  F$;DRVNNNN )))))r:r&c(eZdZdZefdZdZdZdS)TimelineBuildera^At each call to player.Player.update_texture we capture selected player state, before accepting the changes in the event. This is the same as capturing the state at the end of previous update call. Output is a sequence of tuples capturing the desired fields. Meant to extract info on behalf of other sw, especially visualization. cNt|||j}||_g|_dSr<)r&premp_state_iteratortimeline)r5r6r1mps r8r9zTimelineBuilder.__init__s) %o7H$( S S!# r:c|ddkrH|d|d|d|d|d|df}|j|dSdS) Nr(rr r*rrr+r)rZappend)r5rBstps r8rXzTimelineBuilder.presh 8| # #K"]"3R 5EN#R _b9L6MOA M  # # # # # $ #r:c4|jD]}|jddS)z.remember video_time and audio_time can be NonerON)rYrZ)r5r^s r8 get_timelinezTimelineBuilder.get_timelines*(  B }QRR  r:N)rPrQrRrSrTr9rXrar=r:r8rVrVsV ;D $$$ !!!!!r:rVc g}g}d}d}g}|D]`\}}}} } } | |} |||fn| } ||}|||fn|}||||| | | fa|||fS)z Eliminates Nones in timeline so other software don't error. Extra lists are built for the vars with nones, each list with one point for each None in the form (wall_time, prev_value). r()r]) rZcurrent_time_nonesaudio_time_nonesold_current_timeold_audio_timefiltered_timeliner ptrrfnumrtcurrent_time_times r8timeline_postprocessingrls N=E V V9 2z<r  +L  % %y2B&C D D D D ,   'J  # #Y$? @ @ @ @'N  )R\4QS!TUUUU 02B BBr:c*|dddk}|S)Nr'r(r#r=)r6crasheds r8crash_detectedrosb!!$0G Nr:c0eZdZdZeefdZdZdZdZ dS) CountBadsarHelper to report anomalies in the media_player states seen when playing a sample. - provides .anomalies_description, a dict : - calling .count_bads(recorded_events) will return a dict of anomaly: - preprocessing: ad-hoc prefiltering the events stream for noise reduction cT||_||_||_dSr<)r1badsbuild_anomalies_descriptionanomalies_description)r5r1rss r8r9zCountBads.__init__s+!2 %)%E%E%G%G"""r:cF|jfd|jD}d|d<|S)z%builds descriptions for the anomaliesc.i|]}||dS)rr=)rGrds r8rJz9CountBads.build_anomalies_description..s$ S S Sv66): S S Sr:zScheduling in the pastscheduling_in_past)r1rs)r5rurxs @r8rtz%CountBads.build_anomalies_descriptions9  " S S S S S S S6N23$$r:ct|}t|dkr@|dddkr.|dddkr|dddkr |d=|d=|d=nft|dkr+|dddkr|dddkr|d=|d=n(t|dkr|dddkr|d=|S) a9 I see all recordings ending with some potential anomalies in the few frames just before the '>>> play ends'; visually the play is perfect so I assume they are false positives if just at EOF. Deleting the offending events (only if near EOL) to reduce noise in summarize.py r(rii)listlen)r5r6s r8 preprocessingzCountBads.preprocessings//  1 $ $#A&,66#A&,66$Q'<77$###/""Q&&b!!$ 44b!!$ 44###  ! !A % %/"*=a*@L*P*P#r:c||}d|jD}d}t||j}|D]9}|d}||vr||xxdz cc< |d|ddkr|dz }:||d<|S) zreturns counts of anomalies as a dict of anomaly: count recorded_events: media_player events recorded while playing a sample Notice that 'counters' has one more key than 'bads': "scheduling_in_past" ci|]}|dS)r(r=)rGks r8rJz(CountBads.count_bads..s,,,QAq,,,r:r(rrOr"rNry)rrsr&r1)r5r6counterscnt_scheduling_in_past mp_statesr^rs r8 count_badszCountBads.count_badss,,_==,,$),,,!",_d>TUU  , ,B\F!!   A%     ,()5()A--&!+&)?%&r:N) rPrQrRrSrTmp_badsr9rtrrr=r:r8rqrqsj  *3HHHH %%%6r:rqN)rSrTrr&rVrlrorqr=r:r8rsT(!8,-.   !8,01    !;/()   !>2')9:   '444???   /!<0'(+,   '!<0+,   V!#67+,   *! &'   !JJJ13LM    ! "m   _U U  p > = =?)?)?)?)?)?)?)?)D!!!!!!!!6CCC: DDDDDDDDDDr: