static uint32_t module_index;
static int32_t latency_offset;
static bool suspend;
-static pa_volume_t volume;
+static pa_cvolume volume;
static enum volume_flags {
VOL_UINT = 0,
VOL_PERCENT = 1,
static pa_sample_spec sample_spec;
static pa_channel_map channel_map;
static size_t sample_length = 0;
-static int actions = 1;
+
+/* This variable tracks the number of ongoing asynchronous operations. When a
+ * new operation begins, this is incremented simply with actions++, and when
+ * an operation finishes, this is decremented with the complete_action()
+ * function, which shuts down the program if actions reaches zero. */
+static int actions = 0;
static bool nl = false;
/* Relative volume change is additive in case of UINT or PERCENT
* and multiplicative for LINEAR or DECIBEL */
if ((volume_flags & 0x0F) == VOL_UINT || (volume_flags & 0x0F) == VOL_PERCENT) {
- pa_volume_t v = pa_cvolume_avg(cv);
- v = v + volume < PA_VOLUME_NORM ? PA_VOLUME_MUTED : v + volume - PA_VOLUME_NORM;
- pa_cvolume_set(cv, 1, v);
- }
- if ((volume_flags & 0x0F) == VOL_LINEAR || (volume_flags & 0x0F) == VOL_DECIBEL) {
- pa_sw_cvolume_multiply_scalar(cv, cv, volume);
+ unsigned i;
+ for (i = 0; i < cv->channels; i++) {
+ if (cv->values[i] + volume.values[i] < PA_VOLUME_NORM)
+ cv->values[i] = PA_VOLUME_MUTED;
+ else
+ cv->values[i] = cv->values[i] + volume.values[i] - PA_VOLUME_NORM;
+ }
}
+ if ((volume_flags & 0x0F) == VOL_LINEAR || (volume_flags & 0x0F) == VOL_DECIBEL)
+ pa_sw_cvolume_multiply(cv, cv, &volume);
}
static void unload_module_by_name_callback(pa_context *c, const pa_module_info *i, int is_last, void *userdata) {
}
}
+static void fill_volume(pa_cvolume *cv, unsigned supported) {
+ if (volume.channels == 1) {
+ pa_cvolume_set(&volume, supported, volume.values[0]);
+ } else if (volume.channels != supported) {
+ pa_log(_("Failed to set volume: You tried to set volumes for %d channels, whereas channel/s supported = %d\n"),
+ volume.channels, supported);
+ quit(1);
+ return;
+ }
+
+ if (volume_flags & VOL_RELATIVE)
+ volume_relative_adjust(cv);
+ else
+ *cv = volume;
+}
+
static void get_sink_volume_callback(pa_context *c, const pa_sink_info *i, int is_last, void *userdata) {
pa_cvolume cv;
pa_assert(i);
cv = i->volume;
- volume_relative_adjust(&cv);
+ fill_volume(&cv, i->channel_map.channels);
+
pa_operation_unref(pa_context_set_sink_volume_by_name(c, sink_name, &cv, simple_callback, NULL));
}
pa_assert(i);
cv = i->volume;
- volume_relative_adjust(&cv);
+ fill_volume(&cv, i->channel_map.channels);
+
pa_operation_unref(pa_context_set_source_volume_by_name(c, source_name, &cv, simple_callback, NULL));
}
pa_assert(i);
cv = i->volume;
- volume_relative_adjust(&cv);
+ fill_volume(&cv, i->channel_map.channels);
+
pa_operation_unref(pa_context_set_sink_input_volume(c, sink_input_idx, &cv, simple_callback, NULL));
}
pa_assert(o);
cv = o->volume;
- volume_relative_adjust(&cv);
+ fill_volume(&cv, o->channel_map.channels);
+
pa_operation_unref(pa_context_set_source_output_volume(c, source_output_idx, &cv, simple_callback, NULL));
}
char *format = NULL;
const char *state = NULL;
int i = 0;
+ pa_operation *o = NULL;
while ((format = pa_split(str, ";", &state))) {
pa_format_info *f = pa_format_info_from_string(pa_strip(format));
pa_xfree(format);
}
- pa_operation_unref(pa_ext_device_restore_save_formats(c, PA_DEVICE_TYPE_SINK, sink, i, f_arr, simple_callback, NULL));
+ o = pa_ext_device_restore_save_formats(c, PA_DEVICE_TYPE_SINK, sink, i, f_arr, simple_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
done:
if (format)
}
static void context_state_callback(pa_context *c, void *userdata) {
+ pa_operation *o = NULL;
+
pa_assert(c);
+
switch (pa_context_get_state(c)) {
case PA_CONTEXT_CONNECTING:
case PA_CONTEXT_AUTHORIZING:
case PA_CONTEXT_READY:
switch (action) {
case STAT:
- pa_operation_unref(pa_context_stat(c, stat_callback, NULL));
+ o = pa_context_stat(c, stat_callback, NULL);
if (short_list_format)
break;
- actions++;
+
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+ /* Fall through */
case INFO:
- pa_operation_unref(pa_context_get_server_info(c, get_server_info_callback, NULL));
+ o = pa_context_get_server_info(c, get_server_info_callback, NULL);
break;
case PLAY_SAMPLE:
- pa_operation_unref(pa_context_play_sample(c, sample_name, sink_name, PA_VOLUME_NORM, simple_callback, NULL));
+ o = pa_context_play_sample(c, sample_name, sink_name, PA_VOLUME_NORM, simple_callback, NULL);
break;
case REMOVE_SAMPLE:
- pa_operation_unref(pa_context_remove_sample(c, sample_name, simple_callback, NULL));
+ o = pa_context_remove_sample(c, sample_name, simple_callback, NULL);
break;
case UPLOAD_SAMPLE:
pa_stream_set_state_callback(sample_stream, stream_state_callback, NULL);
pa_stream_set_write_callback(sample_stream, stream_write_callback, NULL);
pa_stream_connect_upload(sample_stream, sample_length);
+ actions++;
break;
case EXIT:
- pa_operation_unref(pa_context_exit_daemon(c, simple_callback, NULL));
+ o = pa_context_exit_daemon(c, simple_callback, NULL);
break;
case LIST:
if (list_type) {
if (pa_streq(list_type, "modules"))
- pa_operation_unref(pa_context_get_module_info_list(c, get_module_info_callback, NULL));
+ o = pa_context_get_module_info_list(c, get_module_info_callback, NULL);
else if (pa_streq(list_type, "sinks"))
- pa_operation_unref(pa_context_get_sink_info_list(c, get_sink_info_callback, NULL));
+ o = pa_context_get_sink_info_list(c, get_sink_info_callback, NULL);
else if (pa_streq(list_type, "sources"))
- pa_operation_unref(pa_context_get_source_info_list(c, get_source_info_callback, NULL));
+ o = pa_context_get_source_info_list(c, get_source_info_callback, NULL);
else if (pa_streq(list_type, "sink-inputs"))
- pa_operation_unref(pa_context_get_sink_input_info_list(c, get_sink_input_info_callback, NULL));
+ o = pa_context_get_sink_input_info_list(c, get_sink_input_info_callback, NULL);
else if (pa_streq(list_type, "source-outputs"))
- pa_operation_unref(pa_context_get_source_output_info_list(c, get_source_output_info_callback, NULL));
+ o = pa_context_get_source_output_info_list(c, get_source_output_info_callback, NULL);
else if (pa_streq(list_type, "clients"))
- pa_operation_unref(pa_context_get_client_info_list(c, get_client_info_callback, NULL));
+ o = pa_context_get_client_info_list(c, get_client_info_callback, NULL);
else if (pa_streq(list_type, "samples"))
- pa_operation_unref(pa_context_get_sample_info_list(c, get_sample_info_callback, NULL));
+ o = pa_context_get_sample_info_list(c, get_sample_info_callback, NULL);
else if (pa_streq(list_type, "cards"))
- pa_operation_unref(pa_context_get_card_info_list(c, get_card_info_callback, NULL));
+ o = pa_context_get_card_info_list(c, get_card_info_callback, NULL);
else
pa_assert_not_reached();
} else {
- actions = 8;
- pa_operation_unref(pa_context_get_module_info_list(c, get_module_info_callback, NULL));
- pa_operation_unref(pa_context_get_sink_info_list(c, get_sink_info_callback, NULL));
- pa_operation_unref(pa_context_get_source_info_list(c, get_source_info_callback, NULL));
- pa_operation_unref(pa_context_get_sink_input_info_list(c, get_sink_input_info_callback, NULL));
- pa_operation_unref(pa_context_get_source_output_info_list(c, get_source_output_info_callback, NULL));
- pa_operation_unref(pa_context_get_client_info_list(c, get_client_info_callback, NULL));
- pa_operation_unref(pa_context_get_sample_info_list(c, get_sample_info_callback, NULL));
- pa_operation_unref(pa_context_get_card_info_list(c, get_card_info_callback, NULL));
+ o = pa_context_get_module_info_list(c, get_module_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ o = pa_context_get_sink_info_list(c, get_sink_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ o = pa_context_get_source_info_list(c, get_source_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+ o = pa_context_get_sink_input_info_list(c, get_sink_input_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ o = pa_context_get_source_output_info_list(c, get_source_output_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ o = pa_context_get_client_info_list(c, get_client_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ o = pa_context_get_sample_info_list(c, get_sample_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ o = pa_context_get_card_info_list(c, get_card_info_callback, NULL);
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ o = NULL;
}
break;
case MOVE_SINK_INPUT:
- pa_operation_unref(pa_context_move_sink_input_by_name(c, sink_input_idx, sink_name, simple_callback, NULL));
+ o = pa_context_move_sink_input_by_name(c, sink_input_idx, sink_name, simple_callback, NULL);
break;
case MOVE_SOURCE_OUTPUT:
- pa_operation_unref(pa_context_move_source_output_by_name(c, source_output_idx, source_name, simple_callback, NULL));
+ o = pa_context_move_source_output_by_name(c, source_output_idx, source_name, simple_callback, NULL);
break;
case LOAD_MODULE:
- pa_operation_unref(pa_context_load_module(c, module_name, module_args, index_callback, NULL));
+ o = pa_context_load_module(c, module_name, module_args, index_callback, NULL);
break;
case UNLOAD_MODULE:
if (module_name)
- pa_operation_unref(pa_context_get_module_info_list(c, unload_module_by_name_callback, NULL));
+ o = pa_context_get_module_info_list(c, unload_module_by_name_callback, NULL);
else
- pa_operation_unref(pa_context_unload_module(c, module_index, simple_callback, NULL));
+ o = pa_context_unload_module(c, module_index, simple_callback, NULL);
break;
case SUSPEND_SINK:
if (sink_name)
- pa_operation_unref(pa_context_suspend_sink_by_name(c, sink_name, suspend, simple_callback, NULL));
+ o = pa_context_suspend_sink_by_name(c, sink_name, suspend, simple_callback, NULL);
else
- pa_operation_unref(pa_context_suspend_sink_by_index(c, PA_INVALID_INDEX, suspend, simple_callback, NULL));
+ o = pa_context_suspend_sink_by_index(c, PA_INVALID_INDEX, suspend, simple_callback, NULL);
break;
case SUSPEND_SOURCE:
if (source_name)
- pa_operation_unref(pa_context_suspend_source_by_name(c, source_name, suspend, simple_callback, NULL));
+ o = pa_context_suspend_source_by_name(c, source_name, suspend, simple_callback, NULL);
else
- pa_operation_unref(pa_context_suspend_source_by_index(c, PA_INVALID_INDEX, suspend, simple_callback, NULL));
+ o = pa_context_suspend_source_by_index(c, PA_INVALID_INDEX, suspend, simple_callback, NULL);
break;
case SET_CARD_PROFILE:
- pa_operation_unref(pa_context_set_card_profile_by_name(c, card_name, profile_name, simple_callback, NULL));
+ o = pa_context_set_card_profile_by_name(c, card_name, profile_name, simple_callback, NULL);
break;
case SET_SINK_PORT:
- pa_operation_unref(pa_context_set_sink_port_by_name(c, sink_name, port_name, simple_callback, NULL));
+ o = pa_context_set_sink_port_by_name(c, sink_name, port_name, simple_callback, NULL);
break;
case SET_DEFAULT_SINK:
- pa_operation_unref(pa_context_set_default_sink(c, sink_name, simple_callback, NULL));
+ o = pa_context_set_default_sink(c, sink_name, simple_callback, NULL);
break;
case SET_SOURCE_PORT:
- pa_operation_unref(pa_context_set_source_port_by_name(c, source_name, port_name, simple_callback, NULL));
+ o = pa_context_set_source_port_by_name(c, source_name, port_name, simple_callback, NULL);
break;
case SET_DEFAULT_SOURCE:
- pa_operation_unref(pa_context_set_default_source(c, source_name, simple_callback, NULL));
+ o = pa_context_set_default_source(c, source_name, simple_callback, NULL);
break;
case SET_SINK_MUTE:
if (mute == TOGGLE_MUTE)
- pa_operation_unref(pa_context_get_sink_info_by_name(c, sink_name, sink_toggle_mute_callback, NULL));
+ o = pa_context_get_sink_info_by_name(c, sink_name, sink_toggle_mute_callback, NULL);
else
- pa_operation_unref(pa_context_set_sink_mute_by_name(c, sink_name, mute, simple_callback, NULL));
+ o = pa_context_set_sink_mute_by_name(c, sink_name, mute, simple_callback, NULL);
break;
case SET_SOURCE_MUTE:
if (mute == TOGGLE_MUTE)
- pa_operation_unref(pa_context_get_source_info_by_name(c, source_name, source_toggle_mute_callback, NULL));
+ o = pa_context_get_source_info_by_name(c, source_name, source_toggle_mute_callback, NULL);
else
- pa_operation_unref(pa_context_set_source_mute_by_name(c, source_name, mute, simple_callback, NULL));
+ o = pa_context_set_source_mute_by_name(c, source_name, mute, simple_callback, NULL);
break;
case SET_SINK_INPUT_MUTE:
if (mute == TOGGLE_MUTE)
- pa_operation_unref(pa_context_get_sink_input_info(c, sink_input_idx, sink_input_toggle_mute_callback, NULL));
+ o = pa_context_get_sink_input_info(c, sink_input_idx, sink_input_toggle_mute_callback, NULL);
else
- pa_operation_unref(pa_context_set_sink_input_mute(c, sink_input_idx, mute, simple_callback, NULL));
+ o = pa_context_set_sink_input_mute(c, sink_input_idx, mute, simple_callback, NULL);
break;
case SET_SOURCE_OUTPUT_MUTE:
if (mute == TOGGLE_MUTE)
- pa_operation_unref(pa_context_get_source_output_info(c, source_output_idx, source_output_toggle_mute_callback, NULL));
+ o = pa_context_get_source_output_info(c, source_output_idx, source_output_toggle_mute_callback, NULL);
else
- pa_operation_unref(pa_context_set_source_output_mute(c, source_output_idx, mute, simple_callback, NULL));
+ o = pa_context_set_source_output_mute(c, source_output_idx, mute, simple_callback, NULL);
break;
case SET_SINK_VOLUME:
- if ((volume_flags & VOL_RELATIVE) == VOL_RELATIVE) {
- pa_operation_unref(pa_context_get_sink_info_by_name(c, sink_name, get_sink_volume_callback, NULL));
- } else {
- pa_cvolume v;
- pa_cvolume_set(&v, 1, volume);
- pa_operation_unref(pa_context_set_sink_volume_by_name(c, sink_name, &v, simple_callback, NULL));
- }
+ o = pa_context_get_sink_info_by_name(c, sink_name, get_sink_volume_callback, NULL);
break;
case SET_SOURCE_VOLUME:
- if ((volume_flags & VOL_RELATIVE) == VOL_RELATIVE) {
- pa_operation_unref(pa_context_get_source_info_by_name(c, source_name, get_source_volume_callback, NULL));
- } else {
- pa_cvolume v;
- pa_cvolume_set(&v, 1, volume);
- pa_operation_unref(pa_context_set_source_volume_by_name(c, source_name, &v, simple_callback, NULL));
- }
+ o = pa_context_get_source_info_by_name(c, source_name, get_source_volume_callback, NULL);
break;
case SET_SINK_INPUT_VOLUME:
- if ((volume_flags & VOL_RELATIVE) == VOL_RELATIVE) {
- pa_operation_unref(pa_context_get_sink_input_info(c, sink_input_idx, get_sink_input_volume_callback, NULL));
- } else {
- pa_cvolume v;
- pa_cvolume_set(&v, 1, volume);
- pa_operation_unref(pa_context_set_sink_input_volume(c, sink_input_idx, &v, simple_callback, NULL));
- }
+ o = pa_context_get_sink_input_info(c, sink_input_idx, get_sink_input_volume_callback, NULL);
break;
case SET_SOURCE_OUTPUT_VOLUME:
- if ((volume_flags & VOL_RELATIVE) == VOL_RELATIVE) {
- pa_operation_unref(pa_context_get_source_output_info(c, source_output_idx, get_source_output_volume_callback, NULL));
- } else {
- pa_cvolume v;
- pa_cvolume_set(&v, 1, volume);
- pa_operation_unref(pa_context_set_source_output_volume(c, source_output_idx, &v, simple_callback, NULL));
- }
+ o = pa_context_get_source_output_info(c, source_output_idx, get_source_output_volume_callback, NULL);
break;
case SET_SINK_FORMATS:
break;
case SET_PORT_LATENCY_OFFSET:
- pa_operation_unref(pa_context_set_port_latency_offset(c, card_name, port_name, latency_offset, simple_callback, NULL));
+ o = pa_context_set_port_latency_offset(c, card_name, port_name, latency_offset, simple_callback, NULL);
break;
case SUBSCRIBE:
pa_context_set_subscribe_callback(c, context_subscribe_callback, NULL);
- pa_operation_unref(pa_context_subscribe(
- c,
- PA_SUBSCRIPTION_MASK_SINK|
- PA_SUBSCRIPTION_MASK_SOURCE|
- PA_SUBSCRIPTION_MASK_SINK_INPUT|
- PA_SUBSCRIPTION_MASK_SOURCE_OUTPUT|
- PA_SUBSCRIPTION_MASK_MODULE|
- PA_SUBSCRIPTION_MASK_CLIENT|
- PA_SUBSCRIPTION_MASK_SAMPLE_CACHE|
- PA_SUBSCRIPTION_MASK_SERVER|
- PA_SUBSCRIPTION_MASK_CARD,
- NULL,
- NULL));
+ o = pa_context_subscribe(c,
+ PA_SUBSCRIPTION_MASK_SINK|
+ PA_SUBSCRIPTION_MASK_SOURCE|
+ PA_SUBSCRIPTION_MASK_SINK_INPUT|
+ PA_SUBSCRIPTION_MASK_SOURCE_OUTPUT|
+ PA_SUBSCRIPTION_MASK_MODULE|
+ PA_SUBSCRIPTION_MASK_CLIENT|
+ PA_SUBSCRIPTION_MASK_SAMPLE_CACHE|
+ PA_SUBSCRIPTION_MASK_SERVER|
+ PA_SUBSCRIPTION_MASK_CARD,
+ NULL,
+ NULL);
break;
default:
pa_assert_not_reached();
}
+
+ if (o) {
+ pa_operation_unref(o);
+ actions++;
+ }
+
+ if (actions == 0) {
+ pa_log("Operation failed: %s", pa_strerror(pa_context_errno(c)));
+ quit(1);
+ }
+
break;
case PA_CONTEXT_TERMINATED:
return 0;
}
+static int parse_volumes(char *args[], unsigned n) {
+ unsigned i;
+
+ if (n >= PA_CHANNELS_MAX) {
+ pa_log(_("Invalid number of volume specifications.\n"));
+ return -1;
+ }
+
+ volume.channels = n;
+ for (i = 0; i < volume.channels; i++) {
+ enum volume_flags flags;
+
+ if (parse_volume(args[i], &volume.values[i], &flags) < 0)
+ return -1;
+
+ if (i > 0 && flags != volume_flags) {
+ pa_log(_("Inconsistent volume specification.\n"));
+ return -1;
+ } else
+ volume_flags = flags;
+ }
+
+ return 0;
+}
+
static enum mute_flags parse_mute(const char *mute_text) {
int b;
proplist = pa_proplist_new();
- while ((c = getopt_long(argc, argv, "s:n:h", long_options, NULL)) != -1) {
+ while ((c = getopt_long(argc, argv, "+s:n:h", long_options, NULL)) != -1) {
switch (c) {
case 'h' :
help(bn);
} else if (pa_streq(argv[optind], "set-sink-volume")) {
action = SET_SINK_VOLUME;
- if (argc != optind+3) {
+ if (argc < optind+3) {
pa_log(_("You have to specify a sink name/index and a volume"));
goto quit;
}
sink_name = pa_xstrdup(argv[optind+1]);
- if (parse_volume(argv[optind+2], &volume, &volume_flags) < 0)
+ if (parse_volumes(argv+optind+2, argc-3) < 0)
goto quit;
} else if (pa_streq(argv[optind], "set-source-volume")) {
action = SET_SOURCE_VOLUME;
- if (argc != optind+3) {
+ if (argc < optind+3) {
pa_log(_("You have to specify a source name/index and a volume"));
goto quit;
}
source_name = pa_xstrdup(argv[optind+1]);
- if (parse_volume(argv[optind+2], &volume, &volume_flags) < 0)
+ if (parse_volumes(argv+optind+2, argc-3) < 0)
goto quit;
} else if (pa_streq(argv[optind], "set-sink-input-volume")) {
action = SET_SINK_INPUT_VOLUME;
- if (argc != optind+3) {
+ if (argc < optind+3) {
pa_log(_("You have to specify a sink input index and a volume"));
goto quit;
}
goto quit;
}
- if (parse_volume(argv[optind+2], &volume, &volume_flags) < 0)
+ if (parse_volumes(argv+optind+2, argc-3) < 0)
goto quit;
} else if (pa_streq(argv[optind], "set-source-output-volume")) {
action = SET_SOURCE_OUTPUT_VOLUME;
- if (argc != optind+3) {
+ if (argc < optind+3) {
pa_log(_("You have to specify a source output index and a volume"));
goto quit;
}
goto quit;
}
- if (parse_volume(argv[optind+2], &volume, &volume_flags) < 0)
+ if (parse_volumes(argv+optind+2, argc-3) < 0)
goto quit;
} else if (pa_streq(argv[optind], "set-sink-mute")) {