TCPStreamPusher: Enforce run number in ACK match input
This commit is contained in:
@@ -16,6 +16,7 @@ TEST_CASE("TCPImageCommTest_2Writers_WithAck", "[TCP]") {
|
||||
x.Raw();
|
||||
x.PedestalG0Frames(0).NumTriggers(1).UseInternalPacketGenerator(false).IncidentEnergy_keV(12.4)
|
||||
.ImagesPerTrigger(nframes).Compression(CompressionAlgorithm::NO_COMPRESSION);
|
||||
x.RunNumber(567);
|
||||
|
||||
std::mt19937 g1(1387);
|
||||
std::uniform_int_distribution<uint16_t> dist;
|
||||
@@ -45,6 +46,7 @@ TEST_CASE("TCPImageCommTest_2Writers_WithAck", "[TCP]") {
|
||||
|
||||
StartMessage start{
|
||||
.images_per_file = images_per_file,
|
||||
.run_number = x.GetRunNumber(),
|
||||
.write_master_file = true
|
||||
};
|
||||
EndMessage end{};
|
||||
@@ -100,6 +102,7 @@ TEST_CASE("TCPImageCommTest_2Writers_WithAck", "[TCP]") {
|
||||
ack.image_number = 0;
|
||||
ack.processed_images = 0;
|
||||
ack.error_code = TCPAckCode::None;
|
||||
REQUIRE(ack.run_number == x.GetRunNumber());
|
||||
REQUIRE(puller[w]->SendAck(ack));
|
||||
seen_start = true;
|
||||
continue;
|
||||
|
||||
Reference in New Issue
Block a user