diff options
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/pa-mock.c | 253 |
1 files changed, 235 insertions, 18 deletions
diff --git a/tests/pa-mock.c b/tests/pa-mock.c index 6f4e6ad..906e3de 100644 --- a/tests/pa-mock.c +++ b/tests/pa-mock.c @@ -7,15 +7,18 @@ #define G_LOG_DOMAIN "PA-Mock" G_DEFINE_QUARK("pa-mock-state-cb-list", state_cb); -typedef struct { - pa_context_notify_cb_t cb; - gpointer user_data; -} state_cb_t; +G_DEFINE_QUARK("pa-mock-subscribe-callback", subscribe_cb); +G_DEFINE_QUARK("pa-mock-subscribe-mask", subscribe_mask); /* ******************************* * context.h * *******************************/ +typedef struct { + pa_context_notify_cb_t cb; + gpointer user_data; +} state_cb_t; + static void context_weak_cb (gpointer user_data, GObject * oldobj) { @@ -223,22 +226,128 @@ pa_context_get_sink_info_list (pa_context *c, pa_sink_info_cb_t cb, void *userda return pa_context_get_sink_info_by_name(c, "default-sink", cb, userdata); } +typedef struct { + pa_sink_info_cb_t cb; + gpointer userdata; + pa_context * context; +} get_sink_input_info_t; + +static void +get_sink_info_free (gpointer data) +{ + get_sink_input_info_t * info = (get_sink_info_t *)data; + pa_context_unref(info->context); + g_free(info); +} + +static gboolean +get_sink_info_cb (gpointer data) +{ + pa_sink_input_info sink = { + .name = "default-sink" + }; + get_sink_input_info_t * info = (get_sink_input_info_t *)data; + + info->cb(info->context, &sink, info->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation * +pa_context_get_sink_input_info (pa_context *c, pa_sink_input_info_cb_t cb, void * userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), NULL); + g_return_val_if_fail(cb != NULL, NULL); + + get_sink_input_info_t * info = g_new(get_sink_input_info_t, 1); + info->cb = cb; + info->userdata = userdata; + info->context = g_objet_ref(c); + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + get_sink_input_info_cb, + info, + get_sink_input_info_free); + + GObject * goper = g_object_new(G_TYPE_OBJECT); + pa_operation * oper = (pa_operation *)goper; + return oper; +} -pa_context_get_sink_input_info +#if 0 pa_context_get_source_info_by_name pa_context_get_source_output_info -pa_context_get_state pa_context_set_sink_mute_by_index pa_context_set_sink_volume_by_index pa_context_set_source_volume_by_name -pa_context_set_subscribe_callback -pa_context_subscribe +#endif + +/* ******************************* + * subscribe.h + * *******************************/ + +typedef struct { + pa_context_subscribe_cb_t cb; + gointer userdata; + GObject * context; + pa_subscription_mask_t mask; +} subscribe_mask_t; + +static void +subscribe_mask_free (gpointer data) +{ + subscribe_mask_t * mask_data = (subscribe_mask_t *)data; + g_object_unref(mask_data->context); + g_free(mask_data); +} + +static gboolean +subscribe_mask_cb (gpointer data) +{ + subscribe_mask_t * mask_data = (subscribe_mask_t *)data; + g_object_set_qdata(mask_data->context, subscribe_mask_quark, GINT_TO_POINTER(mask_data->mask)); + mask_data->cb(mask_data->context, 1, mask_data->userdata); + return G_SOURCE_REMOVE; +} + +pa_operation * +pa_context_subscribe (pa_context * c, pa_subscription_mask_t mask, pa_context_success_cb_t callback, void * userdata) +{ + g_return_if_fail(G_IS_OBJECT(c)); + + subscribe_mask_t * data = g_new0(subscribe_mask_t, 1); + data->cb = callback; + data->userdata = userdata; + data->context = g_object_ref(G_OBJECT(c)); + data->mask = mask; -pa_cvolume_init -pa_cvolume_max -pa_cvolume_scale -pa_cvolume_set + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + subscribe_mask_cb, + data, + subscribe_mask_free); + + GObject * goper = g_object_new(G_TYPE_OBJECT); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_context_subscribe_cb_t cb; + gointer userdata; +} subscribe_cb_t; + +void +pa_context_set_subscribe_callback (pa_context * c, pa_context_subscribe_cb_t callback, void * userdata) +{ + g_return_if_fail(G_IS_OBJECT(c)); + + subscribe_cb_t * sub = g_new0(subscribe_cb_t, 1); + sub->cb = callback; + sub->userdata = userdata; + + g_object_set_qdata_full(c, subscribe_cb_quark, sub, g_free); +} /* ******************************* * glib-mainloop.h @@ -288,12 +397,120 @@ pa_operation_unref (pa_operation * operation) g_object_unref(G_OBJECT(operation)); } -pa_proplist_free -pa_proplist_gets -pa_proplist_new -pa_proplist_sets +/* ******************************* + * proplist.h + * *******************************/ + +pa_proplist * +pa_proplist_new (void) +{ + return (pa_proplist *)g_hash_table_new_full(g_str_hash, g_str_equal, g_free, g_free); +} + +void +pa_proplist_free (pa_proplist * p) +{ + g_return_if_fail(p != NULL); + g_hash_table_destroy((GHashTable *)p); +} + +const char * +pa_proplist_gets (pa_proplist * p, const char * key) +{ + g_return_val_if_fail(p != NULL, NULL); + g_return_val_if_fail(key != NULL, NULL); + return g_hash_table_lookup((GHashTable *)p, key); +} + +int +pa_proplist_sets (pa_proplist *p, const char * key, const char * value) +{ + g_return_val_if_fail(p != NULL, -1); + g_return_val_if_fail(key != NULL, -1); + g_return_val_if_fail(value != NULL, -1); -pa_strerror + g_hash_table_insert((GHashTable *)p, g_strdup(key), g_strdup(value)); + return 0; +} -pa_sw_volume_from_dB +/* ******************************* + * error.h + * *******************************/ + +const char * +pa_strerror (int error) +{ + return "This is error text"; +} + +/* ******************************* + * volume.h + * *******************************/ + +pa_volume_t +pa_sw_volume_from_dB (double f) +{ + double linear = pow(10.0, f / 20.0); + return (pa_volume_t) PA_CLAMP_VOLUME((uint64_t) lround(cbrt(linear) * PA_VOLUME_NORM)); +} + +pa_cvolume * +pa_cvolume_init (pa_cvolume * cvol) +{ + g_return_val_if_fail(cvol != NULL, NULL); + + cvol->channels = 0; + + unsigned int i; + for (i = 0; i < PA_CHANNELS_MAX; i++) + cvol->values[i] = PA_VOLUME_INVALID; + + return cvol; +} + +pa_cvolume * +pa_cvolume_set (pa_cvolume * cvol, unsigned channels, pa_volume_t volume) +{ + g_return_val_if_fail(cvol != NULL, NULL); + g_return_val_if_fail(channels > 0, NULL); + g_return_val_if_fail(channels <= PA_CHANNELS_MAX, NULL); + + cvol->channels = channels; + + unsigned int i; + for (i = 0; i < channels; i++) + cvol->values[i] = PA_CLAMP_VOLUME(volume); + + return cvol; +} + +pa_volume_t +pa_cvolume_max (const pa_cvolume * cvol) +{ + g_return_val_if_fail(cvol != NULL, NULL); + pa_volume_t max = PA_VOLUME_MUTED; + + unsigned int i; + for (i = 0; i < cvol->channels; i++) + max = MAX(max, cvol->values[i]); + + return max; +} + +pa_cvolume * +pa_cvolume_scale (pa_cvolume * cvol, pa_volume_t max) +{ + g_return_val_if_fail(cvol != NULL, NULL); + + pa_volume_t originalmax = pa_cvolume_max(cvol); + + if (originalmax <= PA_VOLUME_MUTED) + return pa_cvolume_set(cvol, cvol->channels, max); + + unsigned int i; + for (i = 0; i < channels; i++) + cvol->values[i] = PA_CLAMP_VOLUME( (cvol->values[i] * max) / originalmax ); + + return cvol; +} |