Skip to content

Commit

Permalink
Review fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
pepone committed Dec 20, 2024
1 parent 6d7c008 commit 9a8226d
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
1 change: 0 additions & 1 deletion cpp/test/DataStorm/reliability/Reader.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
4 changes: 2 additions & 2 deletions cpp/test/DataStorm/reliability/Writer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down

0 comments on commit 9a8226d

Please sign in to comment.