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: msrp: mark listener stream-info dirty on TA/TF registrar change

Browse source
This commit is contained in:
hackerman-kl 2026-04-25 13:45:44 +02:00 • committed by Wim Taymans
parent 995def4927
commit ce42b7c1da
1 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/modules/module-avb/msrp.c
View file

@ -79,12 +79,18 @@ static void notify_talker(struct msrp *msrp, uint64_t now, struct attr *attr, ui
sc->lstream_attr.param = AVB_MSRP_LISTENER_PARAM_READY; sc->lstream_attr.param = AVB_MSRP_LISTENER_PARAM_READY;
else if (notify == AVB_MRP_NOTIFY_LEAVE) else if (notify == AVB_MRP_NOTIFY_LEAVE)
sc->lstream_attr.param = AVB_MSRP_LISTENER_PARAM_ASKING_FAILED; sc->lstream_attr.param = AVB_MSRP_LISTENER_PARAM_ASKING_FAILED;
/* Milan Table 5.10: TA registrar state flips flags_ex.REGISTERING
* in the listener-side GET_STREAM_INFO answer — emit an unsol. */
avb_aecp_aem_mark_stream_info_dirty(msrp->server,
AVB_AEM_DESC_STREAM_INPUT, sc->stream.index);
} }
} }
static void notify_talker_failed(struct msrp *msrp, uint64_t now, struct attr *attr, uint8_t notify) static void notify_talker_failed(struct msrp *msrp, uint64_t now, struct attr *attr, uint8_t notify)
{ {
struct stream_common *sc;
char label[64]; char label[64];
pw_log_info("> notify talker failed: %s", avb_mrp_notify_name(notify)); pw_log_info("> notify talker failed: %s", avb_mrp_notify_name(notify));
snprintf(label, sizeof(label), "MSRP talker-fail %s", avb_mrp_notify_name(notify)); snprintf(label, sizeof(label), "MSRP talker-fail %s", avb_mrp_notify_name(notify));
avb_log_state(msrp->server, label); avb_log_state(msrp->server, label);
@ -93,6 +99,13 @@ static void notify_talker_failed(struct msrp *msrp, uint64_t now, struct attr *a
if (notify == AVB_MRP_NOTIFY_NEW || notify == AVB_MRP_NOTIFY_JOIN) if (notify == AVB_MRP_NOTIFY_NEW || notify == AVB_MRP_NOTIFY_JOIN)
handle_evt_tk_registration_failed(msrp->server->acmp, attr->attr, now); handle_evt_tk_registration_failed(msrp->server->acmp, attr->attr, now);
} }
/* Milan Table 5.10: TF registrar state also flips flags_ex.REGISTERING
* on the listener side; emit an unsol when it changes. */
sc = SPA_CONTAINER_OF(attr->attr, struct stream_common, tfstream_attr);
if (sc->stream.direction == SPA_DIRECTION_INPUT)
avb_aecp_aem_mark_stream_info_dirty(msrp->server,
AVB_AEM_DESC_STREAM_INPUT, sc->stream.index);
} }
static int process_talker(struct msrp *msrp, uint64_t now, uint8_t attr_type, static int process_talker(struct msrp *msrp, uint64_t now, uint8_t attr_type,