From fb23acf87417d2c97ad4a5914d742fbf0c8a00e1 Mon Sep 17 00:00:00 2001 From: "Michael Bouchaud (yoz)" Date: Mon, 18 Mar 2019 08:54:42 -0400 Subject: [PATCH] mixer: factorize backend emix infra Summary: The mixer gadgets suffer of a bad design between old and new gadget infra. This commit refactorize the mixer backend to get only one instance between old and new gadget. This resolve many problems as e_client_volume integration or the default_sink choosen in one of this modules. Now it will be easier to maintain this code and better support when we will remove old gadget infra. Reviewers: zmike, devilhorns, stephenmhouston Reviewed By: zmike Subscribers: cedric Tags: #enlightenment-git Differential Revision: https://phab.enlightenment.org/D7718 --- src/modules/mixer/e_mod_main.c | 1294 ++------------------------- src/modules/mixer/gadget/backend.c | 1340 ++++++++++++++++++++++++++++ src/modules/mixer/gadget/backend.h | 24 + src/modules/mixer/gadget/mixer.c | 1101 ++--------------------- src/modules/mixer/gadget/mod.c | 5 +- src/modules/mixer/meson.build | 3 +- 6 files changed, 1515 insertions(+), 2252 deletions(-) create mode 100644 src/modules/mixer/gadget/backend.c create mode 100644 src/modules/mixer/gadget/backend.h diff --git a/src/modules/mixer/e_mod_main.c b/src/modules/mixer/e_mod_main.c index 32d3715b2..3fdbd4a09 100644 --- a/src/modules/mixer/e_mod_main.c +++ b/src/modules/mixer/e_mod_main.c @@ -4,21 +4,9 @@ #include "e_mod_main.h" #include "e_mod_config.h" #include "gadget/mixer.h" +#include "gadget/backend.h" -#define VOLUME_STEP 5 - -#define BARRIER_CHECK(old_val, new_val) \ - (old_val > EMIX_VOLUME_BARRIER - 20) && \ - (old_val <= EMIX_VOLUME_BARRIER) && \ - (new_val > EMIX_VOLUME_BARRIER) && \ - (new_val < EMIX_VOLUME_BARRIER + 20) - -int _e_emix_log_domain; -static Eina_Bool init; -static Eina_List *_client_sinks = NULL; -static Eina_List *_client_mixers = NULL; -static Eina_List *_client_handlers = NULL; -static E_Client_Menu_Hook *_border_hook = NULL; +EINTERN int _e_emix_log_domain; /* module requirements */ E_API E_Module_Api e_modapi = @@ -54,23 +42,9 @@ typedef struct _Context Context; struct _Context { char *theme; - Ecore_Exe *emixer; - Ecore_Event_Handler *desklock_handler; - Ecore_Event_Handler *emix_event_handler; - const Emix_Sink *sink_default; E_Module *module; Eina_List *instances; E_Menu *menu; - unsigned int notification_id; - - struct { - E_Action *incr; - E_Action *decr; - E_Action *mute; - E_Action *incr_app; - E_Action *decr_app; - E_Action *mute_app; - } actions; }; typedef struct _Instance Instance; @@ -85,62 +59,10 @@ struct _Instance Evas_Object *list; Evas_Object *slider; Evas_Object *check; - - Eina_Bool mute; -}; - -typedef struct _Client_Mixer Client_Mixer; -struct _Client_Mixer -{ - Evas_Object *win; - Evas_Object *volume; - Evas_Object *mute; - E_Client *ec; - Evas_Object *bx; - Eina_List *sinks; }; static Context *mixer_context = NULL; - -static void -_notify_cb(void *data EINA_UNUSED, unsigned int id) -{ - mixer_context->notification_id = id; -} - -static void -_notify(const int val) -{ - E_Notification_Notify n; - char *icon, buf[56]; - int ret; - - if (!emix_config_notify_get()) return; - - memset(&n, 0, sizeof(E_Notification_Notify)); - if (val < 0) return; - - ret = snprintf(buf, (sizeof(buf) - 1), "%s: %d%%", _("New volume"), val); - if ((ret < 0) || ((unsigned int)ret > sizeof(buf))) - return; - //Names are taken from FDO icon naming scheme - if (val == 0) - icon = "audio-volume-muted"; - else if ((val > 33) && (val < 66)) - icon = "audio-volume-medium"; - else if (val <= 33) - icon = "audio-volume-low"; - else - icon = "audio-volume-high"; - - n.app_name = _("Mixer"); - n.replaces_id = mixer_context->notification_id; - n.icon.icon = icon; - n.summary = _("Volume changed"); - n.body = buf; - n.timeout = 2000; - e_notification_client_send(&n, _notify_cb, NULL); -} +static Eina_List *_handlers = NULL; static void _mixer_popup_update(Instance *inst, int mute, int vol) @@ -157,13 +79,15 @@ _mixer_gadget_update(void) Edje_Message_Int_Set *msg; Instance *inst; Eina_List *l; + const Eina_List *ll; + Elm_Object_Item *it; EINA_LIST_FOREACH(mixer_context->instances, l, inst) { msg = alloca(sizeof(Edje_Message_Int_Set) + (2 * sizeof(int))); msg->count = 3; - if (!mixer_context->sink_default) + if (!backend_sink_default_get()) { msg->val[0] = EINA_FALSE; msg->val[1] = 0; @@ -173,235 +97,31 @@ _mixer_gadget_update(void) } else { - int vol = 0; - unsigned int i = 0; - for (i = 0; i < - mixer_context->sink_default->volume.channel_count; i++) - vol += mixer_context->sink_default->volume.volumes[i]; - if (mixer_context->sink_default->volume.channel_count) - vol /= mixer_context->sink_default->volume.channel_count; - msg->val[0] = mixer_context->sink_default->mute; - msg->val[1] = vol; + msg->val[0] = backend_mute_get(); + msg->val[1] = backend_volume_get(); msg->val[2] = msg->val[1]; if (inst->popup) - _mixer_popup_update(inst, mixer_context->sink_default->mute, - msg->val[1]); + _mixer_popup_update(inst, msg->val[0], msg->val[1]); } edje_object_message_send(inst->gadget, EDJE_MESSAGE_INT_SET, 0, msg); edje_object_signal_emit(inst->gadget, "e,action,volume,change", "e"); + + if (inst->list) + { + EINA_LIST_FOREACH(elm_list_items_get(inst->list), ll, it) + { + if (backend_sink_default_get() == elm_object_item_data_get(it)) + elm_list_item_selected_set(it, EINA_TRUE); + } + } } } -static void -_volume_increase_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) +static Eina_Bool +_mixer_backend_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event EINA_UNUSED) { - unsigned int i; - Emix_Volume volume; - - EINA_SAFETY_ON_NULL_RETURN(mixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)mixer_context->sink_default; - - if (!s->volume.channel_count) return; - - if (BARRIER_CHECK(s->volume.volumes[0], s->volume.volumes[0] + VOLUME_STEP)) - return; - - volume.channel_count = s->volume.channel_count; - volume.volumes = calloc(s->volume.channel_count, sizeof(int)); - for (i = 0; i < volume.channel_count; i++) - { - if (s->volume.volumes[i] < (emix_max_volume_get()) - VOLUME_STEP) - volume.volumes[i] = s->volume.volumes[i] + VOLUME_STEP; - else if (s->volume.volumes[i] < emix_max_volume_get()) - volume.volumes[i] = emix_max_volume_get(); - else - volume.volumes[i] = s->volume.volumes[i]; - } - - emix_sink_volume_set(s, volume); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - free(volume.volumes); -} - -static void -_volume_decrease_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - unsigned int i; - Emix_Volume volume; - - EINA_SAFETY_ON_NULL_RETURN(mixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)mixer_context->sink_default; - volume.channel_count = s->volume.channel_count; - volume.volumes = calloc(s->volume.channel_count, sizeof(int)); - for (i = 0; i < volume.channel_count; i++) - { - if (s->volume.volumes[i] > VOLUME_STEP) - volume.volumes[i] = s->volume.volumes[i] - VOLUME_STEP; - else if (s->volume.volumes[i] < VOLUME_STEP) - volume.volumes[i] = 0; - else - volume.volumes[i] = s->volume.volumes[i]; - } - - emix_sink_volume_set(s, volume); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - free(volume.volumes); -} - -static void -_volume_mute_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - EINA_SAFETY_ON_NULL_RETURN(mixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)mixer_context->sink_default; - Eina_Bool mute = !s->mute; - emix_sink_mute_set(s, mute); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); -} - -static void -_volume_increase_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - E_Client *ec; - - ec = e_client_focused_get(); - if (ec && ec->volume_control_enabled) - { - e_client_volume_set(ec, ec->volume + VOLUME_STEP); - } -} - -static void -_volume_decrease_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - E_Client *ec; - - ec = e_client_focused_get(); - if (ec && ec->volume_control_enabled) - { - e_client_volume_set(ec, ec->volume - VOLUME_STEP); - } -} - -static void -_volume_mute_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - E_Client *ec; - - ec = e_client_focused_get(); - if (ec && ec->volume_control_enabled) - { - e_client_volume_mute_set(ec, !ec->mute); - } -} - -static void -_actions_register(void) -{ - mixer_context->actions.incr = e_action_add("volume_increase"); - if (mixer_context->actions.incr) - { - mixer_context->actions.incr->func.go = _volume_increase_cb; - e_action_predef_name_set("Mixer", _("Increase Volume"), - "volume_increase", NULL, NULL, 0); - } - - mixer_context->actions.decr = e_action_add("volume_decrease"); - if (mixer_context->actions.decr) - { - mixer_context->actions.decr->func.go = _volume_decrease_cb; - e_action_predef_name_set("Mixer", _("Decrease Volume"), - "volume_decrease", NULL, NULL, 0); - } - - mixer_context->actions.mute = e_action_add("volume_mute"); - if (mixer_context->actions.mute) - { - mixer_context->actions.mute->func.go = _volume_mute_cb; - e_action_predef_name_set("Mixer", _("Mute volume"), "volume_mute", - NULL, NULL, 0); - } - mixer_context->actions.incr_app = e_action_add("volume_increase_app"); - if (mixer_context->actions.incr_app) - { - mixer_context->actions.incr_app->func.go = _volume_increase_app_cb; - e_action_predef_name_set("Mixer", - _("Increase Volume of Focused Application"), - "volume_increase_app", NULL, NULL, 0); - } - mixer_context->actions.decr_app = e_action_add("volume_decrease_app"); - if (mixer_context->actions.decr_app) - { - mixer_context->actions.decr_app->func.go = _volume_decrease_app_cb; - e_action_predef_name_set("Mixer", - _("Decrease Volume of Focused Application"), - "volume_decrease_app", NULL, NULL, 0); - } - mixer_context->actions.mute_app = e_action_add("volume_mute_app"); - if (mixer_context->actions.mute_app) - { - mixer_context->actions.mute_app->func.go = _volume_mute_app_cb; - e_action_predef_name_set("Mixer", - _("Mute Volume of Focused Application"), - "volume_mute_app", NULL, NULL, 0); - } - - e_comp_canvas_keys_ungrab(); - e_comp_canvas_keys_grab(); -} - -static void -_actions_unregister(void) -{ - if (mixer_context->actions.incr) - { - e_action_predef_name_del("Mixer", _("Increase Volume")); - e_action_del("volume_increase"); - mixer_context->actions.incr = NULL; - } - - if (mixer_context->actions.decr) - { - e_action_predef_name_del("Mixer", _("Decrease Volume")); - e_action_del("volume_decrease"); - mixer_context->actions.decr = NULL; - } - - if (mixer_context->actions.mute) - { - e_action_predef_name_del("Mixer", _("Mute Volume")); - e_action_del("volume_mute"); - mixer_context->actions.mute = NULL; - } - - if (mixer_context->actions.incr_app) - { - e_action_predef_name_del("Mixer", - _("Increase Volume of Focuse Application")); - e_action_del("volume_increase_app"); - mixer_context->actions.incr_app = NULL; - } - - if (mixer_context->actions.decr_app) - { - e_action_predef_name_del("Mixer", - _("Decrease Volume of Focuse Application")); - e_action_del("volume_decrease_app"); - mixer_context->actions.decr_app = NULL; - } - - if (mixer_context->actions.mute_app) - { - e_action_predef_name_del("Mixer", - _("Mute Volume of Focuse Application")); - e_action_del("volume_mute_app"); - mixer_context->actions.mute_app = NULL; - } - - e_comp_canvas_keys_ungrab(); - e_comp_canvas_keys_grab(); + _mixer_gadget_update(); + return ECORE_CALLBACK_PASS_ON; } static void @@ -409,6 +129,7 @@ _popup_del(Instance *inst) { inst->slider = NULL; inst->check = NULL; + inst->list = NULL; E_FREE_FUNC(inst->popup, e_object_del); } @@ -426,48 +147,20 @@ _popup_comp_del_cb(void *data, Evas_Object *obj EINA_UNUSED) E_FREE_FUNC(inst->popup, e_object_del); } -static Eina_Bool -_emixer_del_cb(void *data EINA_UNUSED, int type EINA_UNUSED, - void *info EINA_UNUSED) -{ - mixer_context->emixer = NULL; - if (mixer_context->emix_event_handler) - { - ecore_event_handler_del(mixer_context->emix_event_handler); - mixer_context->emix_event_handler = NULL; - } - return EINA_TRUE; -} - static void _emixer_exec_cb(void *data, Evas_Object *obj EINA_UNUSED, void *event_info EINA_UNUSED) { Instance *inst = data; _popup_del(inst); - if (mixer_context->emixer) return; - - mixer_context->emixer = e_util_exe_safe_run("emixer", NULL); - if (mixer_context->emix_event_handler) - ecore_event_handler_del(mixer_context->emix_event_handler); - mixer_context->emix_event_handler = - ecore_event_handler_add(ECORE_EXE_EVENT_DEL, _emixer_del_cb, NULL); + backend_emixer_exec(); } static void -_check_changed_cb(void *data EINA_UNUSED, Evas_Object *obj EINA_UNUSED, +_check_changed_cb(void *data EINA_UNUSED, Evas_Object *obj, void *event EINA_UNUSED) { - EINA_SAFETY_ON_NULL_RETURN(mixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)mixer_context->sink_default; - emix_sink_mute_set(s, !s->mute); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - /* - *TODO: is it really necessary ? or it will be update - * with the sink changed hanlder - */ - _mixer_gadget_update(); + backend_mute_set(elm_check_state_get(obj)); } static void @@ -476,23 +169,46 @@ _slider_changed_cb(void *data EINA_UNUSED, Evas_Object *obj, { int val; - EINA_SAFETY_ON_NULL_RETURN(mixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)mixer_context->sink_default; - val = (int)elm_slider_value_get(obj); - VOLSET(val, s->volume, s, emix_sink_volume_set); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); + backend_volume_set(val); } static void _sink_selected_cb(void *data, Evas_Object *obj EINA_UNUSED, void *event_info EINA_UNUSED) { - Emix_Sink *s = data; + backend_sink_default_set(data); +} - mixer_context->sink_default = s; - if (s) emix_config_save_sink_set(s->name); - _mixer_gadget_update(); +static Eina_Bool +_mixer_sinks_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event EINA_UNUSED) +{ + Instance *inst; + Eina_List *l, *ll; + + EINA_LIST_FOREACH(mixer_context->instances, l, inst) + { + if (inst->list) + { + Elm_Object_Item *default_it = NULL; + Emix_Sink *s; + + elm_list_clear(inst->list); + EINA_LIST_FOREACH((Eina_List *)emix_sinks_get(), ll, s) + { + Elm_Object_Item *it; + + it = elm_list_item_append(inst->list, s->name, NULL, NULL, + _sink_selected_cb, s); + if (backend_sink_default_get() == s) + default_it = it; + } + elm_list_go(inst->list); + if (default_it) + elm_list_item_selected_set(default_it, EINA_TRUE); + } + } + + return ECORE_CALLBACK_PASS_ON; } static void @@ -501,12 +217,8 @@ _popup_new(Instance *inst) Evas_Object *button, *list, *slider, *bx; Emix_Sink *s; Eina_List *l; - int num = 0; Elm_Object_Item *default_it = NULL; - unsigned int volume = 0, i; - EINA_SAFETY_ON_NULL_RETURN(mixer_context->sink_default); - unsigned int channels = mixer_context->sink_default->volume.channel_count; inst->popup = e_gadcon_popup_new(inst->gcc, 0); list = elm_box_add(e_comp->elm); @@ -515,23 +227,17 @@ _popup_new(Instance *inst) evas_object_size_hint_align_set(inst->list, EVAS_HINT_FILL, EVAS_HINT_FILL); evas_object_size_hint_weight_set(inst->list, EVAS_HINT_EXPAND, EVAS_HINT_EXPAND); evas_object_show(inst->list); - EINA_LIST_FOREACH((Eina_List *)emix_sinks_get(), l, s) { Elm_Object_Item *it; it = elm_list_item_append(inst->list, s->name, NULL, NULL, _sink_selected_cb, s); - if (mixer_context->sink_default == s) + if (backend_sink_default_get() == s) default_it = it; - num++; } elm_list_go(inst->list); elm_box_pack_end(list, inst->list); - for (volume = 0, i = 0; i < channels; i++) - volume += mixer_context->sink_default->volume.volumes[i]; - if (channels) volume = volume / channels; - bx = elm_box_add(e_comp->elm); elm_box_horizontal_set(bx, EINA_TRUE); evas_object_size_hint_weight_set(bx, EVAS_HINT_EXPAND, 0.0); @@ -549,15 +255,14 @@ _popup_new(Instance *inst) evas_object_show(slider); elm_slider_min_max_set(slider, 0.0, emix_max_volume_get()); evas_object_smart_callback_add(slider, "changed", _slider_changed_cb, NULL); - elm_slider_value_set(slider, volume); + elm_slider_value_set(slider, backend_volume_get()); elm_box_pack_end(bx, slider); evas_object_show(slider); - inst->mute = mixer_context->sink_default->mute; inst->check = elm_check_add(e_comp->elm); evas_object_size_hint_align_set(inst->check, 0.5, EVAS_HINT_FILL); elm_object_text_set(inst->check, _("Mute")); - elm_check_state_pointer_set(inst->check, &(inst->mute)); + elm_check_state_set(inst->check, backend_mute_get()); evas_object_smart_callback_add(inst->check, "changed", _check_changed_cb, NULL); elm_box_pack_end(bx, inst->check); @@ -573,7 +278,6 @@ _popup_new(Instance *inst) evas_object_size_hint_min_set(list, 208, 208); - e_gadcon_popup_content_set(inst->popup, list); e_comp_object_util_autoclose(inst->popup->comp_object, _popup_comp_del_cb, NULL, inst); @@ -643,7 +347,7 @@ _mouse_down_cb(void *data, Evas *evas EINA_UNUSED, } else if (ev->button == 2) { - _volume_mute_cb(NULL, NULL); + backend_mute_set(!backend_mute_get()); } else if (ev->button == 3) { @@ -658,9 +362,9 @@ _mouse_wheel_cb(void *data EINA_UNUSED, Evas *evas EINA_UNUSED, Evas_Event_Mouse_Wheel *ev = event; if (ev->z > 0) - _volume_decrease_cb(NULL, NULL); + backend_volume_decrease(); else if (ev->z < 0) - _volume_increase_cb(NULL, NULL); + backend_volume_increase(); } /* @@ -690,8 +394,7 @@ _gc_init(E_Gadcon *gc, const char *name, const char *id, const char *style) _mouse_wheel_cb, inst); mixer_context->instances = eina_list_append(mixer_context->instances, inst); - if (mixer_context->sink_default) - _mixer_gadget_update(); + _mixer_gadget_update(); return gcc; } @@ -740,908 +443,57 @@ _gc_id_new(const E_Gadcon_Client_Class *client_class EINA_UNUSED) return _gadcon_class.name; } -static void -_sink_event(int type, void *info) -{ - Emix_Sink *sink = info; - const Eina_List *l; - - if (type == EMIX_SINK_REMOVED_EVENT) - { - if (sink == mixer_context->sink_default) - { - l = emix_sinks_get(); - if (l) - mixer_context->sink_default = l->data; - else - mixer_context->sink_default = NULL; - if (emix_config_save_get()) e_config_save_queue(); - _mixer_gadget_update(); - } - } - else if (type == EMIX_SINK_CHANGED_EVENT) - { - if (mixer_context->sink_default == sink) - { - int vol; - - _mixer_gadget_update(); - if (sink->mute || !sink->volume.channel_count) - vol = 0; - else - vol = sink->volume.volumes[0]; - - _notify(vol); - } - } - else - { - DBG("Sink added"); - } - /* - Only safe the state if we are not in init mode, - If we are in init mode, this is a result of the restore call. - Restore iterates over a list of sinks which would get deleted in the - save_state_get call. - */ - if (!init) - { - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - } -} - -static void -_disconnected(void) -{ - E_Client_Volume_Sink *sink; - - EINA_LIST_FREE(_client_sinks, sink) - { - e_client_volume_sink_del(sink); - } - if (mixer_context) mixer_context->sink_default = NULL; - _mixer_gadget_update(); -} - - -static void -_ready(void) -{ - init = EINA_TRUE; - if (emix_sink_default_support()) - mixer_context->sink_default = emix_sink_default_get(); - else - { - if (emix_sinks_get()) - mixer_context->sink_default = emix_sinks_get()->data; - } - - if (emix_config_save_get()) - { - Emix_Sink *s; - const char *sinkname; - - sinkname = emix_config_save_sink_get(); - if (sinkname) - { - Eina_List *sinks = (Eina_List *)emix_sinks_get(); - Eina_List *l; - - EINA_LIST_FOREACH(sinks, l, s) - { - if ((s->name) && (!strcmp(s->name, sinkname))) - { - mixer_context->sink_default = s; - break; - } - } - } - emix_config_save_state_restore(); - } - - _mixer_gadget_update(); - init = EINA_FALSE; -} - -static void -_sink_input_get(int *volume, Eina_Bool *muted, void *data) -{ - Emix_Sink_Input *input; - - input = data; - - if (input->volume.channel_count > 0) - { - if (volume) *volume = input->volume.volumes[0]; - } - if (muted) *muted = input->mute; -} - -static void -_sink_input_set(int volume, Eina_Bool muted, void *data) -{ - Emix_Sink_Input *input; - - input = data; - - VOLSET(volume, input->volume, input, emix_sink_input_volume_set); - emix_sink_input_mute_set(input, muted); -} - -static int -_sink_input_min_get(void *data EINA_UNUSED) -{ - return 0; -} - -static int -_sink_input_max_get(void *data EINA_UNUSED) -{ - return emix_max_volume_get(); -} - -static const char * -_sink_input_name_get(void *data) -{ - Emix_Sink_Input *input; - - input = data; - return input->name; -} - -static pid_t -_get_ppid(pid_t pid) -{ - int fd; - char buf[128]; - char *s; - pid_t ppid; - - /* Open the status info process file provided by kernel to get the parent - * process id. 'man 5 proc' and go to /proc/[pid]/stat to get information - * about the content of this file. - */ - snprintf(buf, sizeof(buf), "/proc/%d/stat", pid); - fd = open(buf, O_RDONLY); - if (fd == -1) - { - ERR("Can't open %s, maybee the process exited.", buf); - return -1; - } - if ((read(fd, buf, sizeof(buf))) < 4) - { - close(fd); - return -1; - } - buf[sizeof(buf) - 1] = 0; - s = strrchr(buf, ')'); - s += 3; - ppid = atoi(s); - close(fd); - return ppid; -} - -static void -_sink_input_event(int type, Emix_Sink_Input *input) -{ - Eina_List *clients, *l, *ll; - E_Client *ec; - E_Client_Volume_Sink *sink; - pid_t pid; - Eina_Bool found = EINA_FALSE; - - switch (type) - { - case EMIX_SINK_INPUT_ADDED_EVENT: - pid = input->pid; - for (;;) - { - if ((pid <= 1) || (pid == getpid())) return; - clients = e_client_focus_stack_get(); - EINA_LIST_FOREACH(clients, l, ec) - { - if ((ec->netwm.pid == pid) && (!ec->parent)) - { - DBG("Sink found the client %s", - e_client_util_name_get(ec)); - sink = e_client_volume_sink_new(_sink_input_get, - _sink_input_set, - _sink_input_min_get, - _sink_input_max_get, - _sink_input_name_get, - input); - e_client_volume_sink_append(ec, sink); - _client_sinks = eina_list_append(_client_sinks, sink); - found = EINA_TRUE; - } - } - if (found) break; - pid = _get_ppid(pid); - } - break; - case EMIX_SINK_INPUT_REMOVED_EVENT: - EINA_LIST_FOREACH_SAFE(_client_sinks, l, ll, sink) - { - if (sink->data == input) - { - e_client_volume_sink_del(sink); - _client_sinks = eina_list_remove_list(_client_sinks, l); - } - } - break; - case EMIX_SINK_INPUT_CHANGED_EVENT: - EINA_LIST_FOREACH(_client_sinks, l, sink) - { - if (sink->data == input) - { - e_client_volume_sink_update(sink); - } - } - break; - } -} - -static void -_events_cb(void *data EINA_UNUSED, enum Emix_Event type, void *event_info) -{ - switch (type) - { - case EMIX_SINK_ADDED_EVENT: - case EMIX_SINK_CHANGED_EVENT: - case EMIX_SINK_REMOVED_EVENT: - _sink_event(type, event_info); - break; - case EMIX_DISCONNECTED_EVENT: - _disconnected(); - break; - case EMIX_READY_EVENT: - _ready(); - break; - case EMIX_SINK_INPUT_ADDED_EVENT: - case EMIX_SINK_INPUT_REMOVED_EVENT: - case EMIX_SINK_INPUT_CHANGED_EVENT: - _sink_input_event(type, event_info); - break; - - default: - break; - } -} - -static Eina_Bool -_desklock_cb(void *data EINA_UNUSED, int type EINA_UNUSED, void *info) -{ - E_Event_Desklock *ev = info; - static Eina_Bool _was_mute = EINA_FALSE; - - if (emix_config_desklock_mute_get() == EINA_FALSE) - return ECORE_CALLBACK_PASS_ON; - if (!mixer_context) - return ECORE_CALLBACK_PASS_ON; - - if (ev->on) - { - if (mixer_context->sink_default) - { - _was_mute = mixer_context->sink_default->mute; - if (!_was_mute) - emix_sink_mute_set((Emix_Sink *)mixer_context->sink_default, EINA_TRUE); - } - } - else - { - if (mixer_context->sink_default) - { - if (!_was_mute) - emix_sink_mute_set((Emix_Sink *)mixer_context->sink_default, EINA_FALSE); - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static void -_backend_changed(const char *backend, void *data EINA_UNUSED) -{ - _disconnected(); - - if (emix_backend_set(backend) == EINA_FALSE) - ERR("Could not load backend: %s", backend); -} - -static void -_bd_hook_volume_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client *ec; - - ec = data; - - e_client_volume_set(ec, elm_slider_value_get(obj)); -} - -static void -_bd_hook_volume_drag_stop(void *data, Evas_Object *obj EINA_UNUSED, void *event_info EINA_UNUSED) -{ - E_Client *ec; - - ec = data; - - elm_slider_value_set(obj, ec->volume); -} - - -static void -_bd_hook_mute_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client *ec; - - ec = data; - - e_client_volume_mute_set(ec, elm_check_state_get(obj)); -} - -static void -_bd_hook_sink_volume_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client_Volume_Sink *sink; - Evas_Object *check; - - sink = data; - - check = evas_object_data_get(obj, "e_sink_check"); - - e_client_volume_sink_set(sink, - elm_slider_value_get(obj), - elm_check_state_get(check)); -} - -static void -_bd_hook_sink_volume_drag_stop(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client_Volume_Sink *sink; - Evas_Object *check; - Eina_Bool mute; - int vol; - - sink = data; - - check = evas_object_data_get(obj, "e_sink_check"); - - e_client_volume_sink_get(sink, &vol, &mute); - elm_slider_value_set(obj, vol); - elm_check_state_set(check, mute); -} - - -static void -_bd_hook_sink_mute_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client_Volume_Sink *sink; - Evas_Object *slider; - - sink = data; - slider = evas_object_data_get(obj, "e_sink_volume"); - - e_client_volume_sink_set(sink, - elm_slider_value_get(slider), - elm_check_state_get(obj)); -} - -static Eina_Bool -_e_client_volume_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client *ev; - Client_Mixer *cm; - E_Client_Volume_Sink *sink; - Evas_Object *o; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - elm_slider_value_set(cm->volume, cm->ec->volume); - EINA_LIST_FOREACH(cm->sinks, l, o) - { - int volume; - sink = evas_object_data_get(o, "e_sink"); - e_client_volume_sink_get(sink, &volume, NULL); - elm_slider_value_set(o, volume); - } - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static Eina_Bool -_e_client_mute_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client *ev; - Client_Mixer *cm; - E_Client_Volume_Sink *sink; - Evas_Object *o, *check; - Eina_List *l; - Eina_Bool mute; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - elm_check_state_set(cm->mute, !!cm->ec->mute); - elm_object_disabled_set(cm->volume, !!cm->ec->mute); - EINA_LIST_FOREACH(cm->sinks, l, o) - { - sink = evas_object_data_get(o, "e_sink"); - check = evas_object_data_get(o, "e_sink_check"); - e_client_volume_sink_get(sink, NULL, &mute); - elm_check_state_set(check, mute); - elm_object_disabled_set(o, mute); - } - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static void -_e_client_mixer_sink_append(E_Client_Volume_Sink *sink, Client_Mixer *cm) -{ - Evas_Object *lbl, *slider, *check, *sep; - int volume; - int min, max; - Eina_Bool mute; - - min = e_client_volume_sink_min_get(sink); - max = e_client_volume_sink_max_get(sink); - e_client_volume_sink_get(sink, &volume, &mute); - - sep = elm_separator_add(cm->bx); - elm_separator_horizontal_set(sep, EINA_TRUE); - evas_object_size_hint_weight_set(sep, 0.0, EVAS_HINT_EXPAND); - evas_object_size_hint_align_set(sep, EVAS_HINT_FILL, EVAS_HINT_FILL); - elm_box_pack_end(cm->bx, sep); - evas_object_show(sep); - - lbl = elm_label_add(cm->bx); - elm_object_text_set(lbl, e_client_volume_sink_name_get(sink)); - evas_object_size_hint_align_set(lbl, 0.0, EVAS_HINT_FILL); - elm_box_pack_end(cm->bx, lbl); - evas_object_show(lbl); - - slider = elm_slider_add(cm->bx); - elm_slider_horizontal_set(slider, EINA_TRUE); - elm_slider_min_max_set(slider, min, max); - elm_slider_span_size_set(slider, max * elm_config_scale_get()); - elm_slider_unit_format_set(slider, "%.0f"); - elm_slider_indicator_format_set(slider, "%.0f"); - evas_object_size_hint_weight_set(slider, 0.0, EVAS_HINT_EXPAND); - evas_object_size_hint_align_set(slider, EVAS_HINT_FILL, EVAS_HINT_FILL); - elm_slider_value_set(slider, volume); - evas_object_smart_callback_add(slider, "changed", - _bd_hook_sink_volume_changed, sink); - evas_object_smart_callback_add(slider, "slider,drag,stop", - _bd_hook_sink_volume_drag_stop, sink); - elm_box_pack_end(cm->bx, slider); - evas_object_show(slider); - - check = elm_check_add(cm->bx); - elm_object_text_set(check, _("Mute")); - evas_object_size_hint_align_set(check, 0.0, EVAS_HINT_FILL); - elm_check_state_set(check, !!mute); - elm_object_disabled_set(slider, !!mute); - evas_object_smart_callback_add(check, "changed", - _bd_hook_sink_mute_changed, sink); - - elm_box_pack_end(cm->bx, check); - evas_object_show(check); - - evas_object_data_set(slider, "e_sink", sink); - evas_object_data_set(slider, "e_sink_check", check); - evas_object_data_set(slider, "e_sink_label", lbl); - evas_object_data_set(slider, "e_sink_separator", sep); - evas_object_data_set(check, "e_sink_volume", slider); - cm->sinks = eina_list_append(cm->sinks, slider); -} - -static Eina_Bool -_e_client_volume_sink_add(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client_Volume_Sink *ev; - Client_Mixer *cm; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - _e_client_mixer_sink_append(ev->sink, cm); - } - } - return ECORE_CALLBACK_PASS_ON; -} - -static Eina_Bool -_e_client_volume_sink_del(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client_Volume_Sink *ev; - E_Client_Volume_Sink *sink; - Client_Mixer *cm; - Evas_Object *o, *lbl, *check, *sep; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - EINA_LIST_FOREACH(cm->sinks, l, o) - { - sink = evas_object_data_get(o, "e_sink"); - if (sink == ev->sink) - { - lbl = evas_object_data_get(o, "e_sink_label"); - check = evas_object_data_get(o, "e_sink_check"); - sep = evas_object_data_get(o, "e_sink_separator"); - evas_object_del(sep); - evas_object_del(lbl); - evas_object_del(o); - evas_object_del(check); - cm->sinks = eina_list_remove_list(cm->sinks, l); - } - } - break; - } - } - return ECORE_CALLBACK_PASS_ON; -} - -static Eina_Bool -_e_client_volume_sink_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client_Volume_Sink *ev; - Client_Mixer *cm; - E_Client_Volume_Sink *sink; - Evas_Object *o, *check; - Eina_List *l; - int volume; - Eina_Bool mute; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - EINA_LIST_FOREACH(cm->sinks, l, o) - { - sink = evas_object_data_get(o, "e_sink"); - if (sink != ev->sink) continue; - check = evas_object_data_get(o, "e_sink_check"); - e_client_volume_sink_get(sink, &volume, &mute); - elm_slider_value_set(o, volume); - elm_object_disabled_set(o, mute); - elm_check_state_set(check, mute); - } - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static void -_client_mixer_del(void *data, Evas *e EINA_UNUSED, Evas_Object *obj EINA_UNUSED, void *event_info EINA_UNUSED) -{ - Client_Mixer *cm; - - cm = data; - - _client_mixers = eina_list_remove(_client_mixers, cm); - free(cm); -} - -static Eina_Bool -_e_client_add(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client *ev; - Eina_List *l; - Emix_Sink_Input *input; - pid_t pid; - E_Client_Volume_Sink *sink; - - ev = event; - - if (ev->ec->parent) return ECORE_CALLBACK_PASS_ON; - EINA_LIST_FOREACH((Eina_List *)emix_sink_inputs_get(), l, input) - { - pid = input->pid; - while (42) - { - if (pid <= 1 || pid == getpid()) return ECORE_CALLBACK_PASS_ON; - if (ev->ec->netwm.pid == pid) - { - DBG("Client(%s) found a sink input", - e_client_util_name_get(ev->ec)); - sink = e_client_volume_sink_new(_sink_input_get, - _sink_input_set, - _sink_input_min_get, - _sink_input_max_get, - _sink_input_name_get, - input); - e_client_volume_sink_append(ev->ec, sink); - _client_sinks = eina_list_append(_client_sinks, sink); - return ECORE_CALLBACK_PASS_ON; - } - pid = _get_ppid(pid); - } - } - return ECORE_CALLBACK_PASS_ON; -} - -static Eina_Bool -_e_client_remove(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client *ev; - Client_Mixer *cm; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - evas_object_event_callback_del_full(cm->win, EVAS_CALLBACK_DEL, - _client_mixer_del, cm); - evas_object_del(cm->win); - _client_mixers = eina_list_remove_list(_client_mixers, l); - free(cm); - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static void -_bd_hook_cb(void *data, E_Menu *m EINA_UNUSED, E_Menu_Item *it EINA_UNUSED) -{ - E_Client *ec; - Client_Mixer *cm; - E_Client_Volume_Sink *sink; - Evas_Object *win, *popup, *bx, *o; - Eina_List *l; - int w, h; - - ec = data; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ec) - return; - } - cm = E_NEW(Client_Mixer, 1); - cm->ec = ec; - - win = elm_popup_add(e_comp->elm); - elm_popup_allow_events_set(win, EINA_TRUE); - - bx = elm_box_add(win); - elm_box_horizontal_set(bx, EINA_FALSE); - elm_object_content_set(win, bx); - evas_object_size_hint_weight_set(bx, EVAS_HINT_EXPAND, EVAS_HINT_EXPAND); - cm->bx = bx; - - o = elm_label_add(bx); - elm_object_text_set(o, _("Main")); - evas_object_size_hint_align_set(o, 0.0, EVAS_HINT_FILL); - elm_box_pack_end(bx, o); - evas_object_show(o); - - o = elm_slider_add(bx); - elm_slider_horizontal_set(o, EINA_TRUE); - elm_slider_min_max_set(o, ec->volume_min, ec->volume_max); - elm_slider_span_size_set(o, ec->volume_max * elm_config_scale_get()); - elm_slider_unit_format_set(o, "%.0f"); - elm_slider_indicator_format_set(o, "%.0f"); - evas_object_size_hint_weight_set(o, 0.0, EVAS_HINT_EXPAND); - evas_object_size_hint_align_set(o, EVAS_HINT_FILL, EVAS_HINT_FILL); - elm_slider_value_set(o, ec->volume); - evas_object_smart_callback_add(o, "changed", _bd_hook_volume_changed, ec); - evas_object_smart_callback_add(o, "slider,drag,stop", - _bd_hook_volume_drag_stop, ec); - elm_box_pack_end(bx, o); - evas_object_show(o); - cm->volume = o; - - o = elm_check_add(bx); - elm_object_text_set(o, _("Mute")); - evas_object_size_hint_align_set(o, 0.0, EVAS_HINT_FILL); - elm_check_state_set(o, !!ec->mute); - elm_object_disabled_set(o, !!ec->mute); - evas_object_smart_callback_add(o, "changed", _bd_hook_mute_changed, ec); - elm_box_pack_end(bx, o); - evas_object_show(o); - cm->mute = o; - - EINA_LIST_FOREACH(ec->sinks, l, sink) - { - _e_client_mixer_sink_append(sink, cm); - } - - evas_object_show(bx); - evas_object_size_hint_min_get(bx, &w, &h); - evas_object_resize(win, w, h); - evas_object_show(win); - popup = e_comp_object_util_add(win, E_COMP_OBJECT_TYPE_NONE); - evas_object_layer_set(popup, E_LAYER_POPUP); - e_comp_object_util_center_on_zone(popup, ec->zone); - evas_object_show(popup); - e_comp_object_util_autoclose(popup, NULL, NULL, NULL); - _client_mixers = eina_list_append(_client_mixers, cm); - evas_object_event_callback_add(popup, EVAS_CALLBACK_DEL, _client_mixer_del, cm); - cm->win = popup; -} - -static void -_bd_hook(void *data EINA_UNUSED, E_Client *ec) -{ - E_Menu_Item *it; - E_Menu *m; - Eina_List *l; - - if (!ec->volume_control_enabled) return; - m = ec->border_menu; - - /* Find the first separator and add us below him */ - EINA_LIST_FOREACH(m->items, l, it) - { - if (it->separator) break; - } - if ((!it) || (!it->separator)) return; - - it = e_menu_item_new_relative(m, it); - e_menu_item_label_set(it, _("Volume")); - e_util_menu_item_theme_icon_set(it, "preferences-desktop-mixer"); - e_menu_item_callback_set(it, _bd_hook_cb, ec); - - it = e_menu_item_new_relative(m, it); - e_menu_item_separator_set(it, EINA_TRUE); -} - E_API void * e_modapi_init(E_Module *m) { - Eina_List *l; char buf[4096]; - const char *backend; - Eina_Bool backend_loaded = EINA_FALSE; _e_emix_log_domain = eina_log_domain_register("mixer", EINA_COLOR_RED); + if (!backend_init()) return NULL; if (!mixer_context) { mixer_context = E_NEW(Context, 1); - mixer_context->desklock_handler = - ecore_event_handler_add(E_EVENT_DESKLOCK, _desklock_cb, NULL); mixer_context->module = m; snprintf(buf, sizeof(buf), "%s/mixer.edj", e_module_dir_get(mixer_context->module)); mixer_context->theme = strdup(buf); } - - EINA_SAFETY_ON_FALSE_RETURN_VAL(emix_init(), NULL); - emix_config_init(_backend_changed, NULL); - emix_event_callback_add(_events_cb, NULL); + E_LIST_HANDLER_APPEND(_handlers, E_EVENT_MIXER_BACKEND_CHANGED, + _mixer_backend_changed, NULL); + E_LIST_HANDLER_APPEND(_handlers, E_EVENT_MIXER_SINKS_CHANGED, + _mixer_sinks_changed, NULL); e_modapi_gadget_init(m); - backend = emix_config_backend_get(); - if (backend && emix_backend_set(backend)) - backend_loaded = EINA_TRUE; - else - { - if (backend) - WRN("Could not load %s, trying another one ...", backend); - EINA_LIST_FOREACH((Eina_List *)emix_backends_available(), l, - backend) - { - if (emix_backend_set(backend) == EINA_TRUE) - { - DBG("Loaded backend: %s!", backend); - backend_loaded = EINA_TRUE; - emix_config_backend_set(backend); - break; - } - } - } - - if (!backend_loaded) goto err; - e_configure_registry_category_add("extensions", 90, _("Extensions"), NULL, "preferences-extensions"); e_configure_registry_item_add("extensions/emix", 30, _("Mixer"), NULL, "preferences-desktop-mixer", emix_config_popup_new); - if (emix_sink_default_support()) - mixer_context->sink_default = emix_sink_default_get(); - e_gadcon_provider_register(&_gadcon_class); - _actions_register(); - - _border_hook = e_int_client_menu_hook_add(_bd_hook, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME, - _e_client_volume_changed, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_MUTE, - _e_client_mute_changed, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_UNMUTE, - _e_client_mute_changed, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_ADD, - _e_client_add, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_REMOVE, - _e_client_remove, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_ADD, - _e_client_volume_sink_add, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_DEL, - _e_client_volume_sink_del, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_CHANGED, - _e_client_volume_sink_changed, NULL); return m; - -err: - emix_config_shutdown(); - emix_shutdown(); - return NULL; } E_API int e_modapi_shutdown(E_Module *m) { - E_Client_Volume_Sink *sink; - Client_Mixer *cm; - - E_FREE_LIST(_client_handlers, ecore_event_handler_del); - EINA_LIST_FREE(_client_mixers, cm) - { - evas_object_event_callback_del_full(cm->win, EVAS_CALLBACK_DEL, - _client_mixer_del, cm); - evas_object_del(cm->win); - free(cm); - } - - e_int_client_menu_hook_del(_border_hook); - _actions_unregister(); e_gadcon_provider_unregister((const E_Gadcon_Client_Class *)&_gadcon_class); + E_FREE_LIST(_handlers, ecore_event_handler_del); if (mixer_context) { free(mixer_context->theme); E_FREE(mixer_context); } - EINA_LIST_FREE(_client_sinks, sink) - e_client_volume_sink_del(sink); - e_modapi_gadget_shutdown(m); - emix_event_callback_del(_events_cb); - emix_shutdown(); - emix_config_shutdown(); + backend_shutdown(); return 1; } diff --git a/src/modules/mixer/gadget/backend.c b/src/modules/mixer/gadget/backend.c new file mode 100644 index 000000000..0f9b469c1 --- /dev/null +++ b/src/modules/mixer/gadget/backend.c @@ -0,0 +1,1340 @@ +#include +#include +#include "emix.h" +#include "e_mod_main.h" +#include "e_mod_config.h" +#include "gadget/mixer.h" +#include "gadget/backend.h" + +#define VOLUME_STEP 5 + +#define BARRIER_CHECK(old_val, new_val) \ + (old_val > EMIX_VOLUME_BARRIER - 20) && \ + (old_val <= EMIX_VOLUME_BARRIER) && \ + (new_val > EMIX_VOLUME_BARRIER) && \ + (new_val < EMIX_VOLUME_BARRIER + 20) + +typedef struct _Client_Mixer Client_Mixer; +struct _Client_Mixer +{ + Evas_Object *win; + Evas_Object *volume; + Evas_Object *mute; + E_Client *ec; + Evas_Object *bx; + Eina_List *sinks; +}; + + +static void _notify_cb(void *data, unsigned int id); +static void _notify(const int val); +static void _volume_increase_cb(E_Object *obj, const char *params); +static void _volume_decrease_cb(E_Object *obj, const char *params); +static void _volume_mute_cb(E_Object *obj, const char *params); +static void _volume_increase_app_cb(E_Object *obj, const char *params); +static void _volume_decrease_app_cb(E_Object *obj, const char *params); +static void _volume_mute_app_cb(E_Object *obj, const char *params); +static void _actions_register(void); +static void _actions_unregister(void); +static void _sink_event(int type, void *info); +static void _disconnected(void); +static void _ready(void); +static void _sink_input_get(int *volume, Eina_Bool *muted, void *data); +static void _sink_input_set(int volume, Eina_Bool muted, void *data); +static int _sink_input_min_get(void *data); +static int _sink_input_max_get(void *data); +static const char *_sink_input_name_get(void *data); +static pid_t _get_ppid(pid_t pid); +static void _sink_input_event(int type, Emix_Sink_Input *input); +static void _events_cb(void *data, enum Emix_Event type, void *event_info); +static Eina_Bool _desklock_cb(void *data, int type, void *info); +static void _emix_backend_changed(const char *backend, void *data); +static void _bd_hook_volume_changed(void *data, Evas_Object *obj, void *event_info); +static void _bd_hook_volume_drag_stop(void *data, Evas_Object *obj, void *event_info); +static void _bd_hook_mute_changed(void *data, Evas_Object *obj, void *event_info); +static void _bd_hook_sink_volume_changed(void *data, Evas_Object *obj, void *event_info); +static void _bd_hook_sink_volume_drag_stop(void *data, Evas_Object *obj, void *event_info); +static void _bd_hook_sink_mute_changed(void *data, Evas_Object *obj, void *event_info); +static Eina_Bool _e_client_volume_changed(void *data, int type, void *event); +static Eina_Bool _e_client_mute_changed(void *data, int type, void *event); +static void _e_client_mixer_sink_append(E_Client_Volume_Sink *sink, Client_Mixer *cm); +static Eina_Bool _e_client_volume_sink_add(void *data, int type, void *event); +static Eina_Bool _e_client_volume_sink_del(void *data, int type, void *event); +static Eina_Bool _e_client_volume_sink_changed(void *data, int type, void *event); +static void _client_mixer_del(void *data, Evas *e, Evas_Object *obj, void *event_info); +static Eina_Bool _e_client_add(void *data, int type, void *event); +static Eina_Bool _e_client_remove(void *data, int type, void *event); +static void _bd_hook_cb(void *data, E_Menu *m, E_Menu_Item *it); +static void _bd_hook(void *data, E_Client *ec); +static Eina_Bool _emixer_del_cb(void *data, int type, void *info); +static void _backend_changed(void); + +static int _backend_log_domain = 0; +static int _volume_init = 0; +static Eina_Bool _backend_init_flag = EINA_FALSE; + +EINTERN int E_EVENT_MIXER_BACKEND_CHANGED = 0; +EINTERN int E_EVENT_MIXER_SINKS_CHANGED = 0; + +static const Emix_Sink *_sink_default = NULL; +static Eina_List *_client_sinks = NULL; +static Eina_List *_client_mixers = NULL; +static Eina_List *_client_handlers = NULL; +static E_Client_Menu_Hook *_border_hook = NULL; +static int _notification_id = 0; +static Ecore_Exe *_emixer_exe = NULL; +static Ecore_Event_Handler *_emix_exe_event_del_handler = NULL; + +static E_Action *_action_incr = NULL; +static E_Action *_action_decr = NULL; +static E_Action *_action_mute = NULL; +static E_Action *_action_incr_app = NULL; +static E_Action *_action_decr_app = NULL; +static E_Action *_action_mute_app = NULL; + +static void +_notify_cb(void *data EINA_UNUSED, unsigned int id) +{ + _notification_id = id; +} + +static void +_notify(const int val) +{ + E_Notification_Notify n; + char *icon, buf[56]; + int ret; + + if (!emix_config_notify_get()) return; + + memset(&n, 0, sizeof(E_Notification_Notify)); + if (val < 0) return; + + ret = snprintf(buf, (sizeof(buf) - 1), "%s: %d%%", _("New volume"), val); + if ((ret < 0) || ((unsigned int)ret > sizeof(buf))) + return; + //Names are taken from FDO icon naming scheme + if (val == 0) + icon = "audio-volume-muted"; + else if ((val > 33) && (val < 66)) + icon = "audio-volume-medium"; + else if (val <= 33) + icon = "audio-volume-low"; + else + icon = "audio-volume-high"; + + n.app_name = _("Mixer"); + n.replaces_id = _notification_id; + n.icon.icon = icon; + n.summary = _("Volume changed"); + n.body = buf; + n.timeout = 2000; + e_notification_client_send(&n, _notify_cb, NULL); +} + +static void +_volume_increase_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) +{ + unsigned int i; + Emix_Volume volume; + + EINA_SAFETY_ON_NULL_RETURN(_sink_default); + Emix_Sink *s = (Emix_Sink *)_sink_default; + + if (!s->volume.channel_count) return; + + if (BARRIER_CHECK(s->volume.volumes[0], s->volume.volumes[0] + VOLUME_STEP)) + return; + + volume.channel_count = s->volume.channel_count; + volume.volumes = calloc(s->volume.channel_count, sizeof(int)); + for (i = 0; i < volume.channel_count; i++) + { + if (s->volume.volumes[i] < (emix_max_volume_get()) - VOLUME_STEP) + volume.volumes[i] = s->volume.volumes[i] + VOLUME_STEP; + else if (s->volume.volumes[i] < emix_max_volume_get()) + volume.volumes[i] = emix_max_volume_get(); + else + volume.volumes[i] = s->volume.volumes[i]; + } + + emix_sink_volume_set(s, volume); + emix_config_save_state_get(); + if (emix_config_save_get()) e_config_save_queue(); + free(volume.volumes); +} + +static void +_volume_decrease_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) +{ + unsigned int i; + Emix_Volume volume; + + EINA_SAFETY_ON_NULL_RETURN(_sink_default); + Emix_Sink *s = (Emix_Sink *)_sink_default; + volume.channel_count = s->volume.channel_count; + volume.volumes = calloc(s->volume.channel_count, sizeof(int)); + for (i = 0; i < volume.channel_count; i++) + { + if (s->volume.volumes[i] > VOLUME_STEP) + volume.volumes[i] = s->volume.volumes[i] - VOLUME_STEP; + else if (s->volume.volumes[i] < VOLUME_STEP) + volume.volumes[i] = 0; + else + volume.volumes[i] = s->volume.volumes[i]; + } + + emix_sink_volume_set((Emix_Sink *)_sink_default, volume); + emix_config_save_state_get(); + if (emix_config_save_get()) e_config_save_queue(); + free(volume.volumes); +} + +static void +_volume_mute_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) +{ + EINA_SAFETY_ON_NULL_RETURN(_sink_default); + backend_mute_set(!_sink_default->mute); +} + +static void +_volume_increase_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) +{ + E_Client *ec; + + ec = e_client_focused_get(); + if (ec && ec->volume_control_enabled) + { + e_client_volume_set(ec, ec->volume + VOLUME_STEP); + } +} + +static void +_volume_decrease_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) +{ + E_Client *ec; + + ec = e_client_focused_get(); + if (ec && ec->volume_control_enabled) + { + e_client_volume_set(ec, ec->volume - VOLUME_STEP); + } +} + +static void +_volume_mute_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) +{ + E_Client *ec; + + ec = e_client_focused_get(); + if (ec && ec->volume_control_enabled) + { + e_client_volume_mute_set(ec, !ec->mute); + } +} + +static void +_actions_register(void) +{ + _action_incr = e_action_add("volume_increase"); + if (_action_incr) + { + _action_incr->func.go = _volume_increase_cb; + e_action_predef_name_set("Mixer", _("Increase Volume"), + "volume_increase", NULL, NULL, 0); + } + + _action_decr = e_action_add("volume_decrease"); + if (_action_decr) + { + _action_decr->func.go = _volume_decrease_cb; + e_action_predef_name_set("Mixer", _("Decrease Volume"), + "volume_decrease", NULL, NULL, 0); + } + + _action_mute = e_action_add("volume_mute"); + if (_action_mute) + { + _action_mute->func.go = _volume_mute_cb; + e_action_predef_name_set("Mixer", _("Mute volume"), "volume_mute", + NULL, NULL, 0); + } + _action_incr_app = e_action_add("volume_increase_app"); + if (_action_incr_app) + { + _action_incr_app->func.go = _volume_increase_app_cb; + e_action_predef_name_set("Mixer", + _("Increase Volume of Focused Application"), + "volume_increase_app", NULL, NULL, 0); + } + _action_decr_app = e_action_add("volume_decrease_app"); + if (_action_decr_app) + { + _action_decr_app->func.go = _volume_decrease_app_cb; + e_action_predef_name_set("Mixer", + _("Decrease Volume of Focused Application"), + "volume_decrease_app", NULL, NULL, 0); + } + _action_mute_app = e_action_add("volume_mute_app"); + if (_action_mute_app) + { + _action_mute_app->func.go = _volume_mute_app_cb; + e_action_predef_name_set("Mixer", + _("Mute Volume of Focused Application"), + "volume_mute_app", NULL, NULL, 0); + } + + e_comp_canvas_keys_ungrab(); + e_comp_canvas_keys_grab(); +} + +static void +_actions_unregister(void) +{ + if (_action_incr) + { + e_action_predef_name_del("Mixer", _("Increase Volume")); + e_action_del("volume_increase"); + _action_incr = NULL; + } + + if (_action_decr) + { + e_action_predef_name_del("Mixer", _("Decrease Volume")); + e_action_del("volume_decrease"); + _action_decr = NULL; + } + + if (_action_mute) + { + e_action_predef_name_del("Mixer", _("Mute Volume")); + e_action_del("volume_mute"); + _action_mute = NULL; + } + + if (_action_incr_app) + { + e_action_predef_name_del("Mixer", + _("Increase Volume of Focuse Application")); + e_action_del("volume_increase_app"); + _action_incr_app = NULL; + } + + if (_action_decr_app) + { + e_action_predef_name_del("Mixer", + _("Decrease Volume of Focuse Application")); + e_action_del("volume_decrease_app"); + _action_decr_app = NULL; + } + + if (_action_mute_app) + { + e_action_predef_name_del("Mixer", + _("Mute Volume of Focuse Application")); + e_action_del("volume_mute_app"); + _action_mute_app = NULL; + } + + e_comp_canvas_keys_ungrab(); + e_comp_canvas_keys_grab(); +} + +static void +_sink_event(int type, void *info) +{ + Emix_Sink *sink = info; + const Eina_List *l; + + if (type == EMIX_SINK_REMOVED_EVENT) + { + if (sink == _sink_default) + { + l = emix_sinks_get(); + if (l) + _sink_default = l->data; + else + _sink_default = NULL; + if (emix_config_save_get()) e_config_save_queue(); + _backend_changed(); + } + } + else if (type == EMIX_SINK_CHANGED_EVENT) + { + if (_sink_default == sink) + { + int vol; + + _backend_changed(); + if (sink->mute || !sink->volume.channel_count) + vol = 0; + else + vol = sink->volume.volumes[0]; + + _notify(vol); + } + } + else + { + DBG("Sink added"); + } + /* + Only safe the state if we are not in init mode, + If we are in init mode, this is a result of the restore call. + Restore iterates over a list of sinks which would get deleted in the + save_state_get call. + */ + if (!_backend_init_flag) + { + emix_config_save_state_get(); + if (emix_config_save_get()) e_config_save_queue(); + ecore_event_add(E_EVENT_MIXER_SINKS_CHANGED, NULL, NULL, NULL); + } +} + +static void +_disconnected(void) +{ + E_Client_Volume_Sink *sink; + + EINA_LIST_FREE(_client_sinks, sink) + { + e_client_volume_sink_del(sink); + } + _sink_default = NULL; + _backend_changed(); +} + + +static void +_ready(void) +{ + _backend_init_flag = EINA_TRUE; + if (emix_sink_default_support()) + _sink_default = emix_sink_default_get(); + else + { + if (emix_sinks_get()) + _sink_default = emix_sinks_get()->data; + } + + if (emix_config_save_get()) + { + Emix_Sink *s; + const char *sinkname; + + sinkname = emix_config_save_sink_get(); + if (sinkname) + { + Eina_List *sinks = (Eina_List *)emix_sinks_get(); + Eina_List *l; + + EINA_LIST_FOREACH(sinks, l, s) + { + if ((s->name) && (!strcmp(s->name, sinkname))) + { + _sink_default = s; + break; + } + } + } + emix_config_save_state_restore(); + } + + _backend_changed(); + _backend_init_flag = EINA_FALSE; +} + +static void +_sink_input_get(int *volume, Eina_Bool *muted, void *data) +{ + Emix_Sink_Input *input; + + input = data; + + if (input->volume.channel_count > 0) + { + if (volume) *volume = input->volume.volumes[0]; + } + if (muted) *muted = input->mute; +} + +static void +_sink_input_set(int volume, Eina_Bool muted, void *data) +{ + Emix_Sink_Input *input; + + input = data; + + VOLSET(volume, input->volume, input, emix_sink_input_volume_set); + emix_sink_input_mute_set(input, muted); +} + +static int +_sink_input_min_get(void *data EINA_UNUSED) +{ + return 0; +} + +static int +_sink_input_max_get(void *data EINA_UNUSED) +{ + return emix_max_volume_get(); +} + +static const char * +_sink_input_name_get(void *data) +{ + Emix_Sink_Input *input; + + input = data; + return input->name; +} + +static pid_t +_get_ppid(pid_t pid) +{ + int fd; + char buf[128]; + char *s; + pid_t ppid; + + /* Open the status info process file provided by kernel to get the parent + * process id. 'man 5 proc' and go to /proc/[pid]/stat to get information + * about the content of this file. + */ + snprintf(buf, sizeof(buf), "/proc/%d/stat", pid); + fd = open(buf, O_RDONLY); + if (fd == -1) + { + ERR("Can't open %s, maybee the process exited.", buf); + return -1; + } + if ((read(fd, buf, sizeof(buf))) < 4) + { + close(fd); + return -1; + } + buf[sizeof(buf) - 1] = 0; + s = strrchr(buf, ')'); + s += 3; + ppid = atoi(s); + close(fd); + return ppid; +} + +static void +_sink_input_event(int type, Emix_Sink_Input *input) +{ + Eina_List *clients, *l, *ll; + E_Client *ec; + E_Client_Volume_Sink *sink; + pid_t pid; + Eina_Bool found = EINA_FALSE; + + switch (type) + { + case EMIX_SINK_INPUT_ADDED_EVENT: + pid = input->pid; + for (;;) + { + if ((pid <= 1) || (pid == getpid())) return; + clients = e_client_focus_stack_get(); + EINA_LIST_FOREACH(clients, l, ec) + { + if ((ec->netwm.pid == pid) && (!ec->parent)) + { + DBG("Sink found the client %s", + e_client_util_name_get(ec)); + sink = e_client_volume_sink_new(_sink_input_get, + _sink_input_set, + _sink_input_min_get, + _sink_input_max_get, + _sink_input_name_get, + input); + e_client_volume_sink_append(ec, sink); + _client_sinks = eina_list_append(_client_sinks, sink); + found = EINA_TRUE; + } + } + if (found) break; + pid = _get_ppid(pid); + } + break; + case EMIX_SINK_INPUT_REMOVED_EVENT: + EINA_LIST_FOREACH_SAFE(_client_sinks, l, ll, sink) + { + if (sink->data == input) + { + e_client_volume_sink_del(sink); + _client_sinks = eina_list_remove_list(_client_sinks, l); + } + } + break; + case EMIX_SINK_INPUT_CHANGED_EVENT: + EINA_LIST_FOREACH(_client_sinks, l, sink) + { + if (sink->data == input) + { + e_client_volume_sink_update(sink); + } + } + break; + } +} + +static void +_events_cb(void *data EINA_UNUSED, enum Emix_Event type, void *event_info) +{ + switch (type) + { + case EMIX_SINK_ADDED_EVENT: + case EMIX_SINK_CHANGED_EVENT: + case EMIX_SINK_REMOVED_EVENT: + _sink_event(type, event_info); + break; + case EMIX_DISCONNECTED_EVENT: + _disconnected(); + break; + case EMIX_READY_EVENT: + _ready(); + break; + case EMIX_SINK_INPUT_ADDED_EVENT: + case EMIX_SINK_INPUT_REMOVED_EVENT: + case EMIX_SINK_INPUT_CHANGED_EVENT: + _sink_input_event(type, event_info); + break; + + default: + break; + } +} + +static Eina_Bool +_desklock_cb(void *data EINA_UNUSED, int type EINA_UNUSED, void *info) +{ + E_Event_Desklock *ev = info; + static Eina_Bool _was_mute = EINA_FALSE; + + if (emix_config_desklock_mute_get() == EINA_FALSE) + return ECORE_CALLBACK_PASS_ON; + + if (ev->on) + { + if (_sink_default) + { + _was_mute = _sink_default->mute; + if (!_was_mute) + emix_sink_mute_set((Emix_Sink *)_sink_default, EINA_TRUE); + } + } + else + { + if (_sink_default) + { + if (!_was_mute) + emix_sink_mute_set((Emix_Sink *)_sink_default, EINA_FALSE); + } + } + + return ECORE_CALLBACK_PASS_ON; +} + +static void +_emix_backend_changed(const char *backend, void *data EINA_UNUSED) +{ + _disconnected(); + + if (emix_backend_set(backend) == EINA_FALSE) + ERR("Could not load backend: %s", backend); +} + +static void +_bd_hook_volume_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) +{ + E_Client *ec; + + ec = data; + + e_client_volume_set(ec, elm_slider_value_get(obj)); +} + +static void +_bd_hook_volume_drag_stop(void *data, Evas_Object *obj EINA_UNUSED, void *event_info EINA_UNUSED) +{ + E_Client *ec; + + ec = data; + + elm_slider_value_set(obj, ec->volume); +} + + +static void +_bd_hook_mute_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) +{ + E_Client *ec; + + ec = data; + + e_client_volume_mute_set(ec, elm_check_state_get(obj)); +} + +static void +_bd_hook_sink_volume_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) +{ + E_Client_Volume_Sink *sink; + Evas_Object *check; + + sink = data; + + check = evas_object_data_get(obj, "e_sink_check"); + + e_client_volume_sink_set(sink, + elm_slider_value_get(obj), + elm_check_state_get(check)); +} + +static void +_bd_hook_sink_volume_drag_stop(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) +{ + E_Client_Volume_Sink *sink; + Evas_Object *check; + Eina_Bool mute; + int vol; + + sink = data; + + check = evas_object_data_get(obj, "e_sink_check"); + + e_client_volume_sink_get(sink, &vol, &mute); + elm_slider_value_set(obj, vol); + elm_check_state_set(check, mute); +} + + +static void +_bd_hook_sink_mute_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) +{ + E_Client_Volume_Sink *sink; + Evas_Object *slider; + + sink = data; + slider = evas_object_data_get(obj, "e_sink_volume"); + + e_client_volume_sink_set(sink, + elm_slider_value_get(slider), + elm_check_state_get(obj)); +} + +static Eina_Bool +_e_client_volume_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) +{ + E_Event_Client *ev; + Client_Mixer *cm; + E_Client_Volume_Sink *sink; + Evas_Object *o; + Eina_List *l; + + ev = event; + + EINA_LIST_FOREACH(_client_mixers, l, cm) + { + if (cm->ec == ev->ec) + { + elm_slider_value_set(cm->volume, cm->ec->volume); + EINA_LIST_FOREACH(cm->sinks, l, o) + { + int volume; + sink = evas_object_data_get(o, "e_sink"); + e_client_volume_sink_get(sink, &volume, NULL); + elm_slider_value_set(o, volume); + } + break; + } + } + + return ECORE_CALLBACK_PASS_ON; +} + +static Eina_Bool +_e_client_mute_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) +{ + E_Event_Client *ev; + Client_Mixer *cm; + E_Client_Volume_Sink *sink; + Evas_Object *o, *check; + Eina_List *l; + Eina_Bool mute; + + ev = event; + + EINA_LIST_FOREACH(_client_mixers, l, cm) + { + if (cm->ec == ev->ec) + { + elm_check_state_set(cm->mute, !!cm->ec->mute); + elm_object_disabled_set(cm->volume, !!cm->ec->mute); + EINA_LIST_FOREACH(cm->sinks, l, o) + { + sink = evas_object_data_get(o, "e_sink"); + check = evas_object_data_get(o, "e_sink_check"); + e_client_volume_sink_get(sink, NULL, &mute); + elm_check_state_set(check, mute); + elm_object_disabled_set(o, mute); + } + break; + } + } + + return ECORE_CALLBACK_PASS_ON; +} + +static void +_e_client_mixer_sink_append(E_Client_Volume_Sink *sink, Client_Mixer *cm) +{ + Evas_Object *lbl, *slider, *check, *sep; + int volume; + int min, max; + Eina_Bool mute; + + min = e_client_volume_sink_min_get(sink); + max = e_client_volume_sink_max_get(sink); + e_client_volume_sink_get(sink, &volume, &mute); + + sep = elm_separator_add(cm->bx); + elm_separator_horizontal_set(sep, EINA_TRUE); + evas_object_size_hint_weight_set(sep, 0.0, EVAS_HINT_EXPAND); + evas_object_size_hint_align_set(sep, EVAS_HINT_FILL, EVAS_HINT_FILL); + elm_box_pack_end(cm->bx, sep); + evas_object_show(sep); + + lbl = elm_label_add(cm->bx); + elm_object_text_set(lbl, e_client_volume_sink_name_get(sink)); + evas_object_size_hint_align_set(lbl, 0.0, EVAS_HINT_FILL); + elm_box_pack_end(cm->bx, lbl); + evas_object_show(lbl); + + slider = elm_slider_add(cm->bx); + elm_slider_horizontal_set(slider, EINA_TRUE); + elm_slider_min_max_set(slider, min, max); + elm_slider_span_size_set(slider, max * elm_config_scale_get()); + elm_slider_unit_format_set(slider, "%.0f"); + elm_slider_indicator_format_set(slider, "%.0f"); + evas_object_size_hint_weight_set(slider, 0.0, EVAS_HINT_EXPAND); + evas_object_size_hint_align_set(slider, EVAS_HINT_FILL, EVAS_HINT_FILL); + elm_slider_value_set(slider, volume); + evas_object_smart_callback_add(slider, "changed", + _bd_hook_sink_volume_changed, sink); + evas_object_smart_callback_add(slider, "slider,drag,stop", + _bd_hook_sink_volume_drag_stop, sink); + elm_box_pack_end(cm->bx, slider); + evas_object_show(slider); + + check = elm_check_add(cm->bx); + elm_object_text_set(check, _("Mute")); + evas_object_size_hint_align_set(check, 0.0, EVAS_HINT_FILL); + elm_check_state_set(check, !!mute); + elm_object_disabled_set(slider, !!mute); + evas_object_smart_callback_add(check, "changed", + _bd_hook_sink_mute_changed, sink); + + elm_box_pack_end(cm->bx, check); + evas_object_show(check); + + evas_object_data_set(slider, "e_sink", sink); + evas_object_data_set(slider, "e_sink_check", check); + evas_object_data_set(slider, "e_sink_label", lbl); + evas_object_data_set(slider, "e_sink_separator", sep); + evas_object_data_set(check, "e_sink_volume", slider); + cm->sinks = eina_list_append(cm->sinks, slider); +} + +static Eina_Bool +_e_client_volume_sink_add(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) +{ + E_Event_Client_Volume_Sink *ev; + Client_Mixer *cm; + Eina_List *l; + + ev = event; + + EINA_LIST_FOREACH(_client_mixers, l, cm) + { + if (cm->ec == ev->ec) + { + _e_client_mixer_sink_append(ev->sink, cm); + } + } + return ECORE_CALLBACK_PASS_ON; +} + +static Eina_Bool +_e_client_volume_sink_del(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) +{ + E_Event_Client_Volume_Sink *ev; + E_Client_Volume_Sink *sink; + Client_Mixer *cm; + Evas_Object *o, *lbl, *check, *sep; + Eina_List *l; + + ev = event; + + EINA_LIST_FOREACH(_client_mixers, l, cm) + { + if (cm->ec == ev->ec) + { + EINA_LIST_FOREACH(cm->sinks, l, o) + { + sink = evas_object_data_get(o, "e_sink"); + if (sink == ev->sink) + { + lbl = evas_object_data_get(o, "e_sink_label"); + check = evas_object_data_get(o, "e_sink_check"); + sep = evas_object_data_get(o, "e_sink_separator"); + evas_object_del(sep); + evas_object_del(lbl); + evas_object_del(o); + evas_object_del(check); + cm->sinks = eina_list_remove_list(cm->sinks, l); + } + } + break; + } + } + return ECORE_CALLBACK_PASS_ON; +} + +static Eina_Bool +_e_client_volume_sink_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) +{ + E_Event_Client_Volume_Sink *ev; + Client_Mixer *cm; + E_Client_Volume_Sink *sink; + Evas_Object *o, *check; + Eina_List *l; + int volume; + Eina_Bool mute; + + ev = event; + + EINA_LIST_FOREACH(_client_mixers, l, cm) + { + if (cm->ec == ev->ec) + { + EINA_LIST_FOREACH(cm->sinks, l, o) + { + sink = evas_object_data_get(o, "e_sink"); + if (sink != ev->sink) continue; + check = evas_object_data_get(o, "e_sink_check"); + e_client_volume_sink_get(sink, &volume, &mute); + elm_slider_value_set(o, volume); + elm_object_disabled_set(o, mute); + elm_check_state_set(check, mute); + } + break; + } + } + + return ECORE_CALLBACK_PASS_ON; +} + +static void +_client_mixer_del(void *data, Evas *e EINA_UNUSED, Evas_Object *obj EINA_UNUSED, void *event_info EINA_UNUSED) +{ + Client_Mixer *cm; + + cm = data; + + _client_mixers = eina_list_remove(_client_mixers, cm); + free(cm); +} + +static Eina_Bool +_e_client_add(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) +{ + E_Event_Client *ev; + Eina_List *l; + Emix_Sink_Input *input; + pid_t pid; + E_Client_Volume_Sink *sink; + + ev = event; + + if (ev->ec->parent) return ECORE_CALLBACK_PASS_ON; + EINA_LIST_FOREACH((Eina_List *)emix_sink_inputs_get(), l, input) + { + pid = input->pid; + while (42) + { + if (pid <= 1 || pid == getpid()) return ECORE_CALLBACK_PASS_ON; + if (ev->ec->netwm.pid == pid) + { + DBG("Client(%s) found a sink input", + e_client_util_name_get(ev->ec)); + sink = e_client_volume_sink_new(_sink_input_get, + _sink_input_set, + _sink_input_min_get, + _sink_input_max_get, + _sink_input_name_get, + input); + e_client_volume_sink_append(ev->ec, sink); + _client_sinks = eina_list_append(_client_sinks, sink); + return ECORE_CALLBACK_PASS_ON; + } + pid = _get_ppid(pid); + } + } + return ECORE_CALLBACK_PASS_ON; +} + +static Eina_Bool +_e_client_remove(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) +{ + E_Event_Client *ev; + Client_Mixer *cm; + Eina_List *l; + + ev = event; + + EINA_LIST_FOREACH(_client_mixers, l, cm) + { + if (cm->ec == ev->ec) + { + evas_object_event_callback_del_full(cm->win, EVAS_CALLBACK_DEL, + _client_mixer_del, cm); + evas_object_del(cm->win); + _client_mixers = eina_list_remove_list(_client_mixers, l); + free(cm); + break; + } + } + + return ECORE_CALLBACK_PASS_ON; +} + +static void +_bd_hook_cb(void *data, E_Menu *m EINA_UNUSED, E_Menu_Item *it EINA_UNUSED) +{ + E_Client *ec; + Client_Mixer *cm; + E_Client_Volume_Sink *sink; + Evas_Object *win, *popup, *bx, *o; + Eina_List *l; + int w, h; + + ec = data; + + EINA_LIST_FOREACH(_client_mixers, l, cm) + { + if (cm->ec == ec) + return; + } + cm = E_NEW(Client_Mixer, 1); + cm->ec = ec; + + win = elm_popup_add(e_comp->elm); + elm_popup_allow_events_set(win, EINA_TRUE); + + bx = elm_box_add(win); + elm_box_horizontal_set(bx, EINA_FALSE); + elm_object_content_set(win, bx); + evas_object_size_hint_weight_set(bx, EVAS_HINT_EXPAND, EVAS_HINT_EXPAND); + cm->bx = bx; + + o = elm_label_add(bx); + elm_object_text_set(o, _("Main")); + evas_object_size_hint_align_set(o, 0.0, EVAS_HINT_FILL); + elm_box_pack_end(bx, o); + evas_object_show(o); + + o = elm_slider_add(bx); + elm_slider_horizontal_set(o, EINA_TRUE); + elm_slider_min_max_set(o, ec->volume_min, ec->volume_max); + elm_slider_span_size_set(o, ec->volume_max * elm_config_scale_get()); + elm_slider_unit_format_set(o, "%.0f"); + elm_slider_indicator_format_set(o, "%.0f"); + evas_object_size_hint_weight_set(o, 0.0, EVAS_HINT_EXPAND); + evas_object_size_hint_align_set(o, EVAS_HINT_FILL, EVAS_HINT_FILL); + elm_slider_value_set(o, ec->volume); + evas_object_smart_callback_add(o, "changed", _bd_hook_volume_changed, ec); + evas_object_smart_callback_add(o, "slider,drag,stop", + _bd_hook_volume_drag_stop, ec); + elm_box_pack_end(bx, o); + evas_object_show(o); + cm->volume = o; + + o = elm_check_add(bx); + elm_object_text_set(o, _("Mute")); + evas_object_size_hint_align_set(o, 0.0, EVAS_HINT_FILL); + elm_check_state_set(o, !!ec->mute); + elm_object_disabled_set(o, !!ec->mute); + evas_object_smart_callback_add(o, "changed", _bd_hook_mute_changed, ec); + elm_box_pack_end(bx, o); + evas_object_show(o); + cm->mute = o; + + EINA_LIST_FOREACH(ec->sinks, l, sink) + { + _e_client_mixer_sink_append(sink, cm); + } + + evas_object_show(bx); + evas_object_size_hint_min_get(bx, &w, &h); + evas_object_resize(win, w, h); + evas_object_show(win); + popup = e_comp_object_util_add(win, E_COMP_OBJECT_TYPE_NONE); + evas_object_layer_set(popup, E_LAYER_POPUP); + e_comp_object_util_center_on_zone(popup, ec->zone); + evas_object_show(popup); + e_comp_object_util_autoclose(popup, NULL, NULL, NULL); + _client_mixers = eina_list_append(_client_mixers, cm); + evas_object_event_callback_add(popup, EVAS_CALLBACK_DEL, _client_mixer_del, cm); + cm->win = popup; +} + +static void +_bd_hook(void *data EINA_UNUSED, E_Client *ec) +{ + E_Menu_Item *it; + E_Menu *m; + Eina_List *l; + + if (!ec->volume_control_enabled) return; + m = ec->border_menu; + + /* Find the first separator and add us below him */ + EINA_LIST_FOREACH(m->items, l, it) + { + if (it->separator) break; + } + if ((!it) || (!it->separator)) return; + + it = e_menu_item_new_relative(m, it); + e_menu_item_label_set(it, _("Volume")); + e_util_menu_item_theme_icon_set(it, "preferences-desktop-mixer"); + e_menu_item_callback_set(it, _bd_hook_cb, ec); + + it = e_menu_item_new_relative(m, it); + e_menu_item_separator_set(it, EINA_TRUE); +} + +static Eina_Bool +_emixer_del_cb(void *data EINA_UNUSED, int type EINA_UNUSED, void *info EINA_UNUSED) +{ + _emixer_exe = NULL; + if (_emix_exe_event_del_handler) + { + ecore_event_handler_del(_emix_exe_event_del_handler); + _emix_exe_event_del_handler = NULL; + } + return EINA_TRUE; +} + +static void +_backend_changed(void) +{ + ecore_event_add(E_EVENT_MIXER_BACKEND_CHANGED, NULL, NULL, NULL); +} + + +EINTERN int +backend_init(void) +{ + Eina_List *l; + const char *backend; + Eina_Bool backend_loaded = EINA_FALSE; + + if (_volume_init++) return _volume_init; + _backend_log_domain = eina_log_domain_register("mixer_backend", EINA_COLOR_RED); + + DBG("Init mixer backend"); + EINA_SAFETY_ON_FALSE_RETURN_VAL(emix_init(), --_volume_init); + DBG("Init mixer backend config"); + emix_config_init(_emix_backend_changed, NULL); + DBG("Init mixer backend callback"); + emix_event_callback_add(_events_cb, NULL); + + backend = emix_config_backend_get(); + if (backend && emix_backend_set(backend)) + backend_loaded = EINA_TRUE; + else + { + if (backend) + WRN("Could not load %s, trying another one ...", backend); + EINA_LIST_FOREACH((Eina_List *)emix_backends_available(), l, + backend) + { + if (emix_backend_set(backend) == EINA_TRUE) + { + DBG("Loaded backend: %s!", backend); + backend_loaded = EINA_TRUE; + emix_config_backend_set(backend); + break; + } + } + } + + if (!backend_loaded) goto err; + + if (emix_sink_default_support()) + _sink_default = emix_sink_default_get(); + + _actions_register(); + + _border_hook = e_int_client_menu_hook_add(_bd_hook, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_DESKLOCK, + _desklock_cb, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME, + _e_client_volume_changed, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_MUTE, + _e_client_mute_changed, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_UNMUTE, + _e_client_mute_changed, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_ADD, + _e_client_add, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_REMOVE, + _e_client_remove, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_ADD, + _e_client_volume_sink_add, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_DEL, + _e_client_volume_sink_del, NULL); + E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_CHANGED, + _e_client_volume_sink_changed, NULL); + + E_EVENT_MIXER_BACKEND_CHANGED = ecore_event_type_new(); + E_EVENT_MIXER_SINKS_CHANGED = ecore_event_type_new(); + + return _volume_init; +err: + emix_config_shutdown(); + emix_shutdown(); + return --_volume_init; +} + +EINTERN int +backend_shutdown(void) +{ + E_Client_Volume_Sink *sink; + Client_Mixer *cm; + + if (!--_volume_init) return _volume_init; + + E_FREE_LIST(_client_handlers, ecore_event_handler_del); + EINA_LIST_FREE(_client_mixers, cm) + { + evas_object_event_callback_del_full(cm->win, EVAS_CALLBACK_DEL, + _client_mixer_del, cm); + evas_object_del(cm->win); + free(cm); + } + + e_int_client_menu_hook_del(_border_hook); + _actions_unregister(); + + EINA_LIST_FREE(_client_sinks, sink) + e_client_volume_sink_del(sink); + + if (_emix_exe_event_del_handler) + { + ecore_event_handler_del(_emix_exe_event_del_handler); + _emix_exe_event_del_handler = NULL; + } + + + emix_event_callback_del(_events_cb); + emix_shutdown(); + emix_config_shutdown(); + + eina_log_domain_unregister(_backend_log_domain); + return _volume_init; +} + +EINTERN void +backend_emixer_exec(void) +{ + if (_emixer_exe) return; + + _emixer_exe = e_util_exe_safe_run("emixer", NULL); + if (_emix_exe_event_del_handler) + ecore_event_handler_del(_emix_exe_event_del_handler); + _emix_exe_event_del_handler = + ecore_event_handler_add(ECORE_EXE_EVENT_DEL, _emixer_del_cb, NULL); +} + +EINTERN void +backend_volume_set(unsigned int volume) +{ + EINA_SAFETY_ON_NULL_RETURN(_sink_default); + DBG("Sink default mute set %d", volume); + + VOLSET(volume, ((Emix_Sink *)_sink_default)->volume, + (Emix_Sink *)_sink_default, emix_sink_volume_set); + emix_config_save_state_get(); + if (emix_config_save_get()) e_config_save_queue(); +} + +EINTERN unsigned int +backend_volume_get(void) +{ + unsigned int volume = 0, i; + + EINA_SAFETY_ON_NULL_RETURN_VAL(_sink_default, 0); + for (i = 0; i < _sink_default->volume.channel_count; i++) + volume += _sink_default->volume.volumes[i]; + if (_sink_default->volume.channel_count) + volume = volume / _sink_default->volume.channel_count; + + DBG("Sink default volume get %d", volume); + return volume; +} + +EINTERN void +backend_volume_decrease(void) +{ + _volume_decrease_cb(NULL, NULL); +} + +EINTERN void +backend_volume_increase(void) +{ + _volume_increase_cb(NULL, NULL); +} + +EINTERN void +backend_mute_set(Eina_Bool mute) +{ + EINA_SAFETY_ON_NULL_RETURN(_sink_default); + + DBG("Sink default mute set %d", mute); + emix_sink_mute_set((Emix_Sink *)_sink_default, mute); + emix_config_save_state_get(); + if (emix_config_save_get()) e_config_save_queue(); +} + +EINTERN Eina_Bool +backend_mute_get(void) +{ + EINA_SAFETY_ON_NULL_RETURN_VAL(_sink_default, EINA_FALSE); + DBG("Mute get %d", _sink_default->mute); + return _sink_default->mute; +} + +EINTERN void +backend_sink_default_set(const Emix_Sink *s) +{ + if (_sink_default != s) + { + DBG("Sink default set %s", s->name); + _sink_default = s; + if (s) emix_config_save_sink_set(s->name); + _backend_changed(); + } +} + +EINTERN const Emix_Sink * +backend_sink_default_get(void) +{ + return _sink_default; +} + diff --git a/src/modules/mixer/gadget/backend.h b/src/modules/mixer/gadget/backend.h new file mode 100644 index 000000000..9336ef111 --- /dev/null +++ b/src/modules/mixer/gadget/backend.h @@ -0,0 +1,24 @@ +#ifndef MIXER_GADGET_BACKEND_ +#define MIXER_GADGET_BACKEND_ + +typedef void (*Backend_Hook)(void); + +EINTERN extern int E_EVENT_MIXER_BACKEND_CHANGED; +EINTERN extern int E_EVENT_MIXER_SINKS_CHANGED; + +EINTERN int backend_init(void); +EINTERN int backend_shutdown(void); + +EINTERN void backend_emixer_exec(void); + +EINTERN void backend_volume_set(unsigned int volume); +EINTERN unsigned int backend_volume_get(void); +EINTERN void backend_volume_decrease(void); +EINTERN void backend_volume_increase(void); +EINTERN void backend_mute_set(Eina_Bool mute); +EINTERN Eina_Bool backend_mute_get(void); + +EINTERN void backend_sink_default_set(const Emix_Sink *s); +EINTERN const Emix_Sink *backend_sink_default_get(void); + +#endif /* MIXER_GADGET_BACKEND */ diff --git a/src/modules/mixer/gadget/mixer.c b/src/modules/mixer/gadget/mixer.c index 69a59a69e..2376c182c 100644 --- a/src/modules/mixer/gadget/mixer.c +++ b/src/modules/mixer/gadget/mixer.c @@ -1,40 +1,14 @@ #include "mixer.h" - -#define VOLUME_STEP 5 - -#define BARRIER_CHECK(old_val, new_val) \ - (old_val > EMIX_VOLUME_BARRIER - 20) && \ - (old_val <= EMIX_VOLUME_BARRIER) && \ - (new_val > EMIX_VOLUME_BARRIER) && \ - (new_val < EMIX_VOLUME_BARRIER + 20) - -static Eina_Bool init; -static Eina_List *_client_sinks = NULL; -static Eina_List *_client_mixers = NULL; -static Eina_List *_client_handlers = NULL; +#include "backend.h" typedef struct _Context Context; struct _Context { char *theme; - Ecore_Exe *emixer; - Ecore_Event_Handler *desklock_handler; - Ecore_Event_Handler *emix_event_handler; - const Emix_Sink *sink_default; E_Module *module; Eina_List *instances; E_Menu *menu; unsigned int notification_id; - - struct - { - E_Action *incr; - E_Action *decr; - E_Action *mute; - E_Action *incr_app; - E_Action *decr_app; - E_Action *mute_app; - } actions; }; typedef struct _Instance Instance; @@ -48,61 +22,10 @@ struct _Instance Evas_Object *slider; Evas_Object *check; E_Gadget_Site_Orient orient; - Eina_Bool mute; -}; - -typedef struct _Client_Mixer Client_Mixer; -struct _Client_Mixer -{ - Evas_Object *win; - Evas_Object *volume; - Evas_Object *mute; - E_Client *ec; - Evas_Object *bx; - Eina_List *sinks; }; static Context *gmixer_context = NULL; - -static void -_notify_cb(void *data EINA_UNUSED, unsigned int id) -{ - gmixer_context->notification_id = id; -} - -static void -_notify(const int val) -{ - E_Notification_Notify n; - char *icon, buf[56]; - int ret; - - if (!emix_config_notify_get()) return; - - memset(&n, 0, sizeof(E_Notification_Notify)); - if (val < 0) return; - - ret = snprintf(buf, (sizeof(buf) - 1), "%s: %d%%", _("New volume"), val); - if ((ret < 0) || ((unsigned int)ret > sizeof(buf))) - return; - //Names are taken from FDO icon naming scheme - if (val == 0) - icon = "audio-volume-muted"; - else if ((val > 33) && (val < 66)) - icon = "audio-volume-medium"; - else if (val <= 33) - icon = "audio-volume-low"; - else - icon = "audio-volume-high"; - - n.app_name = _("Mixer"); - n.replaces_id = gmixer_context->notification_id; - n.icon.icon = icon; - n.summary = _("Volume changed"); - n.body = buf; - n.timeout = 2000; - e_notification_client_send(&n, _notify_cb, NULL); -} +static Eina_List *_handlers = NULL; static void _mixer_popup_update(Instance *inst, int mute, int vol) @@ -117,13 +40,15 @@ _mixer_gadget_update(void) Edje_Message_Int_Set *msg; Instance *inst; Eina_List *l; + const Eina_List *ll; + Elm_Object_Item *it; EINA_LIST_FOREACH(gmixer_context->instances, l, inst) { msg = alloca(sizeof(Edje_Message_Int_Set) + (2 * sizeof(int))); msg->count = 3; - if (!gmixer_context->sink_default) + if (!backend_sink_default_get()) { msg->val[0] = EINA_FALSE; msg->val[1] = 0; @@ -133,246 +58,31 @@ _mixer_gadget_update(void) } else { - int vol = 0; - unsigned int i = 0; - for (i = 0; i < - gmixer_context->sink_default->volume.channel_count; i++) - vol += gmixer_context->sink_default->volume.volumes[i]; - if (gmixer_context->sink_default->volume.channel_count) - vol /= gmixer_context->sink_default->volume.channel_count; - msg->val[0] = gmixer_context->sink_default->mute; - msg->val[1] = vol; + msg->val[0] = backend_mute_get(); + msg->val[1] = backend_volume_get(); msg->val[2] = msg->val[1]; if (inst->popup) - _mixer_popup_update(inst, gmixer_context->sink_default->mute, - msg->val[1]); + _mixer_popup_update(inst, msg->val[0], msg->val[1]); } edje_object_message_send(elm_layout_edje_get(inst->o_mixer), EDJE_MESSAGE_INT_SET, 0, msg); elm_layout_signal_emit(inst->o_mixer, "e,action,volume,change", "e"); + + if (inst->list) + { + EINA_LIST_FOREACH(elm_list_items_get(inst->list), ll, it) + { + if (backend_sink_default_get() == elm_object_item_data_get(it)) + elm_list_item_selected_set(it, EINA_TRUE); + } + } } } -static void -_volume_increase_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - unsigned int i; - Emix_Volume volume; - - EINA_SAFETY_ON_NULL_RETURN(gmixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)gmixer_context->sink_default; - - if (!s->volume.channel_count) return; - - if (BARRIER_CHECK(s->volume.volumes[0], s->volume.volumes[0] + VOLUME_STEP)) - return; - - volume.channel_count = s->volume.channel_count; - volume.volumes = calloc(s->volume.channel_count, sizeof(int)); - for (i = 0; i < volume.channel_count; i++) - { - if (s->volume.volumes[i] < (emix_max_volume_get()) - VOLUME_STEP) - volume.volumes[i] = s->volume.volumes[i] + VOLUME_STEP; - else if (s->volume.volumes[i] < emix_max_volume_get()) - volume.volumes[i] = emix_max_volume_get(); - else - volume.volumes[i] = s->volume.volumes[i]; - } - - emix_sink_volume_set(s, volume); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - free(volume.volumes); -} - -static void -_volume_decrease_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - unsigned int i; - Emix_Volume volume; - - EINA_SAFETY_ON_NULL_RETURN(gmixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)gmixer_context->sink_default; - volume.channel_count = s->volume.channel_count; - volume.volumes = calloc(s->volume.channel_count, sizeof(int)); - for (i = 0; i < volume.channel_count; i++) - { - if (s->volume.volumes[i] > VOLUME_STEP) - volume.volumes[i] = s->volume.volumes[i] - VOLUME_STEP; - else if (s->volume.volumes[i] < VOLUME_STEP) - volume.volumes[i] = 0; - else - volume.volumes[i] = s->volume.volumes[i]; - } - - emix_sink_volume_set(s, volume); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - free(volume.volumes); -} - -static void -_volume_mute_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - EINA_SAFETY_ON_NULL_RETURN(gmixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)gmixer_context->sink_default; - Eina_Bool mute = !s->mute; - emix_sink_mute_set(s, mute); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); -} - -static void -_volume_increase_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - E_Client *ec; - - ec = e_client_focused_get(); - if (ec && ec->volume_control_enabled) - { - e_client_volume_set(ec, ec->volume + VOLUME_STEP); - } -} - -static void -_volume_decrease_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - E_Client *ec; - - ec = e_client_focused_get(); - if (ec && ec->volume_control_enabled) - { - e_client_volume_set(ec, ec->volume - VOLUME_STEP); - } -} - -static void -_volume_mute_app_cb(E_Object *obj EINA_UNUSED, const char *params EINA_UNUSED) -{ - E_Client *ec; - - ec = e_client_focused_get(); - if (ec && ec->volume_control_enabled) - { - e_client_volume_mute_set(ec, !ec->mute); - } -} - -static void -_actions_register(void) -{ - gmixer_context->actions.incr = e_action_add("gadget_volume_increase"); - if (gmixer_context->actions.incr) - { - gmixer_context->actions.incr->func.go = _volume_increase_cb; - e_action_predef_name_set("Mixer Gadget", _("Increase Volume"), - "gadget_volume_increase", NULL, NULL, 0); - } - - gmixer_context->actions.decr = e_action_add("gadget_volume_decrease"); - if (gmixer_context->actions.decr) - { - gmixer_context->actions.decr->func.go = _volume_decrease_cb; - e_action_predef_name_set("Mixer Gadget", _("Decrease Volume"), - "gadget_volume_decrease", NULL, NULL, 0); - } - - gmixer_context->actions.mute = e_action_add("gadget_volume_mute"); - if (gmixer_context->actions.mute) - { - gmixer_context->actions.mute->func.go = _volume_mute_cb; - e_action_predef_name_set("Mixer Gadget", _("Mute volume"), "gadget_volume_mute", - NULL, NULL, 0); - } - gmixer_context->actions.incr_app = e_action_add("gadget_volume_increase_app"); - if (gmixer_context->actions.incr_app) - { - gmixer_context->actions.incr_app->func.go = _volume_increase_app_cb; - e_action_predef_name_set("Mixer Gadget", - _("Increase Volume of Focused Application"), - "gadget_volume_increase_app", NULL, NULL, 0); - } - gmixer_context->actions.decr_app = e_action_add("gadget_volume_decrease_app"); - if (gmixer_context->actions.decr_app) - { - gmixer_context->actions.decr_app->func.go = _volume_decrease_app_cb; - e_action_predef_name_set("Mixer Gadget", - _("Decrease Volume of Focused Application"), - "gadget_volume_decrease_app", NULL, NULL, 0); - } - gmixer_context->actions.mute_app = e_action_add("gadget_volume_mute_app"); - if (gmixer_context->actions.mute_app) - { - gmixer_context->actions.mute_app->func.go = _volume_mute_app_cb; - e_action_predef_name_set("Mixer Gadget", - _("Mute Volume of Focused Application"), - "gadget_volume_mute_app", NULL, NULL, 0); - } - - e_comp_canvas_keys_ungrab(); - e_comp_canvas_keys_grab(); -} - -static void -_actions_unregister(void) -{ - if (gmixer_context->actions.incr) - { - e_action_predef_name_del("Mixer Gadget", _("Increase Volume")); - e_action_del("gadget_volume_increase"); - gmixer_context->actions.incr = NULL; - } - - if (gmixer_context->actions.decr) - { - e_action_predef_name_del("Mixer Gadget", _("Decrease Volume")); - e_action_del("gadget_volume_decrease"); - gmixer_context->actions.decr = NULL; - } - - if (gmixer_context->actions.mute) - { - e_action_predef_name_del("Mixer Gadget", _("Mute Volume")); - e_action_del("gadget_volume_mute"); - gmixer_context->actions.mute = NULL; - } - - if (gmixer_context->actions.incr_app) - { - e_action_predef_name_del("Mixer Gadget", - _("Increase Volume of Focuse Application")); - e_action_del("gadget_volume_increase_app"); - gmixer_context->actions.incr_app = NULL; - } - - if (gmixer_context->actions.decr_app) - { - e_action_predef_name_del("Mixer Gadget", - _("Decrease Volume of Focuse Application")); - e_action_del("gadget_volume_decrease_app"); - gmixer_context->actions.decr_app = NULL; - } - - if (gmixer_context->actions.mute_app) - { - e_action_predef_name_del("Mixer Gadget", - _("Mute Volume of Focuse Application")); - e_action_del("gadget_volume_mute_app"); - gmixer_context->actions.mute_app = NULL; - } - - e_comp_canvas_keys_ungrab(); - e_comp_canvas_keys_grab(); -} - static Eina_Bool -_emixer_del_cb(void *data EINA_UNUSED, int type EINA_UNUSED, - void *info EINA_UNUSED) +_mixer_backend_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event EINA_UNUSED) { - gmixer_context->emixer = NULL; - if (gmixer_context->emix_event_handler) - ecore_event_handler_del(gmixer_context->emix_event_handler); - - return EINA_TRUE; + _mixer_gadget_update(); + return ECORE_CALLBACK_PASS_ON; } static void @@ -381,29 +91,15 @@ _emixer_exec_cb(void *data, Evas_Object *obj EINA_UNUSED, void *event_info EINA_ Instance *inst = data; elm_ctxpopup_dismiss(inst->popup); - if (gmixer_context->emixer) return; - gmixer_context->emixer = e_util_exe_safe_run("emixer", NULL); - if (gmixer_context->emix_event_handler) - ecore_event_handler_del(gmixer_context->emix_event_handler); - gmixer_context->emix_event_handler = - ecore_event_handler_add(ECORE_EXE_EVENT_DEL, _emixer_del_cb, NULL); + backend_emixer_exec(); } static void -_check_changed_cb(void *data EINA_UNUSED, Evas_Object *obj EINA_UNUSED, +_check_changed_cb(void *data EINA_UNUSED, Evas_Object *obj, void *event EINA_UNUSED) { - EINA_SAFETY_ON_NULL_RETURN(gmixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)gmixer_context->sink_default; - emix_sink_mute_set(s, !s->mute); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - /* - * TODO: is it really necessary ? or it will be update - * with the sink changed hanlder - */ - _mixer_gadget_update(); + backend_mute_set(elm_check_state_get(obj)); } static void @@ -412,13 +108,9 @@ _slider_changed_cb(void *data EINA_UNUSED, Evas_Object *obj, { int val; - EINA_SAFETY_ON_NULL_RETURN(gmixer_context->sink_default); - Emix_Sink *s = (Emix_Sink *)gmixer_context->sink_default; val = (int)elm_slider_value_get(obj); - VOLSET(val, s->volume, s, emix_sink_volume_set); - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); + backend_volume_set(val); } static void @@ -426,9 +118,7 @@ _sink_selected_cb(void *data, Evas_Object *obj EINA_UNUSED, void *event_info EIN { Emix_Sink *s = data; - gmixer_context->sink_default = s; - if (s) emix_config_save_sink_set(s->name); - _mixer_gadget_update(); + backend_sink_default_set(s); } static void @@ -444,6 +134,42 @@ _mixer_popup_deleted(void *data, Evas *e EINA_UNUSED, Evas_Object *obj EINA_UNUS { Instance *inst = data; inst->popup = NULL; + inst->list = NULL; + inst->slider = NULL; + inst->check = NULL; +} + +static Eina_Bool +_mixer_sinks_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event EINA_UNUSED) +{ + Eina_List *l, *ll; + Instance *inst; + + EINA_LIST_FOREACH(gmixer_context->instances, l, inst) + { + if (inst->list) + { + Elm_Object_Item *default_it = NULL; + Emix_Sink *s; + + elm_list_clear(inst->list); + EINA_LIST_FOREACH((Eina_List *)emix_sinks_get(), ll, s) + { + Elm_Object_Item *it; + + it = elm_list_item_append(inst->list, s->name, NULL, NULL, + _sink_selected_cb, s); + if (backend_sink_default_get() == s) + default_it = it; + } + elm_list_go(inst->list); + if (default_it) + elm_list_item_selected_set(default_it, EINA_TRUE); + } + } + + + return ECORE_CALLBACK_PASS_ON; } static void @@ -452,12 +178,7 @@ _popup_new(Instance *inst) Evas_Object *button, *list, *slider, *bx; Emix_Sink *s; Eina_List *l; - int num = 0; Elm_Object_Item *default_it = NULL; - unsigned int volume = 0, i; - - EINA_SAFETY_ON_NULL_RETURN(gmixer_context->sink_default); - unsigned int channels = gmixer_context->sink_default->volume.channel_count; inst->popup = elm_ctxpopup_add(e_comp->elm); elm_object_style_set(inst->popup, "noblock"); @@ -478,17 +199,12 @@ _popup_new(Instance *inst) Elm_Object_Item *it; it = elm_list_item_append(inst->list, s->name, NULL, NULL, _sink_selected_cb, s); - if (gmixer_context->sink_default == s) + if (backend_sink_default_get() == s) default_it = it; - num++; } elm_list_go(inst->list); elm_box_pack_end(list, inst->list); - for (volume = 0, i = 0; i < channels; i++) - volume += gmixer_context->sink_default->volume.volumes[i]; - if (channels) volume = volume / channels; - bx = elm_box_add(e_comp->elm); elm_box_horizontal_set(bx, EINA_TRUE); evas_object_size_hint_weight_set(bx, EVAS_HINT_EXPAND, 0.0); @@ -506,15 +222,14 @@ _popup_new(Instance *inst) evas_object_show(slider); elm_slider_min_max_set(slider, 0.0, emix_max_volume_get()); evas_object_smart_callback_add(slider, "changed", _slider_changed_cb, NULL); - elm_slider_value_set(slider, volume); + elm_slider_value_set(slider, backend_volume_get()); elm_box_pack_end(bx, slider); evas_object_show(slider); - inst->mute = gmixer_context->sink_default->mute; inst->check = elm_check_add(e_comp->elm); evas_object_size_hint_align_set(inst->check, 0.5, EVAS_HINT_FILL); elm_object_text_set(inst->check, _("Mute")); - elm_check_state_pointer_set(inst->check, &(inst->mute)); + elm_check_state_set(inst->check, backend_mute_get()); evas_object_smart_callback_add(inst->check, "changed", _check_changed_cb, NULL); elm_box_pack_end(bx, inst->check); @@ -557,7 +272,7 @@ _mouse_up_cb(void *data, Evas *evas EINA_UNUSED, } else if (ev->button == 2) { - _volume_mute_cb(NULL, NULL); + backend_mute_set(!backend_mute_get()); } } @@ -568,9 +283,9 @@ _mouse_wheel_cb(void *data EINA_UNUSED, Evas *evas EINA_UNUSED, Evas_Event_Mouse_Wheel *ev = event; if (ev->z > 0) - _volume_decrease_cb(NULL, NULL); + backend_volume_decrease(); else if (ev->z < 0) - _volume_increase_cb(NULL, NULL); + backend_volume_increase(); } static Evas_Object * @@ -659,8 +374,6 @@ mixer_gadget_create(Evas_Object *parent, int *id, E_Gadget_Site_Orient orient) if (*id != -1) { - EINA_SAFETY_ON_FALSE_RETURN_VAL(emix_init(), NULL); - if (!mixer_init()) return NULL; } @@ -676,705 +389,35 @@ mixer_gadget_create(Evas_Object *parent, int *id, E_Gadget_Site_Orient orient) return inst->o_main; } -static void -_sink_event(int type, void *info) -{ - Emix_Sink *sink = info; - const Eina_List *l; - - if (type == EMIX_SINK_REMOVED_EVENT) - { - if (sink == gmixer_context->sink_default) - { - l = emix_sinks_get(); - if (l) - gmixer_context->sink_default = l->data; - else - gmixer_context->sink_default = NULL; - if (emix_config_save_get()) e_config_save_queue(); - _mixer_gadget_update(); - } - } - else if (type == EMIX_SINK_CHANGED_EVENT) - { - if (gmixer_context->sink_default == sink) - { - int vol; - - _mixer_gadget_update(); - if (sink->mute || !sink->volume.channel_count) - vol = 0; - else - vol = sink->volume.volumes[0]; - - _notify(vol); - } - } - else - { - DBG("Sink added"); - } - /* - Only safe the state if we are not in init mode, - If we are in init mode, this is a result of the restore call. - Restore iterates over a list of sinks which would get deleted in the - save_state_get call. - */ - if (!init) - { - emix_config_save_state_get(); - if (emix_config_save_get()) e_config_save_queue(); - } -} - -static void -_disconnected(void) -{ - E_Client_Volume_Sink *sink; - - EINA_LIST_FREE(_client_sinks, sink) - { - e_client_volume_sink_del(sink); - } - if (gmixer_context) gmixer_context->sink_default = NULL; - _mixer_gadget_update(); -} - -static void -_ready(void) -{ - init = EINA_TRUE; - if (emix_sink_default_support()) - gmixer_context->sink_default = emix_sink_default_get(); - else - { - if (emix_sinks_get()) - gmixer_context->sink_default = emix_sinks_get()->data; - } - - if (emix_config_save_get()) - { - Emix_Sink *s; - const char *sinkname; - - sinkname = emix_config_save_sink_get(); - if (sinkname) - { - Eina_List *sinks = (Eina_List *)emix_sinks_get(); - Eina_List *l; - - EINA_LIST_FOREACH(sinks, l, s) - { - if ((s->name) && (!strcmp(s->name, sinkname))) - { - gmixer_context->sink_default = s; - break; - } - } - } - emix_config_save_state_restore(); - } - - _mixer_gadget_update(); - init = EINA_FALSE; -} - -static void -_sink_input_get(int *volume, Eina_Bool *muted, void *data) -{ - Emix_Sink_Input *input; - - input = data; - - if (input->volume.channel_count > 0) - { - if (volume) *volume = input->volume.volumes[0]; - } - if (muted) *muted = input->mute; -} - -static void -_sink_input_set(int volume, Eina_Bool muted, void *data) -{ - Emix_Sink_Input *input; - - input = data; - - VOLSET(volume, input->volume, input, emix_sink_input_volume_set); - emix_sink_input_mute_set(input, muted); -} - -static int -_sink_input_min_get(void *data EINA_UNUSED) -{ - return 0; -} - -static int -_sink_input_max_get(void *data EINA_UNUSED) -{ - return emix_max_volume_get(); -} - -static const char * -_sink_input_name_get(void *data) -{ - Emix_Sink_Input *input; - - input = data; - return input->name; -} - -static pid_t -_get_ppid(pid_t pid) -{ - int fd; - char buf[128]; - char *s; - pid_t ppid; - - /* Open the status info process file provided by kernel to get the parent - * process id. 'man 5 proc' and go to /proc/[pid]/stat to get information - * about the content of this file. - */ - snprintf(buf, sizeof(buf), "/proc/%d/stat", pid); - fd = open(buf, O_RDONLY); - if (fd == -1) - { - ERR("Can't open %s, maybee the process exited.", buf); - return -1; - } - if ((read(fd, buf, sizeof(buf))) < 4) - { - close(fd); - return -1; - } - buf[sizeof(buf) - 1] = 0; - s = strrchr(buf, ')'); - s += 3; - ppid = atoi(s); - close(fd); - return ppid; -} - -static void -_sink_input_event(int type, Emix_Sink_Input *input) -{ - Eina_List *clients, *l, *ll; - E_Client *ec; - E_Client_Volume_Sink *sink; - pid_t pid; - Eina_Bool found = EINA_FALSE; - - switch (type) - { - case EMIX_SINK_INPUT_ADDED_EVENT: - pid = input->pid; - for (;;) - { - if (pid <= 1 || pid == getpid()) return; - clients = e_client_focus_stack_get(); - EINA_LIST_FOREACH(clients, l, ec) - { - if ((ec->netwm.pid == pid) && (!ec->parent)) - { - DBG("Sink found the client %s", - e_client_util_name_get(ec)); - sink = e_client_volume_sink_new(_sink_input_get, - _sink_input_set, - _sink_input_min_get, - _sink_input_max_get, - _sink_input_name_get, - input); - e_client_volume_sink_append(ec, sink); - _client_sinks = eina_list_append(_client_sinks, sink); - found = EINA_TRUE; - } - } - if (found) break; - pid = _get_ppid(pid); - } - break; - - case EMIX_SINK_INPUT_REMOVED_EVENT: - EINA_LIST_FOREACH_SAFE(_client_sinks, l, ll, sink) - { - if (sink->data == input) - { - e_client_volume_sink_del(sink); - _client_sinks = eina_list_remove_list(_client_sinks, l); - } - } - break; - - case EMIX_SINK_INPUT_CHANGED_EVENT: - EINA_LIST_FOREACH(_client_sinks, l, sink) - { - if (sink->data == input) - { - e_client_volume_sink_update(sink); - } - } - break; - } -} - -static void -_events_cb(void *data EINA_UNUSED, enum Emix_Event type, void *event_info) -{ - switch (type) - { - case EMIX_SINK_ADDED_EVENT: - case EMIX_SINK_CHANGED_EVENT: - case EMIX_SINK_REMOVED_EVENT: - _sink_event(type, event_info); - break; - - case EMIX_DISCONNECTED_EVENT: - _disconnected(); - break; - - case EMIX_READY_EVENT: - _ready(); - break; - - case EMIX_SINK_INPUT_ADDED_EVENT: - case EMIX_SINK_INPUT_REMOVED_EVENT: - case EMIX_SINK_INPUT_CHANGED_EVENT: - _sink_input_event(type, event_info); - break; - - default: - break; - } -} - -static Eina_Bool -_desklock_cb(void *data EINA_UNUSED, int type EINA_UNUSED, void *info) -{ - E_Event_Desklock *ev = info; - static Eina_Bool _was_mute = EINA_FALSE; - - if (emix_config_desklock_mute_get() == EINA_FALSE) - return ECORE_CALLBACK_PASS_ON; - if (!gmixer_context) - return ECORE_CALLBACK_PASS_ON; - - if (ev->on) - { - if (gmixer_context->sink_default) - { - _was_mute = gmixer_context->sink_default->mute; - if (!_was_mute) - emix_sink_mute_set((Emix_Sink *)gmixer_context->sink_default, EINA_TRUE); - } - } - else - { - if (gmixer_context->sink_default) - { - if (!_was_mute) - emix_sink_mute_set((Emix_Sink *)gmixer_context->sink_default, EINA_FALSE); - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static void -_backend_changed(const char *backend, void *data EINA_UNUSED) -{ - _disconnected(); - - if (emix_backend_set(backend) == EINA_FALSE) - ERR("Could not load backend: %s", backend); -} - -static Eina_Bool -_e_client_volume_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client *ev; - Client_Mixer *cm; - E_Client_Volume_Sink *sink; - Evas_Object *o; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - elm_slider_value_set(cm->volume, cm->ec->volume); - EINA_LIST_FOREACH(cm->sinks, l, o) - { - int volume; - sink = evas_object_data_get(o, "e_sink"); - e_client_volume_sink_get(sink, &volume, NULL); - elm_slider_value_set(o, volume); - } - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static Eina_Bool -_e_client_mute_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client *ev; - Client_Mixer *cm; - E_Client_Volume_Sink *sink; - Evas_Object *o, *check; - Eina_List *l; - Eina_Bool mute; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - elm_check_state_set(cm->mute, !!cm->ec->mute); - elm_object_disabled_set(cm->volume, !!cm->ec->mute); - EINA_LIST_FOREACH(cm->sinks, l, o) - { - sink = evas_object_data_get(o, "e_sink"); - check = evas_object_data_get(o, "e_sink_check"); - e_client_volume_sink_get(sink, NULL, &mute); - elm_check_state_set(check, mute); - elm_object_disabled_set(o, mute); - } - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static void -_bd_hook_sink_volume_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client_Volume_Sink *sink; - Evas_Object *check; - - sink = data; - - check = evas_object_data_get(obj, "e_sink_check"); - - e_client_volume_sink_set(sink, - elm_slider_value_get(obj), - elm_check_state_get(check)); -} - -static void -_bd_hook_sink_volume_drag_stop(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client_Volume_Sink *sink; - Evas_Object *check; - Eina_Bool mute; - int vol; - - sink = data; - - check = evas_object_data_get(obj, "e_sink_check"); - - e_client_volume_sink_get(sink, &vol, &mute); - elm_slider_value_set(obj, vol); - elm_check_state_set(check, mute); -} - -static void -_bd_hook_sink_mute_changed(void *data, Evas_Object *obj, void *event_info EINA_UNUSED) -{ - E_Client_Volume_Sink *sink; - Evas_Object *slider; - - sink = data; - slider = evas_object_data_get(obj, "e_sink_volume"); - - e_client_volume_sink_set(sink, - elm_slider_value_get(slider), - elm_check_state_get(obj)); -} - -static void -_e_client_mixer_sink_append(E_Client_Volume_Sink *sink, Client_Mixer *cm) -{ - Evas_Object *lbl, *slider, *check, *sep; - int volume; - int min, max; - Eina_Bool mute; - - min = e_client_volume_sink_min_get(sink); - max = e_client_volume_sink_max_get(sink); - e_client_volume_sink_get(sink, &volume, &mute); - - sep = elm_separator_add(cm->bx); - elm_separator_horizontal_set(sep, EINA_TRUE); - evas_object_size_hint_weight_set(sep, 0.0, EVAS_HINT_EXPAND); - evas_object_size_hint_align_set(sep, EVAS_HINT_FILL, EVAS_HINT_FILL); - elm_box_pack_end(cm->bx, sep); - evas_object_show(sep); - - lbl = elm_label_add(cm->bx); - elm_object_text_set(lbl, e_client_volume_sink_name_get(sink)); - evas_object_size_hint_align_set(lbl, 0.0, EVAS_HINT_FILL); - elm_box_pack_end(cm->bx, lbl); - evas_object_show(lbl); - - slider = elm_slider_add(cm->bx); - elm_slider_horizontal_set(slider, EINA_TRUE); - elm_slider_min_max_set(slider, min, max); - elm_slider_span_size_set(slider, max * elm_config_scale_get()); - elm_slider_unit_format_set(slider, "%.0f"); - elm_slider_indicator_format_set(slider, "%.0f"); - evas_object_size_hint_weight_set(slider, 0.0, EVAS_HINT_EXPAND); - evas_object_size_hint_align_set(slider, EVAS_HINT_FILL, EVAS_HINT_FILL); - elm_slider_value_set(slider, volume); - evas_object_smart_callback_add(slider, "changed", - _bd_hook_sink_volume_changed, sink); - evas_object_smart_callback_add(slider, "slider,drag,stop", - _bd_hook_sink_volume_drag_stop, sink); - elm_box_pack_end(cm->bx, slider); - evas_object_show(slider); - - check = elm_check_add(cm->bx); - elm_object_text_set(check, _("Mute")); - evas_object_size_hint_align_set(check, 0.0, EVAS_HINT_FILL); - elm_check_state_set(check, !!mute); - elm_object_disabled_set(slider, !!mute); - evas_object_smart_callback_add(check, "changed", - _bd_hook_sink_mute_changed, sink); - - elm_box_pack_end(cm->bx, check); - evas_object_show(check); - - evas_object_data_set(slider, "e_sink", sink); - evas_object_data_set(slider, "e_sink_check", check); - evas_object_data_set(slider, "e_sink_label", lbl); - evas_object_data_set(slider, "e_sink_separator", sep); - evas_object_data_set(check, "e_sink_volume", slider); - cm->sinks = eina_list_append(cm->sinks, slider); -} - -static Eina_Bool -_e_client_volume_sink_add(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client_Volume_Sink *ev; - Client_Mixer *cm; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - _e_client_mixer_sink_append(ev->sink, cm); - } - } - return ECORE_CALLBACK_PASS_ON; -} - -static Eina_Bool -_e_client_volume_sink_del(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client_Volume_Sink *ev; - E_Client_Volume_Sink *sink; - Client_Mixer *cm; - Evas_Object *o, *lbl, *check, *sep; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - EINA_LIST_FOREACH(cm->sinks, l, o) - { - sink = evas_object_data_get(o, "e_sink"); - if (sink == ev->sink) - { - lbl = evas_object_data_get(o, "e_sink_label"); - check = evas_object_data_get(o, "e_sink_check"); - sep = evas_object_data_get(o, "e_sink_separator"); - evas_object_del(sep); - evas_object_del(lbl); - evas_object_del(o); - evas_object_del(check); - cm->sinks = eina_list_remove_list(cm->sinks, l); - } - } - break; - } - } - return ECORE_CALLBACK_PASS_ON; -} - -static Eina_Bool -_e_client_volume_sink_changed(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client_Volume_Sink *ev; - Client_Mixer *cm; - E_Client_Volume_Sink *sink; - Evas_Object *o, *check; - Eina_List *l; - int volume; - Eina_Bool mute; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - EINA_LIST_FOREACH(cm->sinks, l, o) - { - sink = evas_object_data_get(o, "e_sink"); - if (sink != ev->sink) continue; - check = evas_object_data_get(o, "e_sink_check"); - e_client_volume_sink_get(sink, &volume, &mute); - elm_slider_value_set(o, volume); - elm_object_disabled_set(o, mute); - elm_check_state_set(check, mute); - } - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - -static void -_client_mixer_del(void *data, Evas *e EINA_UNUSED, Evas_Object *obj EINA_UNUSED, void *event_info EINA_UNUSED) -{ - Client_Mixer *cm; - - cm = data; - - _client_mixers = eina_list_remove(_client_mixers, cm); - free(cm); -} - -static Eina_Bool -_e_client_remove(void *data EINA_UNUSED, int type EINA_UNUSED, void *event) -{ - E_Event_Client *ev; - Client_Mixer *cm; - Eina_List *l; - - ev = event; - - EINA_LIST_FOREACH(_client_mixers, l, cm) - { - if (cm->ec == ev->ec) - { - evas_object_event_callback_del_full(cm->win, EVAS_CALLBACK_DEL, - _client_mixer_del, cm); - evas_object_del(cm->win); - _client_mixers = eina_list_remove_list(_client_mixers, l); - free(cm); - break; - } - } - - return ECORE_CALLBACK_PASS_ON; -} - EINTERN Eina_Bool mixer_init(void) { - Eina_List *l; char buf[4096]; - const char *backend; - Eina_Bool backend_loaded = EINA_FALSE; if (!gmixer_context) { gmixer_context = E_NEW(Context, 1); - gmixer_context->desklock_handler = - ecore_event_handler_add(E_EVENT_DESKLOCK, _desklock_cb, NULL); snprintf(buf, sizeof(buf), "%s/mixer.edj", e_module_dir_get(gmixer_context->module)); gmixer_context->theme = strdup(buf); + E_LIST_HANDLER_APPEND(_handlers, E_EVENT_MIXER_BACKEND_CHANGED, + _mixer_backend_changed, NULL); + E_LIST_HANDLER_APPEND(_handlers, E_EVENT_MIXER_SINKS_CHANGED, + _mixer_sinks_changed, NULL); } - emix_config_init(_backend_changed, NULL); - emix_event_callback_add(_events_cb, NULL); - - backend = emix_config_backend_get(); - if (backend && emix_backend_set(backend)) - backend_loaded = EINA_TRUE; - else - { - if (backend) - WRN("Could not load %s, trying another one ...", backend); - EINA_LIST_FOREACH((Eina_List *)emix_backends_available(), l, - backend) - { - if (emix_backend_set(backend) == EINA_TRUE) - { - DBG("Loaded backend: %s!", backend); - backend_loaded = EINA_TRUE; - emix_config_backend_set(backend); - break; - } - } - } - - if (!backend_loaded) return EINA_FALSE; - - if (emix_sink_default_support()) - gmixer_context->sink_default = emix_sink_default_get(); - - _actions_register(); - - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME, - _e_client_volume_changed, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_MUTE, - _e_client_mute_changed, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_UNMUTE, - _e_client_mute_changed, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_REMOVE, - _e_client_remove, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_ADD, - _e_client_volume_sink_add, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_DEL, - _e_client_volume_sink_del, NULL); - E_LIST_HANDLER_APPEND(_client_handlers, E_EVENT_CLIENT_VOLUME_SINK_CHANGED, - _e_client_volume_sink_changed, NULL); - return EINA_TRUE; } EINTERN void mixer_shutdown(void) { - E_Client_Volume_Sink *sink; - Client_Mixer *cm; - - E_FREE_LIST(_client_handlers, ecore_event_handler_del); - EINA_LIST_FREE(_client_mixers, cm) - { - evas_object_event_callback_del_full(cm->win, EVAS_CALLBACK_DEL, - _client_mixer_del, cm); - evas_object_del(cm->win); - free(cm); - } - + E_FREE_LIST(_handlers, ecore_event_handler_del); if (gmixer_context) { - _actions_unregister(); - free(gmixer_context->theme); E_FREE(gmixer_context); } - EINA_LIST_FREE(_client_sinks, sink) - e_client_volume_sink_del(sink); - emix_event_callback_del(_events_cb); } diff --git a/src/modules/mixer/gadget/mod.c b/src/modules/mixer/gadget/mod.c index d815ebacd..613e58df1 100644 --- a/src/modules/mixer/gadget/mod.c +++ b/src/modules/mixer/gadget/mod.c @@ -1,10 +1,13 @@ #include "mixer.h" +#include "backend.h" EINTERN int _e_gemix_log_domain; EINTERN void * e_modapi_gadget_init(E_Module *m) { + if (!backend_init()) return NULL; + _e_gemix_log_domain = eina_log_domain_register("mixer_gadget", EINA_COLOR_RED); e_gadget_type_add("Mixer", mixer_gadget_create, NULL); @@ -19,7 +22,7 @@ e_modapi_gadget_shutdown(E_Module *m EINA_UNUSED) e_gadget_type_del("Mixer"); - emix_shutdown(); + backend_shutdown(); return 1; } diff --git a/src/modules/mixer/meson.build b/src/modules/mixer/meson.build index a0fe8d6f3..dab65eb77 100644 --- a/src/modules/mixer/meson.build +++ b/src/modules/mixer/meson.build @@ -5,7 +5,8 @@ src = files( 'e_mod_main.h', 'gadget/mixer.h', 'gadget/mixer.c', - 'gadget/mod.c' + 'gadget/mod.c', + 'gadget/backend.c' ) mixer_lib = files(