Skip to content

Commit

Permalink
Fix build after rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
gavv committed Jul 19, 2024
1 parent b453b3e commit a5e3f27
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 7 deletions.
2 changes: 2 additions & 0 deletions src/internal_modules/roc_core/csv_dumper.h
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,8 @@ struct CsvEntry {

//! CSV write configuration.
struct CsvConfig {
//! Path to the output CSV file.
//! Can't be null.
const char* dump_file;

//! Maximum number of queued entries.
Expand Down
14 changes: 7 additions & 7 deletions src/tests/roc_pipeline/test_receiver_source.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3561,18 +3561,19 @@ TEST(receiver_source, metrics_truncation) {
// Check how receiver computes packet metrics:
// expected_packets, lost_packets, ext_first_seqnum, ext_last_seqnum
TEST(receiver_source, metrics_packet_counters) {
enum { Rate = SampleRate, Chans = Chans_Stereo, InitSeqnum = 0xFFFC };
enum { InitSeqnum = 0xFFFC };
uint32_t seqnum = InitSeqnum;
uint32_t prev_seqnum = InitSeqnum;
size_t pkt_counter = 0;
size_t prev_pkt_counter = 0;
size_t pkt_lost_counter = 0;
size_t prev_pkt_lost_counter = 0;

init(Rate, Chans, Rate, Chans);
init_with_defaults();

ReceiverSource receiver(make_default_config(), encoding_map, packet_pool,
packet_buffer_pool, frame_pool, frame_buffer_pool, arena);
ReceiverSource receiver(make_default_config(), processor_map, encoding_map,
packet_pool, packet_buffer_pool, frame_pool,
frame_buffer_pool, arena);
LONGS_EQUAL(status::StatusOK, receiver.init_status());

ReceiverSlot* slot = create_slot(receiver);
Expand Down Expand Up @@ -3614,15 +3615,14 @@ TEST(receiver_source, metrics_packet_counters) {
for (size_t np = 0; np < ManyPackets; np++) {
const bool lose_pkt = np % 3 == 0 && np;
for (size_t nf = 0; nf < FramesPerPacket; nf++) {
LONGS_EQUAL(status::StatusOK,
receiver.refresh(frame_reader.refresh_ts(), NULL));
refresh_source(receiver, frame_reader.refresh_ts());
frame_reader.read_any_samples(SamplesPerFrame, output_sample_spec);

UNSIGNED_LONGS_EQUAL(1, receiver.num_sessions());
}

if (lose_pkt) {
packet_writer.skip_packets(1, SamplesPerPacket);
packet_writer.skip_packets(1, SamplesPerPacket, output_sample_spec);
} else {
packet_writer.write_packets(1, SamplesPerPacket, output_sample_spec);
}
Expand Down

0 comments on commit a5e3f27

Please sign in to comment.