Thanks for the comments! I've updated the docs, changed latency_offset in
pactl to a int64_t, and changed the corresponding calls to pa_atoi() to
pa_atol(). Patch incoming.
Regards,
Chris
On Wed, Jan 6, 2016 at 10:52 AM, Peter Meerwald-Stadler <pmeerw at pmeerw.net>
wrote:
>
> > I haven't contributed to pulseaudio before so let me know if I've done
> > anything foolish.
>
> look good to me; two comments:
> (1) there is documentation that needs to be updated
> (man/pulse-cli-syntax.5.xml.in, man/pactl.1.xml.in)
> (2) pactl still has latency_offset as a int32_t and uses pa_atoi(),
> pa_atoi() does not support int64_t; _set_port_latency_offset() should
> consistently use 64bit; I think this is a bug, int64_t should probably be
> used -- I suggest to do a precursory patch to fix this up
>
> > On Wed, Jan 6, 2016 at 2:36 AM, Chris Billington <
> chrisjbillington at gmail.com
> > > wrote:
> >
> > > This required the addition of two commands to the protocol:
> > > PA_COMMAND_SET_SINK_LATENCY_OFFSET and
> > > PA_COMMAND_SET_SOURCE_LATENCY_OFFSET.
> > >
> > > Changed integer type for the offset in pa_cli_command_port_offset() to
> > > int64_t.
> > >
> > > Bumped protocol version number to 31.
> > > ---
> > > PROTOCOL | 6 ++++
> > > configure.ac | 2 +-
> > > src/map-file | 2 ++
> > > src/pulse/introspect.c | 50 +++++++++++++++++++++++++++
> > > src/pulse/introspect.h | 6 ++++
> > > src/pulsecore/cli-command.c | 76
> > > ++++++++++++++++++++++++++++++++++++++++-
> > > src/pulsecore/native-common.h | 4 +++
> > > src/pulsecore/pdispatch.c | 4 +++
> > > src/pulsecore/protocol-native.c | 75
> > > ++++++++++++++++++++++++++++++++++++++++
> > > src/utils/pacmd.c | 1 +
> > > src/utils/pactl.c | 39 +++++++++++++++++++++
> > > 11 files changed, 263 insertions(+), 2 deletions(-)
> > >
> > > diff --git a/PROTOCOL b/PROTOCOL
> > > index 3c08fea..b6a5db7 100644
> > > --- a/PROTOCOL
> > > +++ b/PROTOCOL
> > > @@ -371,6 +371,12 @@ PA_COMMAND_DISABLE_SRBCHANNEL
> > > Tells the client to stop listening on the additional SHM ringbuffer
> > > channel.
> > > Acked by client by sending PA_COMMAND_DISABLE_SRBCHANNEL back.
> > >
> > > +## v31, implemented by >= 8.0
> > > +#
> > > +New opcodes:
> > > + PA_COMMAND_SET_SINK_LATENCY_OFFSET
> > > + PA_COMMAND_SET_SOURCE_LATENCY_OFFSET
> > > +
> > > #### If you just changed the protocol, read this
> > > ## module-tunnel depends on the sink/source/sink-input/source-input
> > > protocol
> > > ## internals, so if you changed these, you might have broken
> > > module-tunnel.
> > > diff --git a/configure.ac b/configure.ac
> > > index ee1b437..e749024 100644
> > > --- a/configure.ac
> > > +++ b/configure.ac
> > > @@ -40,7 +40,7 @@ AC_SUBST(PA_MINOR, pa_minor)
> > > AC_SUBST(PA_MAJORMINOR, pa_major.pa_minor)
> > >
> > > AC_SUBST(PA_API_VERSION, 12)
> > > -AC_SUBST(PA_PROTOCOL_VERSION, 30)
> > > +AC_SUBST(PA_PROTOCOL_VERSION, 31)
> > >
> > > # The stable ABI for client applications, for the version info x:y:z
> > > # always will hold y=z
> > > diff --git a/src/map-file b/src/map-file
> > > index 93a62b8..7826fa4 100644
> > > --- a/src/map-file
> > > +++ b/src/map-file
> > > @@ -62,6 +62,8 @@ pa_context_get_source_info_list;
> > > pa_context_get_source_output_info;
> > > pa_context_get_source_output_info_list;
> > > pa_context_set_port_latency_offset;
> > > +pa_context_set_sink_latency_offset;
> > > +pa_context_set_source_latency_offset;
> > > pa_context_get_state;
> > > pa_context_get_tile_size;
> > > pa_context_is_local;
> > > diff --git a/src/pulse/introspect.c b/src/pulse/introspect.c
> > > index 510d784..7f8b0c0 100644
> > > --- a/src/pulse/introspect.c
> > > +++ b/src/pulse/introspect.c
> > > @@ -1926,6 +1926,56 @@ pa_operation*
> > > pa_context_set_port_latency_offset(pa_context *c, const char *card
> > > return o;
> > > }
> > >
> > > +pa_operation* pa_context_set_sink_latency_offset(pa_context *c, const
> > > char *sink_name, int64_t offset, pa_context_success_cb_t cb, void
> > > *userdata) {
> > > + pa_operation *o;
> > > + pa_tagstruct *t;
> > > + uint32_t tag;
> > > +
> > > + pa_assert(c);
> > > + pa_assert(PA_REFCNT_VALUE(c) >= 1);
> > > +
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, !pa_detect_fork(),
> PA_ERR_FORKED);
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, c->state == PA_CONTEXT_READY,
> > > PA_ERR_BADSTATE);
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, sink_name && *sink_name,
> > > PA_ERR_INVALID);
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, c->version >= 31,
> > > PA_ERR_NOTSUPPORTED);
> > > +
> > > + o = pa_operation_new(c, NULL, (pa_operation_cb_t) cb, userdata);
> > > +
> > > + t = pa_tagstruct_command(c, PA_COMMAND_SET_SINK_LATENCY_OFFSET,
> &tag);
> > > + pa_tagstruct_putu32(t, PA_INVALID_INDEX);
> > > + pa_tagstruct_puts(t, sink_name);
> > > + pa_tagstruct_puts64(t, offset);
> > > + pa_pstream_send_tagstruct(c->pstream, t);
> > > + pa_pdispatch_register_reply(c->pdispatch, tag, DEFAULT_TIMEOUT,
> > > pa_context_simple_ack_callback, pa_operation_ref(o), (pa_free_cb_t)
> > > pa_operation_unref);
> > > +
> > > + return o;
> > > +}
> > > +
> > > +pa_operation* pa_context_set_source_latency_offset(pa_context *c,
> const
> > > char *source_name, int64_t offset, pa_context_success_cb_t cb, void
> > > *userdata) {
> > > + pa_operation *o;
> > > + pa_tagstruct *t;
> > > + uint32_t tag;
> > > +
> > > + pa_assert(c);
> > > + pa_assert(PA_REFCNT_VALUE(c) >= 1);
> > > +
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, !pa_detect_fork(),
> PA_ERR_FORKED);
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, c->state == PA_CONTEXT_READY,
> > > PA_ERR_BADSTATE);
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, source_name && *source_name,
> > > PA_ERR_INVALID);
> > > + PA_CHECK_VALIDITY_RETURN_NULL(c, c->version >= 31,
> > > PA_ERR_NOTSUPPORTED);
> > > +
> > > + o = pa_operation_new(c, NULL, (pa_operation_cb_t) cb, userdata);
> > > +
> > > + t = pa_tagstruct_command(c, PA_COMMAND_SET_SOURCE_LATENCY_OFFSET,
> > > &tag);
> > > + pa_tagstruct_putu32(t, PA_INVALID_INDEX);
> > > + pa_tagstruct_puts(t, source_name);
> > > + pa_tagstruct_puts64(t, offset);
> > > + pa_pstream_send_tagstruct(c->pstream, t);
> > > + pa_pdispatch_register_reply(c->pdispatch, tag, DEFAULT_TIMEOUT,
> > > pa_context_simple_ack_callback, pa_operation_ref(o), (pa_free_cb_t)
> > > pa_operation_unref);
> > > +
> > > + return o;
> > > +}
> > > +
> > > /*** Autoload stuff ***/
> > >
> > > PA_WARN_REFERENCE(pa_context_get_autoload_info_by_name, "Module
> > > auto-loading no longer supported.");
> > > diff --git a/src/pulse/introspect.h b/src/pulse/introspect.h
> > > index 43389b7..bd23467 100644
> > > --- a/src/pulse/introspect.h
> > > +++ b/src/pulse/introspect.h
> > > @@ -550,6 +550,12 @@ pa_operation*
> > > pa_context_set_card_profile_by_name(pa_context *c, const char*name
> > > /** Set the latency offset of a port. \since 3.0 */
> > > pa_operation* pa_context_set_port_latency_offset(pa_context *c, const
> > > char *card_name, const char *port_name, int64_t offset,
> > > pa_context_success_cb_t cb, void *userdata);
> > >
> > > +/** Set the latency offset of a sink. \since 8.0 */
> > > +pa_operation* pa_context_set_sink_latency_offset(pa_context *c, const
> > > char *sink_name, int64_t offset, pa_context_success_cb_t cb, void
> > > *userdata);
> > > +
> > > +/** Set the latency offset of a source. \since 8.0 */
> > > +pa_operation* pa_context_set_source_latency_offset(pa_context *c,
> const
> > > char *source_name, int64_t offset, pa_context_success_cb_t cb, void
> > > *userdata);
> > > +
> > > /** @} */
> > >
> > > /** @{ \name Sink Inputs */
> > > diff --git a/src/pulsecore/cli-command.c b/src/pulsecore/cli-command.c
> > > index 9a73605..94a016c 100644
> > > --- a/src/pulsecore/cli-command.c
> > > +++ b/src/pulsecore/cli-command.c
> > > @@ -134,6 +134,8 @@ static int pa_cli_command_card_profile(pa_core *c,
> > > pa_tokenizer *t, pa_strbuf *b
> > > static int pa_cli_command_sink_port(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail);
> > > static int pa_cli_command_source_port(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail);
> > > static int pa_cli_command_port_offset(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail);
> > > +static int pa_cli_command_sink_offset(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail);
> > > +static int pa_cli_command_source_offset(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail);
> > > static int pa_cli_command_dump_volumes(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail);
> > >
> > > /* A method table for all available commands */
> > > @@ -168,6 +170,8 @@ static const struct command commands[] = {
> > > { "set-sink-port", pa_cli_command_sink_port,
> > > "Change the port of a sink (args: index|name, port-name)", 3},
> > > { "set-source-port", pa_cli_command_source_port,
> > > "Change the port of a source (args: index|name, port-name)", 3},
> > > { "set-port-latency-offset", pa_cli_command_port_offset,
> > > "Change the latency of a port (args: card-index|card-name, port-name,
> > > latency-offset)", 4},
> > > + { "set-sink-latency-offset", pa_cli_command_sink_offset,
> > > "Change the latency of a sink (args: sink-index|sink-name,
> > > latency-offset)", 3},
> > > + { "set-source-latency-offset", pa_cli_command_source_offset,
> > > "Change the latency of a source (args: source-index|source-name,
> > > latency-offset)", 3},
> > > { "suspend-sink", pa_cli_command_suspend_sink,
> > > "Suspend sink (args: index|name, bool)", 3},
> > > { "suspend-source", pa_cli_command_suspend_source,
> > > "Suspend source (args: index|name, bool)", 3},
> > > { "suspend", pa_cli_command_suspend,
> > > "Suspend all sinks and all sources (args: bool)", 2},
> > > @@ -1735,7 +1739,7 @@ static int pa_cli_command_port_offset(pa_core *c,
> > > pa_tokenizer *t, pa_strbuf *bu
> > > const char *n, *p, *l;
> > > pa_device_port *port;
> > > pa_card *card;
> > > - int32_t offset;
> > > + int64_t offset;
> > >
> > > pa_core_assert_ref(c);
> > > pa_assert(t);
> > > @@ -1777,6 +1781,76 @@ static int pa_cli_command_port_offset(pa_core
> *c,
> > > pa_tokenizer *t, pa_strbuf *bu
> > > return 0;
> > > }
> > >
> > > +static int pa_cli_command_sink_offset(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail) {
> > > + const char *n, *l;
> > > + pa_sink *sink;
> > > + int64_t offset;
> > > +
> > > + pa_core_assert_ref(c);
> > > + pa_assert(t);
> > > + pa_assert(buf);
> > > + pa_assert(fail);
> > > +
> > > + if (!(n = pa_tokenizer_get(t, 1))) {
> > > + pa_strbuf_puts(buf, "You need to specify a sink either by
> its
> > > name or its index.\n");
> > > + return -1;
> > > + }
> > > +
> > > + if (!(l = pa_tokenizer_get(t, 2))) {
> > > + pa_strbuf_puts(buf, "You need to specify a latency
> offset.\n");
> > > + return -1;
> > > + }
> > > +
> > > + if (pa_atoi(l, &offset) < 0) {
> > > + pa_strbuf_puts(buf, "Failed to parse the latency offset.\n");
> > > + return -1;
> > > + }
> > > +
> > > + if (!(sink = pa_namereg_get(c, n, PA_NAMEREG_SINK))) {
> > > + pa_strbuf_puts(buf, "No sink found by this name or index.\n");
> > > + return -1;
> > > + }
> > > +
> > > + pa_sink_set_latency_offset(sink, offset);
> > > +
> > > + return 0;
> > > +}
> > > +
> > > +static int pa_cli_command_source_offset(pa_core *c, pa_tokenizer *t,
> > > pa_strbuf *buf, bool *fail) {
> > > + const char *n, *l;
> > > + pa_source *source;
> > > + int64_t offset;
> > > +
> > > + pa_core_assert_ref(c);
> > > + pa_assert(t);
> > > + pa_assert(buf);
> > > + pa_assert(fail);
> > > +
> > > + if (!(n = pa_tokenizer_get(t, 1))) {
> > > + pa_strbuf_puts(buf, "You need to specify a source either by
> > > its name or its index.\n");
> > > + return -1;
> > > + }
> > > +
> > > + if (!(l = pa_tokenizer_get(t, 2))) {
> > > + pa_strbuf_puts(buf, "You need to specify a latency
> offset.\n");
> > > + return -1;
> > > + }
> > > +
> > > + if (pa_atoi(l, &offset) < 0) {
> > > + pa_strbuf_puts(buf, "Failed to parse the latency offset.\n");
> > > + return -1;
> > > + }
> > > +
> > > + if (!(source = pa_namereg_get(c, n, PA_NAMEREG_SOURCE))) {
> > > + pa_strbuf_puts(buf, "No source found by this name or
> index.\n");
> > > + return -1;
> > > + }
> > > +
> > > + pa_source_set_latency_offset(source, offset);
> > > +
> > > + return 0;
> > > +}
> > > +
> > > static int pa_cli_command_dump(pa_core *c, pa_tokenizer *t, pa_strbuf
> > > *buf, bool *fail) {
> > > pa_module *m;
> > > pa_sink *sink;
> > > diff --git a/src/pulsecore/native-common.h
> b/src/pulsecore/native-common.h
> > > index dc62895..b32a235 100644
> > > --- a/src/pulsecore/native-common.h
> > > +++ b/src/pulsecore/native-common.h
> > > @@ -179,6 +179,10 @@ enum {
> > > PA_COMMAND_ENABLE_SRBCHANNEL,
> > > PA_COMMAND_DISABLE_SRBCHANNEL,
> > >
> > > + /* Supported since protocol v31 (8.0) */
> > > + PA_COMMAND_SET_SINK_LATENCY_OFFSET,
> > > + PA_COMMAND_SET_SOURCE_LATENCY_OFFSET,
> > > +
> > > PA_COMMAND_MAX
> > > };
> > >
> > > diff --git a/src/pulsecore/pdispatch.c b/src/pulsecore/pdispatch.c
> > > index f136875..5b58a3f 100644
> > > --- a/src/pulsecore/pdispatch.c
> > > +++ b/src/pulsecore/pdispatch.c
> > > @@ -195,6 +195,10 @@ static const char *command_names[PA_COMMAND_MAX]
> = {
> > > /* BOTH DIRECTIONS */
> > > [PA_COMMAND_ENABLE_SRBCHANNEL] = "ENABLE_SRBCHANNEL",
> > > [PA_COMMAND_DISABLE_SRBCHANNEL] = "DISABLE_SRBCHANNEL",
> > > +
> > > + /* Supported since protocol v31 (8.0) */
> > > + [PA_COMMAND_SET_SINK_LATENCY_OFFSET] = "SET_SINK_LATENCY_OFFSET",
> > > + [PA_COMMAND_SET_SOURCE_LATENCY_OFFSET] =
> "SET_SOURCE_LATENCY_OFFSET",
> > > };
> > >
> > > #endif
> > > diff --git a/src/pulsecore/protocol-native.c
> > > b/src/pulsecore/protocol-native.c
> > > index 145db04..43372ac 100644
> > > --- a/src/pulsecore/protocol-native.c
> > > +++ b/src/pulsecore/protocol-native.c
> > > @@ -293,6 +293,8 @@ static void command_extension(pa_pdispatch *pd,
> > > uint32_t command, uint32_t tag,
> > > static void command_set_card_profile(pa_pdispatch *pd, uint32_t
> command,
> > > uint32_t tag, pa_tagstruct *t, void *userdata);
> > > static void command_set_sink_or_source_port(pa_pdispatch *pd, uint32_t
> > > command, uint32_t tag, pa_tagstruct *t, void *userdata);
> > > static void command_set_port_latency_offset(pa_pdispatch *pd, uint32_t
> > > command, uint32_t tag, pa_tagstruct *t, void *userdata);
> > > +static void command_set_sink_latency_offset(pa_pdispatch *pd, uint32_t
> > > command, uint32_t tag, pa_tagstruct *t, void *userdata);
> > > +static void command_set_source_latency_offset(pa_pdispatch *pd,
> uint32_t
> > > command, uint32_t tag, pa_tagstruct *t, void *userdata);
> > > static void command_enable_srbchannel(pa_pdispatch *pd, uint32_t
> command,
> > > uint32_t tag, pa_tagstruct *t, void *userdata);
> > >
> > > static const pa_pdispatch_cb_t command_table[PA_COMMAND_MAX] = {
> > > @@ -397,6 +399,9 @@ static const pa_pdispatch_cb_t
> > > command_table[PA_COMMAND_MAX] = {
> > >
> > > [PA_COMMAND_SET_PORT_LATENCY_OFFSET] =
> > > command_set_port_latency_offset,
> > >
> > > + [PA_COMMAND_SET_SINK_LATENCY_OFFSET] =
> > > command_set_sink_latency_offset,
> > > + [PA_COMMAND_SET_SOURCE_LATENCY_OFFSET] =
> > > command_set_source_latency_offset,
> > > +
> > > [PA_COMMAND_ENABLE_SRBCHANNEL] = command_enable_srbchannel,
> > >
> > > [PA_COMMAND_EXTENSION] = command_extension
> > > @@ -4887,6 +4892,76 @@ static void
> > > command_set_port_latency_offset(pa_pdispatch *pd, uint32_t command,
> > > pa_pstream_send_simple_ack(c->pstream, tag);
> > > }
> > >
> > > +static void command_set_sink_latency_offset(pa_pdispatch *pd, uint32_t
> > > command, uint32_t tag, pa_tagstruct *t, void *userdata) {
> > > + pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
> > > + const char *sink_name;
> > > + uint32_t idx = PA_INVALID_INDEX;
> > > + int64_t offset;
> > > + pa_sink *sink = NULL;
> > > +
> > > + pa_native_connection_assert_ref(c);
> > > + pa_assert(t);
> > > +
> > > + if (pa_tagstruct_getu32(t, &idx) < 0 ||
> > > + pa_tagstruct_gets(t, &sink_name) < 0 ||
> > > + pa_tagstruct_gets64(t, &offset) < 0 ||
> > > + !pa_tagstruct_eof(t)) {
> > > + protocol_error(c);
> > > + return;
> > > + }
> > > +
> > > + CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
> > > + CHECK_VALIDITY(c->pstream, !sink_name ||
> > > pa_namereg_is_valid_name_or_wildcard(sink_name, PA_NAMEREG_SINK), tag,
> > > PA_ERR_INVALID);
> > > + CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (sink_name
> !=
> > > NULL), tag, PA_ERR_INVALID);
> > > + CHECK_VALIDITY(c->pstream, sink_name, tag, PA_ERR_INVALID);
> > > +
> > > + if (idx != PA_INVALID_INDEX)
> > > + sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
> > > + else
> > > + sink = pa_namereg_get(c->protocol->core, sink_name,
> > > PA_NAMEREG_SINK);
> > > +
> > > + CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY);
> > > +
> > > + pa_sink_set_latency_offset(sink, offset);
> > > +
> > > + pa_pstream_send_simple_ack(c->pstream, tag);
> > > +}
> > > +
> > > +static void command_set_source_latency_offset(pa_pdispatch *pd,
> uint32_t
> > > command, uint32_t tag, pa_tagstruct *t, void *userdata) {
> > > + pa_native_connection *c = PA_NATIVE_CONNECTION(userdata);
> > > + const char *source_name;
> > > + uint32_t idx = PA_INVALID_INDEX;
> > > + int64_t offset;
> > > + pa_source *source = NULL;
> > > +
> > > + pa_native_connection_assert_ref(c);
> > > + pa_assert(t);
> > > +
> > > + if (pa_tagstruct_getu32(t, &idx) < 0 ||
> > > + pa_tagstruct_gets(t, &source_name) < 0 ||
> > > + pa_tagstruct_gets64(t, &offset) < 0 ||
> > > + !pa_tagstruct_eof(t)) {
> > > + protocol_error(c);
> > > + return;
> > > + }
> > > +
> > > + CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS);
> > > + CHECK_VALIDITY(c->pstream, !source_name ||
> > > pa_namereg_is_valid_name_or_wildcard(source_name, PA_NAMEREG_SOURCE),
> tag,
> > > PA_ERR_INVALID);
> > > + CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^
> (source_name
> > > != NULL), tag, PA_ERR_INVALID);
> > > + CHECK_VALIDITY(c->pstream, source_name, tag, PA_ERR_INVALID);
> > > +
> > > + if (idx != PA_INVALID_INDEX)
> > > + source = pa_idxset_get_by_index(c->protocol->core->sources,
> idx);
> > > + else
> > > + source = pa_namereg_get(c->protocol->core, source_name,
> > > PA_NAMEREG_SOURCE);
> > > +
> > > + CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY);
> > > +
> > > + pa_source_set_latency_offset(source, offset);
> > > +
> > > + pa_pstream_send_simple_ack(c->pstream, tag);
> > > +}
> > > +
> > > /*** pstream callbacks ***/
> > >
> > > static void pstream_packet_callback(pa_pstream *p, pa_packet *packet,
> > > const pa_cmsg_ancil_data *ancil_data, void *userdata) {
> > > diff --git a/src/utils/pacmd.c b/src/utils/pacmd.c
> > > index 616573c..e0ea919 100644
> > > --- a/src/utils/pacmd.c
> > > +++ b/src/utils/pacmd.c
> > > @@ -72,6 +72,7 @@ static void help(const char *argv0) {
> > > printf("%s %s %s\n", argv0, "set-card-profile", _("CARD
> PROFILE"));
> > > printf("%s %s %s\n", argv0, "set-(sink|source)-port", _("NAME|#N
> > > PORT"));
> > > printf("%s %s %s\n", argv0, "set-port-latency-offset",
> > > _("CARD-NAME|CARD-#N PORT OFFSET"));
> > > + printf("%s %s %s\n", argv0,
> "set-sink-(sink|source)-latency-offset",
> > > _("NAME|#N OFFSET"));
> > > printf("%s %s %s\n", argv0, "set-log-target", _("TARGET"));
> > > printf("%s %s %s\n", argv0, "set-log-level", _("NUMERIC-LEVEL"));
> > > printf("%s %s %s\n", argv0, "set-log-meta", _("1|0"));
> > > diff --git a/src/utils/pactl.c b/src/utils/pactl.c
> > > index e9bf005..f04bef4 100644
> > > --- a/src/utils/pactl.c
> > > +++ b/src/utils/pactl.c
> > > @@ -130,6 +130,8 @@ static enum {
> > > SET_SOURCE_OUTPUT_MUTE,
> > > SET_SINK_FORMATS,
> > > SET_PORT_LATENCY_OFFSET,
> > > + SET_SINK_LATENCY_OFFSET,
> > > + SET_SOURCE_LATENCY_OFFSET,
> > > SUBSCRIBE
> > > } action = NONE;
> > >
> > > @@ -1404,6 +1406,14 @@ static void context_state_callback(pa_context
> *c,
> > > void *userdata) {
> > > o = pa_context_set_port_latency_offset(c,
> card_name,
> > > port_name, latency_offset, simple_callback, NULL);
> > > break;
> > >
> > > + case SET_SINK_LATENCY_OFFSET:
> > > + o = pa_context_set_sink_latency_offset(c,
> sink_name,
> > > latency_offset, simple_callback, NULL);
> > > + break;
> > > +
> > > + case SET_SOURCE_LATENCY_OFFSET:
> > > + o = pa_context_set_source_latency_offset(c,
> > > source_name, latency_offset, simple_callback, NULL);
> > > + break;
> > > +
> > > case SUBSCRIBE:
> > > pa_context_set_subscribe_callback(c,
> > > context_subscribe_callback, NULL);
> > >
> > > @@ -1580,6 +1590,7 @@ static void help(const char *argv0) {
> > > printf("%s %s %s %s\n", argv0, _("[options]"),
> > > "set-(sink-input|source-output)-mute", _("#N 1|0|toggle"));
> > > printf("%s %s %s %s\n", argv0, _("[options]"), "set-sink-formats",
> > > _("#N FORMATS"));
> > > printf("%s %s %s %s\n", argv0, _("[options]"),
> > > "set-port-latency-offset", _("CARD-NAME|CARD-#N PORT OFFSET"));
> > > + printf("%s %s %s %s\n", argv0, _("[options]"),
> > > "set-(sink|source)-latency-offset", _("NAME|#N OFFSET"));
> > > printf("%s %s %s\n", argv0, _("[options]"), "subscribe");
> > > printf(_("\nThe special names @DEFAULT_SINK@, @DEFAULT_SOURCE@
> and
> > > @DEFAULT_MONITOR@\n"
> > > "can be used to specify the default sink, source and
> > > monitor.\n"));
> > > @@ -2046,6 +2057,34 @@ int main(int argc, char *argv[]) {
> > > goto quit;
> > > }
> > >
> > > + } else if (pa_streq(argv[optind], "set-sink-latency-offset"))
> {
> > > + action = SET_SINK_LATENCY_OFFSET;
> > > +
> > > + if (argc != optind+3) {
> > > + pa_log(_("You have to specify a sink name/index and a
> > > latency offset"));
> > > + goto quit;
> > > + }
> > > +
> > > + sink_name = pa_xstrdup(argv[optind+1]);
> > > + if (pa_atoi(argv[optind + 2], &latency_offset) < 0) {
> > > + pa_log(_("Could not parse latency offset"));
> > > + goto quit;
> > > + }
> > > +
> > > + } else if (pa_streq(argv[optind],
> "set-source-latency-offset")) {
> > > + action = SET_SOURCE_LATENCY_OFFSET;
> > > +
> > > + if (argc != optind+3) {
> > > + pa_log(_("You have to specify a source name/index and
> a
> > > latency offset"));
> > > + goto quit;
> > > + }
> > > +
> > > + source_name = pa_xstrdup(argv[optind+1]);
> > > + if (pa_atoi(argv[optind + 2], &latency_offset) < 0) {
> > > + pa_log(_("Could not parse latency offset"));
> > > + goto quit;
> > > + }
> > > +
> > > } else if (pa_streq(argv[optind], "help")) {
> > > help(bn);
> > > ret = 0;
> > > --
> > > 2.5.0
> > >
> > >
> >
>
> --
>
> Peter Meerwald-Stadler
> +43-664-2444418 (mobile)
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.freedesktop.org/archives/pulseaudio-discuss/attachments/20160106/fd15d4ba/attachment-0001.html>
