From 9a8226d2edeb8bf11ebde720e2dea8a0edbc3b81 Mon Sep 17 00:00:00 2001 From: Jose Date: Fri, 20 Dec 2024 16:47:17 +0100 Subject: [PATCH] Review fixes --- cpp/test/DataStorm/reliability/Reader.cpp | 1 - cpp/test/DataStorm/reliability/Writer.cpp | 4 ++-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/cpp/test/DataStorm/reliability/Reader.cpp b/cpp/test/DataStorm/reliability/Reader.cpp index 3924cecdf7f..94c94f9b368 100644 --- a/cpp/test/DataStorm/reliability/Reader.cpp +++ b/cpp/test/DataStorm/reliability/Reader.cpp @@ -125,7 +125,6 @@ void ::Reader::run(int argc, char* argv[]) cerr << "unexpected sample: " << sample.getValue() << " expected:" << (i + 100) << endl; test(false); } - session = sample.getSession(); } // Let the writer know we have processed all samples. diff --git a/cpp/test/DataStorm/reliability/Writer.cpp b/cpp/test/DataStorm/reliability/Writer.cpp index 62eb40856e7..01b0a5a406e 100644 --- a/cpp/test/DataStorm/reliability/Writer.cpp +++ b/cpp/test/DataStorm/reliability/Writer.cpp @@ -71,8 +71,8 @@ void ::Writer::run(int argc, char* argv[]) auto readerB = makeSingleKeyReader(topic, "reader_barrier"); - // A control sample sent by the reader to let the writer know the connection was closed. The writer processes this - // sample after the first session reestablishment. + // A control sample sent by the reader to let the writer know the connection was closed. The writer processes + // this sample after the first session reestablishment. auto sample = readerB.getNextUnread(); // Send a control sample to let the reader know session was reestablished.