Skip to content

Commit 28a3029

Browse files
Disable test if fec not supported and fix logic
1 parent cec1f3a commit 28a3029

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

src/internal_modules/roc_pipeline/receiver_session_group.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -518,9 +518,12 @@ void ReceiverSessionGroup::dequeue_prebuf_packet_(ReceiverSession& sess) {
518518
}
519519

520520
// if session handles the packet, remove it from the queue
521+
prebuf_packets_.remove(*curr);
521522
const status::StatusCode code = sess.route_packet(curr);
522523
if (code == status::StatusOK) {
523524
prebuf_packets_.remove(*curr);
525+
} else {
526+
prebuf_packets_.insert_before(*curr, *next);
524527
}
525528
}
526529
}

src/tests/roc_pipeline/test_receiver_source.cpp

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3403,6 +3403,10 @@ TEST(receiver_source, timestamp_mapping_remixing) {
34033403
}
34043404

34053405
TEST(receiver_source, packet_buffer) {
3406+
if (!fec_supported()) {
3407+
TEST_SKIP();
3408+
}
3409+
34063410
init_with_defaults();
34073411

34083412
ReceiverSource receiver(make_default_config(), processor_map, encoding_map,
@@ -3425,7 +3429,7 @@ TEST(receiver_source, packet_buffer) {
34253429
test::PacketWriter packet_writer(arena, *source_endpoint_writer,
34263430
*repair_endpoint_writer, encoding_map,
34273431
packet_factory, src_id1, src_addr1, dst_addr1,
3428-
dst_addr2, PayloadType_Ch2, fec_scheme, fec_config);
3432+
dst_addr2, PayloadType_Ch1, fec_scheme, fec_config);
34293433

34303434
// setup reader
34313435
test::FrameReader frame_reader(receiver, frame_factory);

0 commit comments

Comments
 (0)