^ j+HddlmZddlZddlZddlmZmZddlZddlm Z ddl m Z m Z e dZ GddZGd d e ZGd d e ZGddZdS))dequeN)ABCMetaabstractmethod) AudioData) debug_printnext_or_equal_power_of_two debug_mediac*eZdZdZdZdZdZdZdS)SourcePrecisionBuffera7Wrap non-precise sources that may over- or undershoot. This class's purpose is to always return data whose length is equal or less than the requested size, where less hints at definite source exhaustion. This class erases AudioData-contained timestamp/duration information and events. cltj||_t|_d|_dSNF)weakrefproxy_source bytearray_buffer _exhaustedselfsources T/home/agentuser/manim-venv/lib/python3.11/site-packages/pyglet/media/drivers/base.py__init__zSourcePrecisionBuffer.__init__s)}V,,  {{ cd|jrdSt|j|kr|t|jz }tt d|dz}|||dz|dzf}d}d} |dzdkr|dz }|j||}|d|_n5|jdkr|dz}|dkrd|_nd}|xj|jz c_t|j|ks|jrn|jd|}|sdS|jd|=t|t|S) NirT) rlenrrmaxrget_audio_datalengthdatar)rrequested_sizerequired_bytes base_attemptattemptscur_attempt_idx empty_bailoutress rr"z$SourcePrecisionBuffer.get_audio_datasm ? 4 t|  ~ - -,c$,.?.??N6c$QS@S6T6TUUL$lL14DlUVFVWHOM "Q&**#q(Ol11(?2KLL;&*DOOZ1__!Q&M$))*.$%MLLCH,LLt|$$66$/6! $l?N?+ 4 L. )c#hh'''rc8tj||_dSN)rrrrs r set_sourcez SourcePrecisionBuffer.set_sourceJs}V,, rcF|jd|_dSr )rclearrrs rresetzSourcePrecisionBuffer.resetMs! rN)__name__ __module__ __qualname____doc__rr"r.r2rrr r s[   *(*(*(X---     rr cLeZdZdZdZdZdZdZdZdZ dZ d Z d Z e d Ze d Ze d Ze dZe dZe dZe dZdZdZdZdZdZdZdZdZdZd&dZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'dS)'AbstractAudioPlayerzBase class for driver audio players to be used by the high-level player. Relies on a thread to regularly call a `work` method in order for it to operate. rgQ?gQ?g~jt?g?ctj||_tj||_|rdnt ||_|j}td| |j |_ t|j dz|_ t|_| |j|_| |j|_| |j|_t|j|_d|_d|_dS)zCreate a new audio player. :Parameters: `source` : `Source` Source to play from. `player` : `Player` Player to receive EOS and video frame sync events. NigUUUUUU?)maxlenr)rrrplayer is_preciser _precision_buffer audio_formatr!timestamp_to_bytes_alignedaudio_buffer_length_buffered_data_ideal_sizeint _buffered_data_comfortable_limitr_eventsaudio_desync_time_criticaldesync_bytes_criticalaudio_desync_time_minordesync_bytes_minor"audio_minor_desync_correction_timedesync_correction_bytes_minor audio_sync_required_measurementsaudio_sync_measurementsaudio_sync_cumul_measurements_compensated_bytes)rrr<afmts rrzAbstractAudioPlayer.__init___s2mF++ mF++ )/):):)<)r r.rs rr.zAbstractAudioPlayer.set_sources {'6+>>>>> mF++      6%)D " " "  # +%:6%B%BD " " "  " - -f 5 5 5 5 5rcdS)zPrefill the audio buffer with audio data. This method is called before the audio player starts in order to have it play as soon as possible. Nr7r1s r prefill_audioz!AbstractAudioPlayer.prefill_audiorcdS)zRan regularly by the worker thread. This method should fill up the player's buffers if required, and dispatch any necessary events. Nr7r1s rworkzAbstractAudioPlayer.works  rcdS)zBegin playback.Nr7r1s rplayzAbstractAudioPlayer.playrYrcdS)zStop (pause) playback.Nr7r1s rstopzAbstractAudioPlayer.stoprYrc|jd|_|jd|_|j|jdSdS)zClear all buffered data and prepare for replacement data. The player must be stopped before calling this method. rN)rEr0rOrMrNr>r2r1s rr0zAbstractAudioPlayer.clearsi "# $**,,,-.*  ! -  " ( ( * * * * * . -rcdS)z7Stop playing and clean up all resources used by player.Nr7r1s rdeletezAbstractAudioPlayer.deleterYrcdS)zGet this player's most recent play cursor/read index/byte offset, starting from the last clear operation or initialization. ``0`` is an acceptable return value when unavailable or unknown. Nr7r1s rget_play_cursorz#AbstractAudioPlayer.get_play_cursorrYrcj|||jjzS)zRetrieve the time in the current source the player is at, in seconds. By default, calculated using :meth:`get_play_cursor`, divided by the bytes per second played. )_raw_play_cursor_to_timerdr<last_seek_timer1s rget_timezAbstractAudioPlayer.get_times. ,,T-A-A-C-CDDt{GaaarcX|dS|||jjjz Sr-)_to_perceived_play_cursorrr?bytes_per_second)rcursors rrfz,AbstractAudioPlayer._raw_play_cursor_to_times- >4--f55 8P8aaarc||jz Sr-)rO)r play_cursors rrjz-AbstractAudioPlayer._to_perceived_play_cursorsT444rc8|D]}|dS)z7Begin simultaneous playback on a list of audio players.N)r]r audio_playersr<s r _play_groupzAbstractAudioPlayer._play_group,$  F KKMMMM  rc8|D]}|dS)z6Stop simultaneous playback on a list of audio players.N)r_rps r _stop_groupzAbstractAudioPlayer._stop_grouprsrc|jjj}|jj}|D]S}|t d|j|z |zz}td|d|sJ|j ||fTdS)a8Append the given :class:`MediaEvent`s to the events deque using the current source's audio format and the supplied ``start_index`` to convert their timestamps to dispatch indices. The high level player's ``last_seek_time`` will be subtracted from each event's timestamp. z"AbstractAudioPlayer: Adding event z at N) rr?rkr<rgr! timestamp_debugrEappend)r start_indexeventsbpslstevent event_cursors r append_eventsz!AbstractAudioPlayer.append_eventssk&7k( 7 7E&#c5?S3H*I*IC*OPLXuXX,XXYY Y YY L  u 5 6 6 6 6 7 7rc"||}|jrn|jdd|kr[|jd|j|jr|jdd|kUdSdSdSdS)a%Dispatch all :class:`MediaEvent`s whose index is less than or equal to the specified ``until_cursor`` (which should be a very recent play cursor position). Please note that :attr:`_compensated_bytes` will be subtracted from the passed ``until_cursor``. rrN)rjrEpopleftsync_dispatch_to_playerr<)r until_cursors rdispatch_media_eventsz)AbstractAudioPlayer.dispatch_media_events s55lCC l Kt|Aq1\AA L " "1 % = =dk J J Jl Kt|Aq1\AAAA K K K KAArc|jj}||jj}||jjz }|jj||z }t||j kr$|j d|_ |dfSt|j|kr|xj |jdzc_ |j ||xj |z c_ t|j|krC|jj|j |z}t||jkr|dfSdS)aQuery the difference between the provided time and the high level `Player`'s master clock. The time difference returned is calculated as an average on previous audio time differences. Return a tuple of the bytes the player is off by, aligned to correspond to an integer number of audio frames, as well as bool designating whether the difference is extreme. If it is, it should be rectified immediately and all previous measurements will have been cleared. This method will return ``0, False`` if the difference is not significant or ``audio_time`` is ``None``. :rtype: int, bool NrTF)rF)rMr;r<timergrr?r@absrGr0rNr rzalignrI)r audio_timerequired_measurement_countp_time diff_bytesavg_diffs rget_audio_time_diffz'AbstractAudioPlayer.get_audio_time_diffsN"&*%A%H"  ![%F $+4 4J1LLZZ`M`aaJ:$"<<<,22444562!4''4/004NNN22d6RST6UU22  ( / / ; ; ;  . .* < . . t+ , ,0J J J{/5526PPRRH8}}t666&xrcx|j|j|S|j|Sr-)r>rr")rr%s r_get_audio_dataz#AbstractAudioPlayer._get_audio_dataMs8  ! );--n== =%44^DDDrNc>||}||\}}|dkr||Sd}|jj}t d|d|sJ||jzdksJ|dkrt||dz ||j }|||z }||j |jkrtdtj |j|j} t|j |z} | ||jzz| d|<|j| |d<t#| t%| |j}n|dkr|r| nt| |j }|||z}|\|j |kr |j }d}nFt#tj |j|z|j |z |j |z |j}|dz}t d|d sJ|xj|z c_|S) zE Retrieve a packet of `AudioData` of the given size. rzAudio desync, desync_bytes=z, extreme_desync=iNzPartial audio frame returned?z Compensated z after audio desync)rfrrrr?rybytes_per_framemin align_ceilrKr# RuntimeErrorctypes string_atpointerrr$rr r|rO) rr%audio_positionr desync_bytesextreme_desynccompensated_bytesrP audio_data first_frameads r_get_and_compensate_audio_dataz2AbstractAudioPlayer._get_and_compensate_audio_dataRs22>BB '+'?'? 'K'K$ n 1  ''77 7{'I|IIIIJJJJJd22a7777 !   !$!6!662!!  --n?P.PQQJ%$t';;;&'FGGG$.z/A4CWXX z03DDEE*59JdNb9b*c1&&')3$%%&&r3r77J4EFF A   %3"],&)<-9[&\&\ --n?P.PQQJ%$(999)3):(:%!%JJ!*(&.1BB&-0AA#),==") ""J&+%K%6KKKLLLLL #44rcdS)zSee `Player.volume`.Nr7)rvolumes r set_volumezAbstractAudioPlayer.set_volumerSrcdS)z-See :py:attr:`~pyglet.media.Player.position`.Nr7)rpositions r set_positionz AbstractAudioPlayer.set_positionrSrcdS)zSee `Player.min_distance`.Nr7)r min_distances rset_min_distancez$AbstractAudioPlayer.set_min_distancerSrcdS)zSee `Player.max_distance`.Nr7)r max_distances rset_max_distancez$AbstractAudioPlayer.set_max_distancerSrcdS)z*See :py:attr:`~pyglet.media.Player.pitch`.Nr7)rpitchs r set_pitchzAbstractAudioPlayer.set_pitchrSrcdS)zSee `Player.cone_orientation`.Nr7)rcone_orientations rset_cone_orientationz(AbstractAudioPlayer.set_cone_orientationrSrcdS)zSee `Player.cone_inner_angle`.Nr7)rcone_inner_angles rset_cone_inner_anglez(AbstractAudioPlayer.set_cone_inner_anglerSrcdS)zSee `Player.cone_outer_angle`.Nr7)rcone_outer_angles rset_cone_outer_anglez(AbstractAudioPlayer.set_cone_outer_anglerSrcdS)zSee `Player.cone_outer_gain`.Nr7)rcone_outer_gains rset_cone_outer_gainz'AbstractAudioPlayer.set_cone_outer_gainrSrr-)(r3r4r5r6rLrFrHrJrArrRrUr.rrXr[r]r_r0rbrdrhrfrjrrrurrrrrrrrrrrrrrr7rrr9r9Rso ()$!&#).&-$-$-$^      666"  ^   ^ ^%%^% + +^ +FF^F   ^ bbbbbb 555  7 7 7 K K K444lEEE CCCCJ                             rr9) metaclasscPeZdZedZedZedZdS)AbstractAudioDrivercdSr-r7)rrr<s rcreate_audio_playerz'AbstractAudioDriver.create_audio_playerrSrcdSr-r7r1s r get_listenerz AbstractAudioDriver.get_listenerrSrcdSr-r7r1s rrbzAbstractAudioDriver.deleterSrN)r3r4r5rrrrbr7rrrrsc  ^   ^   ^   rrc0eZdZdZdZd dZdZdZdZdS) MediaEventaRepresentation of a media event. These events are used internally by some audio driver implementation to communicate events to the :class:`~pyglet.media.player.Player`. One example is the ``on_eos`` event. Args: event (str): Event description. timestamp (float): The time when this event happens. *args: Any required positional argument to go along with this event. rrxargsrwc0||_||_||_dSr-r)rrrxrs rrzMediaEvent.__init__s " rcTtjjj||jg|jRdSr-)pygletappplatform_event_loop post_eventrr)rr<s rrz"MediaEvent.sync_dispatch_to_players, &1&$*QtyQQQQQQrc8d|jd|jd|jdS)Nz MediaEvent(z, )rr1s r__repr__zMediaEvent.__repr__s)ITZII4>IITYIIIIrcZt|tstS|j|jkSr-) isinstancerNotImplementedrx)rothers r__lt__zMediaEvent.__lt__s)%,, "! !~//rN)rw) r3r4r5r6 __slots__rrrrr7rrrrsl  -I RRRJJJ00000rr) collectionsrrrabcrrrpyglet.media.codecsr pyglet.utilrrryr r9rrr7rrrsP '''''''' ))))))???????? ] # #A A A A A A A A Hg g g g g Gg g g g T      G     0000000000r