mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2026-04-30 06:46:49 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

milan-avb: cmd-start-stop-streaming: add command handler

Browse source
This commit is contained in:
hackerman-kl 2026-04-25 10:56:59 +02:00 • committed by Wim Taymans
parent 6bf27b6c4e
commit d9f224b122
2 changed files with 75 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

60
src/modules/module-avb/aecp-aem-cmds-resps/cmd-start-stop-streaming.c Normal file
View file

@ -0,0 +1,60 @@
/* SPDX-FileCopyrightText: Copyright © 2025 Alexandre Malki */
/* SPDX-License-Identifier: MIT */
#include "../aecp.h"
#include "../aecp-aem.h"
#include "../aecp-aem-descriptors.h"
#include "../aecp-aem-state.h"
#include "cmd-start-stop-streaming.h"
#include "cmd-resp-helpers.h"
static int change_started_state(struct aecp *aecp, const void *m, int len, bool started)
{
const struct avb_ethernet_header *h = m;
const struct avb_packet_aecp_aem *p = SPA_PTROFF(h, sizeof(*h), void);
const struct avb_packet_aecp_aem_startstop_streaming *cmd =
(const struct avb_packet_aecp_aem_startstop_streaming *)p->payload;
uint16_t desc_type = ntohs(cmd->descriptor_type);
uint16_t desc_index = ntohs(cmd->descriptor_id);
struct descriptor *desc;
struct aecp_aem_stream_input_state *si;
/* Milan Section 5.4.2.19/20: not supported on Stream Outputs. */
if (desc_type == AVB_AEM_DESC_STREAM_OUTPUT)
return reply_not_supported(aecp, m, len);
if (desc_type != AVB_AEM_DESC_STREAM_INPUT)
return reply_status(aecp, AVB_AECP_AEM_STATUS_BAD_ARGUMENTS, m, len);
desc = server_find_descriptor(aecp->server, desc_type, desc_index);
if (desc == NULL)
return reply_status(aecp, AVB_AECP_AEM_STATUS_NO_SUCH_DESCRIPTOR, m, len);
si = desc->ptr;
/* Section 5.4.2.19/20: "this command has no effect on a Stream Input that is
* not already bound or already started/stopped." Reply SUCCESS in all
* cases — only the side effect on `started` is gated. */
if (si->common.lstream_attr.attr.listener.stream_id != 0 &&
si->started != started) {
si->started = started;
si->stream_info_dirty = true;
}
return reply_success(aecp, m, len);
}
int handle_cmd_start_streaming_milan_v12(struct aecp *aecp, int64_t now,
const void *m, int len)
{
(void)now;
return change_started_state(aecp, m, len, true);
}
int handle_cmd_stop_streaming_milan_v12(struct aecp *aecp, int64_t now,
const void *m, int len)
{
(void)now;
return change_started_state(aecp, m, len, false);
}

15
src/modules/module-avb/aecp-aem-cmds-resps/cmd-start-stop-streaming.h Normal file
View file

@ -0,0 +1,15 @@
/* SPDX-FileCopyrightText: Copyright © 2025 Alexandre Malki */
/* SPDX-License-Identifier: MIT */
#ifndef __AVB_AECP_AEM_CMD_START_STOP_STREAMING_H__
#define __AVB_AECP_AEM_CMD_START_STOP_STREAMING_H__
#include "../aecp-aem.h"
int handle_cmd_start_streaming_milan_v12(struct aecp *aecp, int64_t now,
const void *m, int len);
int handle_cmd_stop_streaming_milan_v12(struct aecp *aecp, int64_t now,
const void *m, int len);
#endif /* __AVB_AECP_AEM_CMD_START_STOP_STREAMING_H__ */