mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pw-cat: start timer when playing

Browse source
This commit is contained in:
Wim Taymans 2022-03-31 10:15:57 +02:00
parent c6a8f8d3ef
commit 5ec7a9f40c
1 changed files with 32 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

35
src/tools/pw-cat.c
View file

@ -120,6 +120,8 @@ struct data {
struct pw_stream *stream;
struct spa_hook stream_listener;
struct spa_source *timer;
enum mode mode;
bool verbose;
#define TYPE_PCM 0
@ -841,8 +843,9 @@ on_state_changed(void *userdata, enum pw_stream_state old,
pw_stream_state_as_string(old),
pw_stream_state_as_string(state));
if (state == PW_STREAM_STATE_STREAMING && !data->volume_is_set) {
switch (state) {
case PW_STREAM_STATE_STREAMING:
if (!data->volume_is_set) {
ret = pw_stream_set_control(data->stream,
SPA_PROP_volume, 1, &data->volume,
0);
@ -851,19 +854,30 @@ on_state_changed(void *userdata, enum pw_stream_state old,
ret == 0 ? "success" : "FAILED");
data->volume_is_set = true;
}
if (state == PW_STREAM_STATE_STREAMING) {
if (data->verbose)
if (data->verbose) {
struct timespec timeout = {0, 1}, interval = {1, 0};
struct pw_loop *l = pw_main_loop_get_loop(data->loop);
pw_loop_update_timer(l, data->timer, &timeout, &interval, false);
printf("stream node %"PRIu32"\n",
pw_stream_get_node_id(data->stream));
}
if (state == PW_STREAM_STATE_ERROR) {
break;
case PW_STREAM_STATE_PAUSED:
if (data->verbose) {
struct timespec timeout = {0, 0}, interval = {0, 0};
struct pw_loop *l = pw_main_loop_get_loop(data->loop);
pw_loop_update_timer(l, data->timer, &timeout, &interval, false);
}
break;
case PW_STREAM_STATE_ERROR:
printf("stream node %"PRIu32" error: %s\n",
pw_stream_get_node_id(data->stream),
error);
pw_main_loop_quit(data->loop);
break;
default:
break;
}
}
@ -1833,11 +1847,8 @@ int main(int argc, char *argv[])
data.mode == mode_playback ? "playback" : "record",
data.target_id);
if (data.verbose) {
struct timespec timeout = {0, 1}, interval = {1, 0};
struct spa_source *timer = pw_loop_add_timer(l, do_print_delay, &data);
pw_loop_update_timer(l, timer, &timeout, &interval, false);
}
if (data.verbose)
data.timer = pw_loop_add_timer(l, do_print_delay, &data);
ret = pw_stream_connect(data.stream,
data.mode == mode_playback ? PW_DIRECTION_OUTPUT : PW_DIRECTION_INPUT,