From ed54228025cc86f6affca2eafe61d83d234351d4 Mon Sep 17 00:00:00 2001 From: Ted Gould Date: Wed, 28 Jan 2015 09:41:22 -0600 Subject: Create a base object and move the state stuff over to it --- tests/CMakeLists.txt | 2 +- tests/pa-mock.c | 841 -------------------------------------------------- tests/pa-mock.cpp | 857 +++++++++++++++++++++++++++++++++++++++++++++++++++ 3 files changed, 858 insertions(+), 842 deletions(-) delete mode 100644 tests/pa-mock.c create mode 100644 tests/pa-mock.cpp (limited to 'tests') diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt index a9ec204..fb93aca 100644 --- a/tests/CMakeLists.txt +++ b/tests/CMakeLists.txt @@ -89,7 +89,7 @@ include_directories(${CMAKE_CURRENT_BINARY_DIR}) add_library( pulse-mock SHARED - pa-mock.c + pa-mock.cpp ) ########################### diff --git a/tests/pa-mock.c b/tests/pa-mock.c deleted file mode 100644 index bc4fb95..0000000 --- a/tests/pa-mock.c +++ /dev/null @@ -1,841 +0,0 @@ - -#include -#include -#include -#include - -#ifdef G_LOG_DOMAIN -#undef G_LOG_DOMAIN -#endif -#define G_LOG_DOMAIN "PA-Mock" - -G_DEFINE_QUARK("pa-mock-state-cb-list", state_cb); -G_DEFINE_QUARK("pa-mock-subscribe-callback", subscribe_cb); -G_DEFINE_QUARK("pa-mock-subscribe-mask", subscribe_mask); -G_DEFINE_QUARK("pa-mock-current-state", state); -G_DEFINE_QUARK("pa-mock-future-state", state_future); - -/* ******************************* - * Prototypes - * *******************************/ - -static void set_state (pa_context * c, pa_context_state_t state); -static void queue_state (pa_context * context, pa_context_state_t state); - -/* ******************************* - * context.h - * *******************************/ - -typedef struct { - pa_context_notify_cb_t cb; - gpointer userdata; -} state_cb_t; - -static void -context_weak_cb (gpointer user_data, GObject * oldobj) -{ - g_debug("Finalizing context: %p", oldobj); -} - -pa_context * -pa_context_new_with_proplist (pa_mainloop_api *mainloop, const char *name, pa_proplist *proplist) -{ - GObject * gctx = g_object_new(G_TYPE_OBJECT, NULL); - pa_context * ctx = (pa_context *)gctx; - - g_debug("Creating new context: %p", ctx); - g_object_weak_ref(gctx, context_weak_cb, NULL); - - set_state(ctx, PA_CONTEXT_UNCONNECTED); - - return ctx; -} - -void -pa_context_unref (pa_context *c) { - g_return_if_fail(G_IS_OBJECT(c)); - g_object_unref(G_OBJECT(c)); -} - -pa_context * -pa_context_ref (pa_context *c) { - g_return_if_fail(G_IS_OBJECT(c)); - g_object_ref(G_OBJECT(c)); - return c; -} - -int -pa_context_connect (pa_context *c, const char *server, pa_context_flags_t flags, const pa_spawn_api *api) -{ - g_return_if_fail(G_IS_OBJECT(c)); - g_debug("Context Connect"); - queue_state(c, PA_CONTEXT_READY); - return 0; -} - -void -pa_context_disconnect (pa_context *c) -{ - g_return_if_fail(G_IS_OBJECT(c)); - g_debug("Context Disconnect"); - queue_state(c, PA_CONTEXT_UNCONNECTED); -} - -int -pa_context_errno (pa_context *c) -{ - g_return_val_if_fail(G_IS_OBJECT(c), -1); - - return 0; -} - -static void -set_state_cb (gpointer pcbdata, gpointer pcontext) -{ - pa_context * context = (pa_context *)pcontext; - state_cb_t * cbdata = (state_cb_t *)pcbdata; - - cbdata->cb(context, cbdata->userdata); -} - -static void -set_state (pa_context * c, pa_context_state_t state) -{ - pa_context_state_t oldstate = pa_context_get_state(c); - if (oldstate == state) - return; - - g_object_set_qdata(G_OBJECT(c), state_quark(), GINT_TO_POINTER(state)); - GList * statelist = g_object_get_qdata(G_OBJECT(c), state_cb_quark()); - g_list_foreach(statelist, set_state_cb, c); -} - -static gboolean -queue_state_cb (gpointer pcontext) -{ - pa_context * context = (pa_context *)pcontext; - pa_context_state_t state = GPOINTER_TO_INT(g_object_get_qdata(G_OBJECT(context), state_future_quark())); - - set_state(context, state); - - return G_SOURCE_REMOVE; -} - -static void -queue_state (pa_context * context, pa_context_state_t state) -{ - g_object_set_qdata(G_OBJECT(context), state_future_quark(), GINT_TO_POINTER(state)); - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - queue_state_cb, - g_object_ref(context), - g_object_unref); -} - -static void -state_cb_list_destroy (gpointer data) -{ - GList * statelist = (GList *)data; - g_list_free_full(statelist, g_free); -} - -void -pa_context_set_state_callback (pa_context *c, pa_context_notify_cb_t cb, void *userdata) -{ - g_return_if_fail(G_IS_OBJECT(c)); - g_return_if_fail(cb != NULL); - - state_cb_t * state_cb = g_new0(state_cb_t, 1); - state_cb->cb = cb; - state_cb->userdata = userdata; - - GList * statelist = g_object_get_qdata(G_OBJECT(c), state_cb_quark()); - statelist = g_list_append(statelist, state_cb); - g_object_set_qdata_full(G_OBJECT(c), state_cb_quark(), statelist, state_cb_list_destroy); -} - -pa_context_state_t -pa_context_get_state (pa_context *c) -{ - g_return_if_fail(G_IS_OBJECT(c)); - - return GPOINTER_TO_INT(g_object_get_qdata(G_OBJECT(c), state_quark())); -} - -/* ******************************* - * introspect.h - * *******************************/ - -typedef struct { - pa_server_info_cb_t cb; - gpointer userdata; - pa_context * context; -} get_server_info_t; - -static void -get_server_info_free (gpointer data) -{ - get_server_info_t * info = (get_server_info_t *)data; - g_object_unref(info->context); - g_free(info); -} - -static gboolean -get_server_info_cb (gpointer data) -{ - pa_server_info server = { - .user_name = "user", - .host_name = "host", - .server_version = "1.2.3", - .server_name = "server", - .default_sink_name = "default-sink", - .default_source_name = "default-source", - .cookie = 1234, - .channel_map = { - .channels = 0 - } - }; - get_server_info_t * info = (get_server_info_t *)data; - - info->cb(info->context, &server, info->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation* -pa_context_get_server_info (pa_context *c, pa_server_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_server_info_t * info = g_new(get_server_info_t, 1); - info->cb = cb; - info->userdata = userdata; - info->context = g_object_ref(c); - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - get_server_info_cb, - info, - get_server_info_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -typedef struct { - pa_sink_info_cb_t cb; - gpointer userdata; - pa_context * context; - uint32_t index; -} get_sink_info_t; - -static void -get_sink_info_free (gpointer data) -{ - get_sink_info_t * info = (get_sink_info_t *)data; - g_object_unref(info->context); - g_free(info); -} - -static gboolean -get_sink_info_cb (gpointer data) -{ - pa_sink_port_info active_port = { - .name = "speaker" - }; - pa_sink_info sink = { - .name = "default-sink", - .index = 0, - .description = "Default Sink", - .channel_map = { - .channels = 0 - }, - .active_port = &active_port - }; - get_sink_info_t * info = (get_sink_info_t *)data; - - info->cb(info->context, &sink, 1, info->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation* -pa_context_get_sink_info_by_name (pa_context *c, const gchar * name, pa_sink_info_cb_t cb, void *userdata) -{ - g_return_val_if_fail(G_IS_OBJECT(c), NULL); - g_return_val_if_fail(g_strcmp0(name, "default-sink") == 0, NULL); - g_return_val_if_fail(cb != NULL, NULL); - - get_sink_info_t * info = g_new(get_sink_info_t, 1); - info->cb = cb; - info->userdata = userdata; - info->context = g_object_ref(c); - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - get_sink_info_cb, - info, - get_sink_info_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -pa_operation* -pa_context_get_sink_info_list (pa_context *c, pa_sink_info_cb_t cb, void *userdata) -{ - /* Only have one today, so this is the same */ - return pa_context_get_sink_info_by_name(c, "default-sink", cb, userdata); -} - -typedef struct { - pa_sink_input_info_cb_t cb; - gpointer userdata; - pa_context * context; -} get_sink_input_info_t; - -static void -get_sink_input_info_free (gpointer data) -{ - get_sink_input_info_t * info = (get_sink_input_info_t *)data; - pa_context_unref(info->context); - g_free(info); -} - -static gboolean -get_sink_input_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, 0, info->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation * -pa_context_get_sink_input_info (pa_context *c, uint32_t idx, 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_object_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, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -typedef struct { - pa_source_info_cb_t cb; - gpointer userdata; - pa_context * context; -} get_source_info_t; - -static void -get_source_info_free (gpointer data) -{ - get_source_info_t * info = (get_source_info_t *)data; - g_object_unref(info->context); - g_free(info); -} - -static gboolean -get_source_info_cb (gpointer data) -{ - pa_source_info source = { - .name = "default-source" - }; - get_source_info_t * info = (get_source_info_t *)data; - - info->cb(info->context, &source, 0, info->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation* -pa_context_get_source_info_by_name (pa_context *c, const char * name, pa_source_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_source_info_t * info = g_new(get_source_info_t, 1); - info->cb = cb; - info->userdata = userdata; - info->context = g_object_ref(c); - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - get_source_info_cb, - info, - get_source_info_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -typedef struct { - pa_source_output_info_cb_t cb; - gpointer userdata; - pa_context * context; -} get_source_output_t; - -static void -get_source_output_free (gpointer data) -{ - get_source_output_t * info = (get_source_output_t *)data; - g_object_unref(info->context); - g_free(info); -} - -static gboolean -get_source_output_cb (gpointer data) -{ - pa_source_output_info source = { - .name = "default-source" - }; - get_source_output_t * info = (get_source_output_t *)data; - - info->cb(info->context, &source, 0, info->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation* -pa_context_get_source_output_info (pa_context *c, uint32_t idx, pa_source_output_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_source_output_t * info = g_new(get_source_output_t, 1); - info->cb = cb; - info->userdata = userdata; - info->context = g_object_ref(c); - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - get_source_output_cb, - info, - get_source_output_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -typedef struct { - pa_context_success_cb_t cb; - gpointer userdata; - pa_context * context; - int mute; -} set_sink_mute_t; - -static void -set_sink_mute_free (gpointer data) -{ - set_sink_mute_t * mute = (set_sink_mute_t *)data; - g_object_unref(mute->context); - g_free(mute); -} - -static gboolean -set_sink_mute_cb (gpointer data) -{ - set_sink_mute_t * mute = (set_sink_mute_t *)data; - - if (mute->cb != NULL) - mute->cb(mute->context, 1, mute->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation* -pa_context_set_sink_mute_by_index (pa_context *c, uint32_t idx, int mute, pa_context_success_cb_t cb, void *userdata) -{ - g_return_val_if_fail(G_IS_OBJECT(c), NULL); - - set_sink_mute_t * data = g_new(set_sink_mute_t, 1); - data->cb = cb; - data->userdata = userdata; - data->context = g_object_ref(c); - data->mute = mute; - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - set_sink_mute_cb, - data, - set_sink_mute_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -typedef struct { - pa_context_success_cb_t cb; - gpointer userdata; - pa_context * context; - pa_cvolume cvol; -} set_sink_volume_t; - -static void -set_sink_volume_free (gpointer data) -{ - set_sink_volume_t * vol = (set_sink_volume_t *)data; - g_object_unref(vol->context); - g_free(vol); -} - -static gboolean -set_sink_volume_cb (gpointer data) -{ - set_sink_volume_t * vol = (set_sink_volume_t *)data; - - vol->cb(vol->context, 1, vol->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation* -pa_context_set_sink_volume_by_index (pa_context *c, uint32_t idx, const pa_cvolume * cvol, pa_context_success_cb_t cb, void *userdata) -{ - g_return_val_if_fail(G_IS_OBJECT(c), NULL); - g_return_val_if_fail(cb != NULL, NULL); - - set_sink_volume_t * data = g_new(set_sink_volume_t, 1); - data->cb = cb; - data->userdata = userdata; - data->context = g_object_ref(c); - data->cvol.channels = cvol->channels; - - int i; - for (i = 0; i < cvol->channels; i++) - data->cvol.values[i] = cvol->values[i]; - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - set_sink_volume_cb, - data, - set_sink_volume_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -typedef struct { - pa_context_success_cb_t cb; - gpointer userdata; - pa_context * context; - pa_cvolume cvol; -} set_source_volume_t; - -static void -set_source_volume_free (gpointer data) -{ - set_source_volume_t * vol = (set_source_volume_t *)data; - g_object_unref(vol->context); - g_free(vol); -} - -static gboolean -set_source_volume_cb (gpointer data) -{ - set_source_volume_t * vol = (set_source_volume_t *)data; - - vol->cb(vol->context, 1, vol->userdata); - - return G_SOURCE_REMOVE; -} - -pa_operation* -pa_context_set_source_volume_by_name (pa_context *c, const char * name, const pa_cvolume * cvol, pa_context_success_cb_t cb, void *userdata) -{ - g_return_val_if_fail(G_IS_OBJECT(c), NULL); - g_return_val_if_fail(cb != NULL, NULL); - - set_source_volume_t * data = g_new(set_source_volume_t, 1); - data->cb = cb; - data->userdata = userdata; - data->context = g_object_ref(c); - data->cvol.channels = cvol->channels; - - int i; - for (i = 0; i < cvol->channels; i++) - data->cvol.values[i] = cvol->values[i]; - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - set_source_volume_cb, - data, - set_source_volume_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -/* ******************************* - * subscribe.h - * *******************************/ - -typedef struct { - pa_context_success_cb_t cb; - gpointer userdata; - pa_context * 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(G_OBJECT(mask_data->context), subscribe_mask_quark(), GINT_TO_POINTER(mask_data->mask)); - if (mask_data->cb != NULL) - 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; - - g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, - subscribe_mask_cb, - data, - subscribe_mask_free); - - GObject * goper = g_object_new(G_TYPE_OBJECT, NULL); - pa_operation * oper = (pa_operation *)goper; - return oper; -} - -typedef struct { - pa_context_subscribe_cb_t cb; - gpointer 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(G_OBJECT(c), subscribe_cb_quark(), sub, g_free); -} - -/* ******************************* - * glib-mainloop.h - * *******************************/ - -struct pa_glib_mainloop { - GMainContext * context; -}; - -struct pa_mainloop_api mock_mainloop = { 0 }; - -pa_mainloop_api * -pa_glib_mainloop_get_api (pa_glib_mainloop * g) -{ - return &mock_mainloop; -} - -pa_glib_mainloop * -pa_glib_mainloop_new (GMainContext * c) -{ - pa_glib_mainloop * loop = g_new0(pa_glib_mainloop, 1); - - if (c == NULL) - loop->context = g_main_context_default(); - else - loop->context = c; - - g_main_context_ref(loop->context); - return loop; -} - -void -pa_glib_mainloop_free (pa_glib_mainloop * g) -{ - g_main_context_unref(g->context); - g_free(g); -} - -/* ******************************* - * operation.h - * *******************************/ - -void -pa_operation_unref (pa_operation * operation) -{ - g_return_if_fail(G_IS_OBJECT(operation)); - g_object_unref(G_OBJECT(operation)); -} - -/* ******************************* - * 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); - - g_hash_table_insert((GHashTable *)p, g_strdup(key), g_strdup(value)); - return 0; -} - -/* ******************************* - * 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); - - pa_volume_t calculated = lround(cbrt(linear) * PA_VOLUME_NORM); - - if (G_UNLIKELY(calculated > PA_VOLUME_MAX)) { - return PA_VOLUME_MAX; - } else if (G_UNLIKELY(calculated < PA_VOLUME_MUTED)) { - return PA_VOLUME_MUTED; - } else { - return calculated; - } -} - -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_warn_if_fail(channels > 0); - g_return_val_if_fail(channels <= PA_CHANNELS_MAX, NULL); - - cvol->channels = channels; - - unsigned int i; - for (i = 0; i < channels; i++) { - if (G_UNLIKELY(volume > PA_VOLUME_MAX)) { - cvol->values[i] = PA_VOLUME_MAX; - } else if (G_UNLIKELY(volume < PA_VOLUME_MUTED)) { - cvol->values[i] = PA_VOLUME_MUTED; - } else { - cvol->values[i] = 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 < cvol->channels; i++) { - pa_volume_t calculated = (cvol->values[i] * max) / originalmax; - - if (G_UNLIKELY(calculated > PA_VOLUME_MAX)) { - cvol->values[i] = PA_VOLUME_MAX; - } else if (G_UNLIKELY(calculated < PA_VOLUME_MUTED)) { - cvol->values[i] = PA_VOLUME_MUTED; - } else { - cvol->values[i] = calculated; - } - } - - return cvol; -} - diff --git a/tests/pa-mock.cpp b/tests/pa-mock.cpp new file mode 100644 index 0000000..5b433fe --- /dev/null +++ b/tests/pa-mock.cpp @@ -0,0 +1,857 @@ + +#include +#include +#include + +#include +#include +#include +#include + +#ifdef G_LOG_DOMAIN +#undef G_LOG_DOMAIN +#endif +#define G_LOG_DOMAIN "PA-Mock" + +G_DEFINE_QUARK("pa-mock-state-cb-list", state_cb); +G_DEFINE_QUARK("pa-mock-subscribe-callback", subscribe_cb); +G_DEFINE_QUARK("pa-mock-subscribe-mask", subscribe_mask); +G_DEFINE_QUARK("pa-mock-current-state", state); +G_DEFINE_QUARK("pa-mock-future-state", state_future); + +/* Core class of the PA Mock state */ +class PAMockContext { +public: + /* Accounting */ + std::atomic refcnt; + + /* State stuff */ + std::vector> stateCallbacks; + pa_context_state_t currentState; + pa_context_state_t futureState; + + /* Event stuff */ + std::vector> eventCallbacks; + pa_subscription_mask_t mask; + + PAMockContext () + : refcnt(1) + , currentState(PA_CONTEXT_UNCONNECTED) + , futureState(PA_CONTEXT_UNCONNECTED) + , mask(PA_SUBSCRIPTION_MASK_NULL) + { + g_debug("Creating Context: %p", this); + } + + ~PAMockContext () { + g_debug("Destroying Context: %p", this); + } + + /* Ref counting */ + void ref () { + refcnt++; + } + + void unref () { + refcnt--; + if (refcnt == 0) + delete this; + } + + /* C/C++ boundry */ + operator pa_context *() { + return reinterpret_cast(this); + } + + /* State Stuff */ + void setState (pa_context_state_t state) + { + if (state == currentState) + return; + + currentState = state; + for (auto callback : stateCallbacks) { + callback(); + } + } + + void idleOnce (std::function idleFunc) { + auto allocated = new std::function(idleFunc); + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + [](gpointer data) -> gboolean { + std::function * pidleFunc = reinterpret_cast *>(data); + (*pidleFunc)(); + return G_SOURCE_REMOVE; + }, + allocated, + [](gpointer data) -> void { + std::function * pidleFunc = reinterpret_cast *>(data); + delete pidleFunc; + }); + } + + void queueState (pa_context_state_t state) + { + idleOnce([this, state](){ + setState(state); + }); + } + + pa_context_state_t getState (void) + { + return currentState; + } + + void addStateCallback (std::function &callback) + { + stateCallbacks.push_back(callback); + } +}; + +struct pa_context { + operator PAMockContext * () { + return reinterpret_cast(this); + } +}; + +/* ******************************* + * context.h + * *******************************/ + +pa_context * +pa_context_new_with_proplist (pa_mainloop_api *mainloop, const char *name, pa_proplist *proplist) +{ + return *(new PAMockContext()); +} + +void +pa_context_unref (pa_context *c) { + reinterpret_cast(c)->unref(); +} + +pa_context * +pa_context_ref (pa_context *c) { + reinterpret_cast(c)->ref(); + return c; +} + +int +pa_context_connect (pa_context *c, const char *server, pa_context_flags_t flags, const pa_spawn_api *api) +{ + reinterpret_cast(c)->queueState(PA_CONTEXT_READY); + return 0; +} + +void +pa_context_disconnect (pa_context *c) +{ + reinterpret_cast(c)->queueState(PA_CONTEXT_UNCONNECTED); +} + +int +pa_context_errno (pa_context *c) +{ + return 0; +} + +void +pa_context_set_state_callback (pa_context *c, pa_context_notify_cb_t cb, void *userdata) +{ + std::function cppcb([c, cb, userdata]() { + cb(c, userdata); + }); + reinterpret_cast(c)->addStateCallback(cppcb); +} + +pa_context_state_t +pa_context_get_state (pa_context *c) +{ + return reinterpret_cast(c)->getState(); +} + +/* ******************************* + * introspect.h + * *******************************/ + +typedef struct { + pa_server_info_cb_t cb; + gpointer userdata; + pa_context * context; +} get_server_info_t; + +static void +get_server_info_free (gpointer data) +{ + get_server_info_t * info = (get_server_info_t *)data; + g_object_unref(info->context); + g_free(info); +} + +static gboolean +get_server_info_cb (gpointer data) +{ + pa_server_info server{ + .user_name = "user", + .host_name = "host", + .server_version = "1.2.3", + .server_name = "server", + .sample_spec = { + .format = PA_SAMPLE_U8, + .rate = 44100, + .channels = 1 + }, + .default_sink_name = "default-sink", + .default_source_name = "default-source", + .cookie = 1234, + .channel_map = { + .channels = 0 + } + }; + get_server_info_t * info = (get_server_info_t *)data; + + info->cb(info->context, &server, info->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation* +pa_context_get_server_info (pa_context *c, pa_server_info_cb_t cb, void *userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + g_return_val_if_fail(cb != nullptr, nullptr); + + get_server_info_t * info = g_new(get_server_info_t, 1); + info->cb = cb; + info->userdata = userdata; + info->context = (pa_context *)g_object_ref(c); + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + get_server_info_cb, + info, + get_server_info_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_sink_info_cb_t cb; + gpointer userdata; + pa_context * context; + uint32_t index; +} get_sink_info_t; + +static void +get_sink_info_free (gpointer data) +{ + get_sink_info_t * info = (get_sink_info_t *)data; + g_object_unref(info->context); + g_free(info); +} + +static gboolean +get_sink_info_cb (gpointer data) +{ + #if 0 + pa_sink_port_info active_port = { + .name = "speaker" + }; + #endif + pa_sink_info sink = {0}; + #if 0 + .name = "default-sink", + .index = 0, + .description = "Default Sink", + .channel_map = { + .channels = 0 + }, + .active_port = &active_port + }; + #endif + get_sink_info_t * info = (get_sink_info_t *)data; + + info->cb(info->context, &sink, 1, info->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation* +pa_context_get_sink_info_by_name (pa_context *c, const gchar * name, pa_sink_info_cb_t cb, void *userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + g_return_val_if_fail(g_strcmp0(name, "default-sink") == 0, nullptr); + g_return_val_if_fail(cb != nullptr, nullptr); + + get_sink_info_t * info = g_new(get_sink_info_t, 1); + info->cb = cb; + info->userdata = userdata; + info->context = (pa_context *)g_object_ref(c); + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + get_sink_info_cb, + info, + get_sink_info_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +pa_operation* +pa_context_get_sink_info_list (pa_context *c, pa_sink_info_cb_t cb, void *userdata) +{ + /* Only have one today, so this is the same */ + return pa_context_get_sink_info_by_name(c, "default-sink", cb, userdata); +} + +typedef struct { + pa_sink_input_info_cb_t cb; + gpointer userdata; + pa_context * context; +} get_sink_input_info_t; + +static void +get_sink_input_info_free (gpointer data) +{ + get_sink_input_info_t * info = (get_sink_input_info_t *)data; + pa_context_unref(info->context); + g_free(info); +} + +static gboolean +get_sink_input_info_cb (gpointer data) +{ + pa_sink_input_info sink = { 0 }; + + get_sink_input_info_t * info = (get_sink_input_info_t *)data; + + info->cb(info->context, &sink, 0, info->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation * +pa_context_get_sink_input_info (pa_context *c, uint32_t idx, pa_sink_input_info_cb_t cb, void * userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + g_return_val_if_fail(cb != nullptr, nullptr); + + get_sink_input_info_t * info = g_new(get_sink_input_info_t, 1); + info->cb = cb; + info->userdata = userdata; + info->context = (pa_context *)g_object_ref(c); + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + get_sink_input_info_cb, + info, + get_sink_input_info_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_source_info_cb_t cb; + gpointer userdata; + pa_context * context; +} get_source_info_t; + +static void +get_source_info_free (gpointer data) +{ + get_source_info_t * info = (get_source_info_t *)data; + g_object_unref(info->context); + g_free(info); +} + +static gboolean +get_source_info_cb (gpointer data) +{ + pa_source_info source = { + .name = "default-source" + }; + get_source_info_t * info = (get_source_info_t *)data; + + info->cb(info->context, &source, 0, info->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation* +pa_context_get_source_info_by_name (pa_context *c, const char * name, pa_source_info_cb_t cb, void *userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + g_return_val_if_fail(cb != nullptr, nullptr); + + get_source_info_t * info = g_new(get_source_info_t, 1); + info->cb = cb; + info->userdata = userdata; + info->context = (pa_context *)g_object_ref(c); + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + get_source_info_cb, + info, + get_source_info_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_source_output_info_cb_t cb; + gpointer userdata; + pa_context * context; +} get_source_output_t; + +static void +get_source_output_free (gpointer data) +{ + get_source_output_t * info = (get_source_output_t *)data; + g_object_unref(info->context); + g_free(info); +} + +static gboolean +get_source_output_cb (gpointer data) +{ + pa_source_output_info source = {0}; + source.name = "default source"; + + get_source_output_t * info = (get_source_output_t *)data; + + info->cb(info->context, &source, 0, info->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation* +pa_context_get_source_output_info (pa_context *c, uint32_t idx, pa_source_output_info_cb_t cb, void *userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + g_return_val_if_fail(cb != nullptr, nullptr); + + get_source_output_t * info = g_new(get_source_output_t, 1); + info->cb = cb; + info->userdata = userdata; + info->context = (pa_context *)g_object_ref(c); + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + get_source_output_cb, + info, + get_source_output_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_context_success_cb_t cb; + gpointer userdata; + pa_context * context; + int mute; +} set_sink_mute_t; + +static void +set_sink_mute_free (gpointer data) +{ + set_sink_mute_t * mute = (set_sink_mute_t *)data; + g_object_unref(mute->context); + g_free(mute); +} + +static gboolean +set_sink_mute_cb (gpointer data) +{ + set_sink_mute_t * mute = (set_sink_mute_t *)data; + + if (mute->cb != nullptr) + mute->cb(mute->context, 1, mute->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation* +pa_context_set_sink_mute_by_index (pa_context *c, uint32_t idx, int mute, pa_context_success_cb_t cb, void *userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + + set_sink_mute_t * data = g_new(set_sink_mute_t, 1); + data->cb = cb; + data->userdata = userdata; + data->context = pa_context_ref(c); + data->mute = mute; + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + set_sink_mute_cb, + data, + set_sink_mute_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_context_success_cb_t cb; + gpointer userdata; + pa_context * context; + pa_cvolume cvol; +} set_sink_volume_t; + +static void +set_sink_volume_free (gpointer data) +{ + set_sink_volume_t * vol = (set_sink_volume_t *)data; + g_object_unref(vol->context); + g_free(vol); +} + +static gboolean +set_sink_volume_cb (gpointer data) +{ + set_sink_volume_t * vol = (set_sink_volume_t *)data; + + vol->cb(vol->context, 1, vol->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation* +pa_context_set_sink_volume_by_index (pa_context *c, uint32_t idx, const pa_cvolume * cvol, pa_context_success_cb_t cb, void *userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + g_return_val_if_fail(cb != nullptr, nullptr); + + set_sink_volume_t * data = g_new(set_sink_volume_t, 1); + data->cb = cb; + data->userdata = userdata; + data->context = pa_context_ref(c); + data->cvol.channels = cvol->channels; + + int i; + for (i = 0; i < cvol->channels; i++) + data->cvol.values[i] = cvol->values[i]; + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + set_sink_volume_cb, + data, + set_sink_volume_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_context_success_cb_t cb; + gpointer userdata; + pa_context * context; + pa_cvolume cvol; +} set_source_volume_t; + +static void +set_source_volume_free (gpointer data) +{ + set_source_volume_t * vol = (set_source_volume_t *)data; + g_object_unref(vol->context); + g_free(vol); +} + +static gboolean +set_source_volume_cb (gpointer data) +{ + set_source_volume_t * vol = (set_source_volume_t *)data; + + vol->cb(vol->context, 1, vol->userdata); + + return G_SOURCE_REMOVE; +} + +pa_operation* +pa_context_set_source_volume_by_name (pa_context *c, const char * name, const pa_cvolume * cvol, pa_context_success_cb_t cb, void *userdata) +{ + g_return_val_if_fail(G_IS_OBJECT(c), nullptr); + g_return_val_if_fail(cb != nullptr, nullptr); + + set_source_volume_t * data = g_new(set_source_volume_t, 1); + data->cb = cb; + data->userdata = userdata; + data->context = pa_context_ref(c); + data->cvol.channels = cvol->channels; + + int i; + for (i = 0; i < cvol->channels; i++) + data->cvol.values[i] = cvol->values[i]; + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + set_source_volume_cb, + data, + set_source_volume_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +/* ******************************* + * subscribe.h + * *******************************/ + +typedef struct { + pa_context_success_cb_t cb; + gpointer userdata; + pa_context * 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(G_OBJECT(mask_data->context), subscribe_mask_quark(), GINT_TO_POINTER(mask_data->mask)); + if (mask_data->cb != nullptr) + 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_val_if_fail(G_IS_OBJECT(c), nullptr); + + subscribe_mask_t * data = g_new0(subscribe_mask_t, 1); + data->cb = callback; + data->userdata = userdata; + data->context = pa_context_ref(c); + data->mask = mask; + + g_idle_add_full(G_PRIORITY_DEFAULT_IDLE, + subscribe_mask_cb, + data, + subscribe_mask_free); + + GObject * goper = (GObject *)g_object_new(G_TYPE_OBJECT, nullptr); + pa_operation * oper = (pa_operation *)goper; + return oper; +} + +typedef struct { + pa_context_subscribe_cb_t cb; + gpointer 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(G_OBJECT(c), subscribe_cb_quark(), sub, g_free); +} + +/* ******************************* + * glib-mainloop.h + * *******************************/ + +struct pa_glib_mainloop { + GMainContext * context; +}; + +struct pa_mainloop_api mock_mainloop = { 0 }; + +pa_mainloop_api * +pa_glib_mainloop_get_api (pa_glib_mainloop * g) +{ + return &mock_mainloop; +} + +pa_glib_mainloop * +pa_glib_mainloop_new (GMainContext * c) +{ + pa_glib_mainloop * loop = g_new0(pa_glib_mainloop, 1); + + if (c == nullptr) + loop->context = g_main_context_default(); + else + loop->context = c; + + g_main_context_ref(loop->context); + return loop; +} + +void +pa_glib_mainloop_free (pa_glib_mainloop * g) +{ + g_main_context_unref(g->context); + g_free(g); +} + +/* ******************************* + * operation.h + * *******************************/ + +void +pa_operation_unref (pa_operation * operation) +{ + g_return_if_fail(G_IS_OBJECT(operation)); + g_object_unref(G_OBJECT(operation)); +} + +/* ******************************* + * 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 != nullptr); + g_hash_table_destroy((GHashTable *)p); +} + +const char * +pa_proplist_gets (pa_proplist * p, const char * key) +{ + g_return_val_if_fail(p != nullptr, nullptr); + g_return_val_if_fail(key != nullptr, nullptr); + return (const char *)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 != nullptr, -1); + g_return_val_if_fail(key != nullptr, -1); + g_return_val_if_fail(value != nullptr, -1); + + g_hash_table_insert((GHashTable *)p, g_strdup(key), g_strdup(value)); + return 0; +} + +/* ******************************* + * 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); + + pa_volume_t calculated = lround(cbrt(linear) * PA_VOLUME_NORM); + + if (G_UNLIKELY(calculated > PA_VOLUME_MAX)) { + return PA_VOLUME_MAX; + } else if (G_UNLIKELY(calculated < PA_VOLUME_MUTED)) { + return PA_VOLUME_MUTED; + } else { + return calculated; + } +} + +pa_cvolume * +pa_cvolume_init (pa_cvolume * cvol) +{ + g_return_val_if_fail(cvol != nullptr, nullptr); + + 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 != nullptr, nullptr); + g_warn_if_fail(channels > 0); + g_return_val_if_fail(channels <= PA_CHANNELS_MAX, nullptr); + + cvol->channels = channels; + + unsigned int i; + for (i = 0; i < channels; i++) { + if (G_UNLIKELY(volume > PA_VOLUME_MAX)) { + cvol->values[i] = PA_VOLUME_MAX; + } else if (G_UNLIKELY(volume < PA_VOLUME_MUTED)) { + cvol->values[i] = PA_VOLUME_MUTED; + } else { + cvol->values[i] = volume; + } + } + + return cvol; +} + +pa_volume_t +pa_cvolume_max (const pa_cvolume * cvol) +{ + g_return_val_if_fail(cvol != nullptr, PA_VOLUME_MUTED); + 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 != nullptr, nullptr); + + 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 < cvol->channels; i++) { + pa_volume_t calculated = (cvol->values[i] * max) / originalmax; + + if (G_UNLIKELY(calculated > PA_VOLUME_MAX)) { + cvol->values[i] = PA_VOLUME_MAX; + } else if (G_UNLIKELY(calculated < PA_VOLUME_MUTED)) { + cvol->values[i] = PA_VOLUME_MUTED; + } else { + cvol->values[i] = calculated; + } + } + + return cvol; +} + -- cgit v1.2.3