__init__.py 文件源码

def write(self, audio_data, length):
        # Pass audio_data=None to write silence
        if length == 0:
            return 0

        with self._lock:
            p1 = ctypes.c_void_p()
            l1 = lib.DWORD()
            p2 = ctypes.c_void_p()
            l2 = lib.DWORD()
            assert 0 < length <= self._buffer_size
            self._buffer.Lock(self._write_cursor_ring, length, 
                ctypes.byref(p1), l1, ctypes.byref(p2), l2, 0)
            assert length == l1.value + l2.value

            if audio_data:
                ctypes.memmove(p1, audio_data.data, l1.value)
                audio_data.consume(l1.value, self.source_group.audio_format)
                if l2.value:
                    ctypes.memmove(p2, audio_data.data, l2.value)
                    audio_data.consume(l2.value, self.source_group.audio_format)
            else:
                if self.source_group.audio_format.sample_size == 8:
                    c = 0x80
                else:
                    c = 0
                ctypes.memset(p1, c, l1.value)
                if l2.value:
                    ctypes.memset(p2, c, l2.value)
            self._buffer.Unlock(p1, l1, p2, l2)

            self._write_cursor += length
            self._write_cursor_ring += length
            self._write_cursor_ring %= self._buffer_size