audio: pipewire: Code and comment cleanups

Replace "magic numbers" with #defines, explain the requirements when using the userdata pointer in the node_object struct and a few other minor code and comment cleanups.
This commit is contained in:
Frank Praznik 2021-02-27 12:08:15 -05:00 committed by Sam Lantinga
parent 4eadd147cd
commit 2fcba50ec9
1 changed files with 16 additions and 7 deletions

View File

@ -38,6 +38,9 @@
#define PW_MIN_SAMPLES 32 /* About 0.67ms at 48kHz */ #define PW_MIN_SAMPLES 32 /* About 0.67ms at 48kHz */
#define PW_MAX_SAMPLES 8192 /* About 170.6ms at 48kHz */ #define PW_MAX_SAMPLES 8192 /* About 170.6ms at 48kHz */
#define PW_POD_BUFFER_LENGTH 1024
#define PW_THREAD_NAME_BUFFER_LENGTH 128
#define PW_ID_TO_HANDLE(x) (void *)((uintptr_t)x) #define PW_ID_TO_HANDLE(x) (void *)((uintptr_t)x)
#define PW_HANDLE_TO_ID(x) (uint32_t)((uintptr_t)x) #define PW_HANDLE_TO_ID(x) (uint32_t)((uintptr_t)x)
@ -195,6 +198,14 @@ struct node_object
Uint32 id; Uint32 id;
int seq; int seq;
/*
* NOTE: If used, this is *must* be allocated with SDL_malloc() or similar
* as SDL_free() will be called on it when the node_object is destroyed.
*
* If ownership of the referenced memory is transferred, this must be set
* to NULL or the memory will be freed when the node_object is destroyed.
*/
void *userdata; void *userdata;
struct pw_proxy *proxy; struct pw_proxy *proxy;
@ -986,15 +997,15 @@ PIPEWIRE_OpenDevice(_THIS, void *handle, const char *devname, int iscapture)
{ {
/* /*
* NOTE: The PW_STREAM_FLAG_RT_PROCESS flag can be set to call the stream * NOTE: The PW_STREAM_FLAG_RT_PROCESS flag can be set to call the stream
* processing callback from the realtime thread, however it comes with some * processing callback from the realtime thread. However, it comes with some
* caveats: no file IO, allocations, locking or other blocking operations * caveats: no file IO, allocations, locking or other blocking operations
* must occur in the mixer callback. As this cannot be guaranteed when the * must occur in the mixer callback. As this cannot be guaranteed when the
* callback is in the calling application, this flag is omitted. * callback is in the calling application, this flag is omitted.
*/ */
static const enum pw_stream_flags STREAM_FLAGS = PW_STREAM_FLAG_AUTOCONNECT | PW_STREAM_FLAG_MAP_BUFFERS; static const enum pw_stream_flags STREAM_FLAGS = PW_STREAM_FLAG_AUTOCONNECT | PW_STREAM_FLAG_MAP_BUFFERS;
char thread_name[128]; char thread_name[PW_THREAD_NAME_BUFFER_LENGTH];
Uint8 pod_buffer[1024]; Uint8 pod_buffer[PW_POD_BUFFER_LENGTH];
struct spa_pod_builder b = SPA_POD_BUILDER_INIT(pod_buffer, sizeof(pod_buffer)); struct spa_pod_builder b = SPA_POD_BUILDER_INIT(pod_buffer, sizeof(pod_buffer));
struct spa_audio_info_raw spa_info = { 0 }; struct spa_audio_info_raw spa_info = { 0 };
const struct spa_pod * params = NULL; const struct spa_pod * params = NULL;
@ -1032,12 +1043,10 @@ PIPEWIRE_OpenDevice(_THIS, void *handle, const char *devname, int iscapture)
min_period = PW_MIN_SAMPLES * SPA_MAX(this->spec.freq / 48000, 1); min_period = PW_MIN_SAMPLES * SPA_MAX(this->spec.freq / 48000, 1);
adjusted_samples = SPA_CLAMP(this->spec.samples, min_period, PW_MAX_SAMPLES); adjusted_samples = SPA_CLAMP(this->spec.samples, min_period, PW_MAX_SAMPLES);
if ((priv = SDL_calloc(1, sizeof(struct SDL_PrivateAudioData))) == NULL) { if ((this->hidden = priv = SDL_calloc(1, sizeof(struct SDL_PrivateAudioData))) == NULL) {
return SDL_OutOfMemory(); return SDL_OutOfMemory();
} }
this->hidden = priv;
/* Size of a single audio frame in bytes */ /* Size of a single audio frame in bytes */
priv->stride = (SDL_AUDIO_BITSIZE(this->spec.format) >> 3) * this->spec.channels; priv->stride = (SDL_AUDIO_BITSIZE(this->spec.format) >> 3) * this->spec.channels;