- return ret;
-}
-
-static
-int handle_notif_stream_end(
- struct bt_notification_iterator_private_connection *iterator,
- struct bt_notification *notif,
- struct bt_stream *notif_stream)
-{
- int ret = 0;
- struct stream_state *stream_state;
-
- assert(notif->type == BT_NOTIFICATION_TYPE_STREAM_END);
- assert(notif_stream);
- ret = ensure_stream_state_exists(iterator, NULL, notif_stream,
- &stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot ensure that stream state exists.");
- goto error;
- }
-
- ret = handle_packet_switch(iterator, NULL, NULL, stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot handle packet switch.");
- goto error;
- }
-
- add_action_push_notif(iterator, notif);
- add_action_set_stream_state_is_ended(iterator, stream_state);
- goto end;
-
-error:
- ret = -1;
-
-end:
- return ret;
-}
-
-static
-int handle_notif_discarded_elements(
- struct bt_notification_iterator_private_connection *iterator,
- struct bt_notification *notif,
- struct bt_stream *notif_stream)
-{
- int ret = 0;
- struct stream_state *stream_state;
-
- assert(notif->type == BT_NOTIFICATION_TYPE_DISCARDED_EVENTS ||
- notif->type == BT_NOTIFICATION_TYPE_DISCARDED_PACKETS);
- assert(notif_stream);
- ret = ensure_stream_state_exists(iterator, NULL, notif_stream,
- &stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot ensure that stream state exists.");
- goto error;
- }
-
- add_action_push_notif(iterator, notif);
- goto end;
-
-error:
- ret = -1;
-
-end:
- return ret;
-}
-
-static
-int handle_notif_packet_begin(
- struct bt_notification_iterator_private_connection *iterator,
- struct bt_notification *notif,
- struct bt_stream *notif_stream,
- struct bt_packet *notif_packet)
-{
- int ret = 0;
- struct stream_state *stream_state;
-
- assert(notif->type == BT_NOTIFICATION_TYPE_PACKET_BEGIN);
- assert(notif_packet);
- ret = ensure_stream_state_exists(iterator, NULL, notif_stream,
- &stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot ensure that stream state exists.");
- goto error;
- }
-
- ret = handle_packet_switch(iterator, notif, notif_packet, stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot handle packet switch.");
- goto error;
- }
-
- goto end;
-
-error:
- ret = -1;
-
-end:
- return ret;
-}
-
-static
-int handle_notif_packet_end(
- struct bt_notification_iterator_private_connection *iterator,
- struct bt_notification *notif,
- struct bt_stream *notif_stream,
- struct bt_packet *notif_packet)
-{
- int ret = 0;
- struct stream_state *stream_state;
-
- assert(notif->type == BT_NOTIFICATION_TYPE_PACKET_END);
- assert(notif_packet);
- ret = ensure_stream_state_exists(iterator, NULL, notif_stream,
- &stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot ensure that stream state exists.");
- goto error;
- }
-
- ret = handle_packet_switch(iterator, NULL, notif_packet, stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot handle packet switch.");
- goto error;
- }
-
- /* End of the current packet */
- add_action_push_notif(iterator, notif);
- add_action_set_stream_state_cur_packet(iterator, stream_state, NULL);
- goto end;
-
-error:
- ret = -1;
-
-end:
- return ret;
-}
-
-static
-int handle_notif_event(
- struct bt_notification_iterator_private_connection *iterator,
- struct bt_notification *notif,
- struct bt_stream *notif_stream,
- struct bt_packet *notif_packet)
-{
- int ret = 0;
- struct stream_state *stream_state;
-
- assert(notif->type == BT_NOTIFICATION_TYPE_EVENT);
- assert(notif_packet);
- ret = ensure_stream_state_exists(iterator, NULL, notif_stream,
- &stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot ensure that stream state exists.");
- goto error;
- }
-
- ret = handle_packet_switch(iterator, NULL, notif_packet, stream_state);
- if (ret) {
- BT_LOGE_STR("Cannot handle packet switch.");
- goto error;
- }
-
- add_action_push_notif(iterator, notif);
- goto end;
-
-error:
- ret = -1;
-
-end:
- return ret;
-}
-
-static
-int enqueue_notification_and_automatic(
- struct bt_notification_iterator_private_connection *iterator,
- struct bt_notification *notif)
-{
- int ret = 0;
- struct bt_event *notif_event = NULL;
- struct bt_stream *notif_stream = NULL;
- struct bt_packet *notif_packet = NULL;
-
- assert(notif);
-
- BT_LOGV("Enqueuing user notification and automatic notifications: "
- "iter-addr=%p, notif-addr=%p", iterator, notif);
-
- // TODO: Skip most of this if the iterator is only subscribed
- // to event/inactivity notifications.
-
- /* Get the stream and packet referred by the notification */
- switch (notif->type) {
- case BT_NOTIFICATION_TYPE_EVENT:
- notif_event = bt_notification_event_borrow_event(notif);
- assert(notif_event);
- notif_packet = bt_event_borrow_packet(notif_event);
- assert(notif_packet);
- break;
- case BT_NOTIFICATION_TYPE_STREAM_BEGIN:
- notif_stream =
- bt_notification_stream_begin_borrow_stream(notif);
- assert(notif_stream);
- break;
- case BT_NOTIFICATION_TYPE_STREAM_END:
- notif_stream = bt_notification_stream_end_borrow_stream(notif);
- assert(notif_stream);
- break;
- case BT_NOTIFICATION_TYPE_PACKET_BEGIN:
- notif_packet =
- bt_notification_packet_begin_borrow_packet(notif);
- assert(notif_packet);
- break;
- case BT_NOTIFICATION_TYPE_PACKET_END:
- notif_packet = bt_notification_packet_end_borrow_packet(notif);
- assert(notif_packet);
- break;
- case BT_NOTIFICATION_TYPE_INACTIVITY:
- /* Always valid */
- goto handle_notif;
- default:
- /*
- * Invalid type of notification. Only the notification
- * types above are allowed to be returned by a user
- * component.
- */
- BT_LOGF("Unexpected notification type at this point: "
- "notif-addr=%p, notif-type=%s", notif,
- bt_notification_type_string(notif->type));
- abort();
- }
-
- if (notif_packet) {
- notif_stream = bt_packet_borrow_stream(notif_packet);
- assert(notif_stream);
- }
-
- if (!notif_stream) {
- /*
- * The notification has no reference to a stream: it
- * cannot cause the creation of automatic notifications.
- */
- BT_LOGV_STR("Notification has no reference to any stream: skipping automatic notification generation.");
- goto end;
- }
-
- if (!validate_notification(iterator, notif, notif_stream,
- notif_packet)) {
- BT_LOGW_STR("Invalid notification.");
- goto error;
- }
-
-handle_notif:
- switch (notif->type) {
- case BT_NOTIFICATION_TYPE_EVENT:
- ret = handle_notif_event(iterator, notif, notif_stream,
- notif_packet);
- break;
- case BT_NOTIFICATION_TYPE_STREAM_BEGIN:
- ret = handle_notif_stream_begin(iterator, notif, notif_stream);
- break;
- case BT_NOTIFICATION_TYPE_STREAM_END:
- ret = handle_notif_stream_end(iterator, notif, notif_stream);
- break;
- case BT_NOTIFICATION_TYPE_PACKET_BEGIN:
- ret = handle_notif_packet_begin(iterator, notif, notif_stream,
- notif_packet);
- break;
- case BT_NOTIFICATION_TYPE_PACKET_END:
- ret = handle_notif_packet_end(iterator, notif, notif_stream,
- notif_packet);
- break;
- case BT_NOTIFICATION_TYPE_DISCARDED_EVENTS:
- case BT_NOTIFICATION_TYPE_DISCARDED_PACKETS:
- ret = handle_notif_discarded_elements(iterator, notif,
- notif_stream);
- break;
- case BT_NOTIFICATION_TYPE_INACTIVITY:
- add_action_push_notif(iterator, notif);
- break;
- default:
- break;
- }
-
- if (ret) {
- BT_LOGW_STR("Failed to handle notification for automatic notification generation.");
- goto error;