Lines Matching refs:payload_number

763 	seq_err = (meta->payload_number != (sp->prev_pdu_id+1));  in isoal_rx_unframed_consume()
786 || (meta->payload_number % session->pdus_per_sdu == 0)) { in isoal_rx_unframed_consume()
840 sdu_offset = (meta->payload_number % session->burst_number) / session->pdus_per_sdu; in isoal_rx_unframed_consume()
957 sp->prev_pdu_id = meta->payload_number; in isoal_rx_unframed_consume()
1133 seq_err = (meta->payload_number != (sp->prev_pdu_id + 1)); in isoal_rx_framed_consume()
1394 sp->prev_pdu_id = meta->payload_number; in isoal_rx_framed_consume()
1684 const uint64_t payload_number, in isoal_tx_pdu_emit() argument
1702 node_tx->payload_count = payload_number & 0x7fffffffff; in isoal_tx_pdu_emit()
1713 source_ctx, payload_number, status, in isoal_tx_pdu_emit()
1811 pp->payload_number, in isoal_tx_try_emit_pdu()
1813 pp->payload_number++; in isoal_tx_try_emit_pdu()
1831 uint64_t *payload_number) in isoal_tx_unframed_get_next_payload_number() argument
1845 *payload_number = pp->payload_number; in isoal_tx_unframed_get_next_payload_number()
1883 *payload_number = pp->payload_number + in isoal_tx_unframed_get_next_payload_number()
1896 *payload_number = pp->payload_number + in isoal_tx_unframed_get_next_payload_number()
1906 *payload_number = MAX(pp->payload_number, in isoal_tx_unframed_get_next_payload_number()
2011 pp->payload_number = next_payload_number; in isoal_tx_unframed_produce()
2028 actual_event = pp->payload_number / session->burst_number; in isoal_tx_unframed_produce()
2296 uint64_t *payload_number, in isoal_tx_framed_find_correct_tx_event() argument
2317 next_payload_number = pp->payload_number; in isoal_tx_framed_find_correct_tx_event()
2318 actual_event = pp->payload_number / session->burst_number; in isoal_tx_framed_find_correct_tx_event()
2460 next_payload_number = MAX(pp->payload_number, in isoal_tx_framed_find_correct_tx_event()
2479 *payload_number = next_payload_number; in isoal_tx_framed_find_correct_tx_event()
2547 source, tx_sdu->packet_sn, pp->payload_number, next_payload_number, in isoal_tx_framed_produce()
2551 if (next_payload_number > pp->payload_number) { in isoal_tx_framed_produce()
2561 while (err == ISOAL_STATUS_OK && next_payload_number > pp->payload_number && in isoal_tx_framed_produce()
2562 (pp->payload_number % session->burst_number)) { in isoal_tx_framed_produce()
2573 pp->payload_number = next_payload_number; in isoal_tx_framed_produce()
2748 if (pp->pdu_allocated && pp->payload_number <= last_event_payload) { in isoal_tx_framed_event_prepare_handle()
2779 if (pp->payload_number > first_event_payload) { in isoal_tx_framed_event_prepare_handle()
2785 while (!err && !err_alloc && (pp->payload_number < last_event_payload + 1ULL)) { in isoal_tx_framed_event_prepare_handle()
2796 if (pp->payload_number < last_event_payload + 1ULL) { in isoal_tx_framed_event_prepare_handle()
2797 pp->payload_number = last_event_payload + 1ULL; in isoal_tx_framed_event_prepare_handle()
2798 ISOAL_LOG_DBGV("[%p] Prepare PL updated to %lu.", source, pp->payload_number); in isoal_tx_framed_event_prepare_handle()