DR_Team/Difficult-Rocket
DR_Team/Difficult-Rocket
6
2
Fork 0
Code Issues Pull Requests Projects Releases 25 Wiki Activity

sync pyglet

Browse Source
This commit is contained in:
shenjack 2023-10-13 01:10:49 +08:00
parent 5280febb20
commit 0208c1034b
Signed by: shenjack
GPG Key ID: 7B1134A979775551
1 changed files with 16 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
libs/pyglet/media/codecs/wmf.py
View File

@ -398,8 +398,6 @@ class WMFSource(Source):
def __init__(self, filename, file=None): def __init__(self, filename, file=None):
assert any([self.decode_audio, self.decode_video]), "Source must decode audio, video, or both, not none." assert any([self.decode_audio, self.decode_video]), "Source must decode audio, video, or both, not none."
self._current_audio_sample = None
self._current_audio_buffer = None
self._current_video_sample = None self._current_video_sample = None
self._current_video_buffer = None self._current_video_buffer = None
self._timestamp = 0 self._timestamp = 0
@ -615,20 +613,13 @@ class WMFSource(Source):
def get_audio_data(self, num_bytes, compensation_time=0.0): def get_audio_data(self, num_bytes, compensation_time=0.0):
flags = DWORD() flags = DWORD()
timestamp = ctypes.c_longlong() timestamp = ctypes.c_longlong()
audio_data_length = DWORD()
# If we have an audio sample already in use and we call this again, release the memory of buffer and sample. imf_sample = IMFSample()
# Can only release after the data is played or else glitches and pops can be heard. imf_buffer = IMFMediaBuffer()
if self._current_audio_sample:
self._current_audio_buffer.Release()
self._current_audio_sample.Release()
self._current_audio_sample = IMFSample()
self._current_audio_buffer = IMFMediaBuffer()
while True: while True:
self._source_reader.ReadSample(self._audio_stream_index, 0, None, ctypes.byref(flags), self._source_reader.ReadSample(self._audio_stream_index, 0, None, ctypes.byref(flags),
ctypes.byref(timestamp), ctypes.byref(self._current_audio_sample)) ctypes.byref(timestamp), ctypes.byref(imf_sample))
if flags.value & MF_SOURCE_READERF_CURRENTMEDIATYPECHANGED: if flags.value & MF_SOURCE_READERF_CURRENTMEDIATYPECHANGED:
assert _debug('WMFAudioDecoder: Data is no longer valid.') assert _debug('WMFAudioDecoder: Data is no longer valid.')
@ -638,20 +629,23 @@ class WMFSource(Source):
assert _debug('WMFAudioDecoder: End of data from stream source.') assert _debug('WMFAudioDecoder: End of data from stream source.')
break break
if not self._current_audio_sample: if not imf_sample:
assert _debug('WMFAudioDecoder: No sample.') assert _debug('WMFAudioDecoder: No sample.')
continue continue
# Convert to single buffer as a sample could potentially(rarely) have multiple buffers. # Convert to single buffer as a sample could potentially(rarely) have multiple buffers.
self._current_audio_sample.ConvertToContiguousBuffer(ctypes.byref(self._current_audio_buffer)) imf_sample.ConvertToContiguousBuffer(ctypes.byref(imf_buffer))
audio_data_ptr = POINTER(BYTE)() audio_data_ptr = POINTER(BYTE)()
audio_data_length = DWORD()
self._current_audio_buffer.Lock(ctypes.byref(audio_data_ptr), None, ctypes.byref(audio_data_length)) imf_buffer.Lock(ctypes.byref(audio_data_ptr), None, ctypes.byref(audio_data_length))
self._current_audio_buffer.Unlock()
audio_data = create_string_buffer(audio_data_length.value) audio_data = ctypes.string_at(audio_data_ptr, audio_data_length.value)
memmove(audio_data, audio_data_ptr, audio_data_length.value)
imf_buffer.Unlock()
imf_buffer.Release()
imf_sample.Release()
return AudioData(audio_data, return AudioData(audio_data,
audio_data_length.value, audio_data_length.value,
@ -688,6 +682,7 @@ class WMFSource(Source):
# changes if the stride is added/changed before playback? # changes if the stride is added/changed before playback?
stride = ctypes.c_uint32() stride = ctypes.c_uint32()
new.GetUINT32(MF_MT_DEFAULT_STRIDE, ctypes.byref(stride)) new.GetUINT32(MF_MT_DEFAULT_STRIDE, ctypes.byref(stride))
new.Release()
self._stride = stride.value self._stride = stride.value
@ -773,16 +768,15 @@ class WMFSource(Source):
assert _debug('WMFVideoDecoder: Setting configuration attributes.') assert _debug('WMFVideoDecoder: Setting configuration attributes.')
def __del__(self): def __del__(self):
if self._source_reader:
self._source_reader.Release()
if self._stream_obj: if self._stream_obj:
self._stream_obj.Release() self._stream_obj.Release()
if self._imf_bytestream: if self._imf_bytestream:
self._imf_bytestream.Release() self._imf_bytestream.Release()
if self._current_audio_sample:
self._current_audio_buffer.Release()
self._current_audio_sample.Release()
if self._current_video_sample: if self._current_video_sample:
self._current_video_buffer.Release() self._current_video_buffer.Release()
self._current_video_sample.Release() self._current_video_sample.Release()