mx/Jungfraujoch
2
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 67 Wiki Activity

jfjoch_broker: Allow to query image pusher status
Build Packages / build:rpm (ubuntu2204) (push) Has been cancelled
Details
Build Packages / build:rpm (ubuntu2404) (push) Has been cancelled
Details
Build Packages / Generate python client (push) Has been cancelled
Details
Build Packages / Build documentation (push) Has been cancelled
Details
Build Packages / Unit tests (push) Has been cancelled
Details
Build Packages / Create release (push) Has been cancelled
Details
Build Packages / build:rpm (rocky9_nocuda) (push) Has started running
Details
Build Packages / build:rpm (rocky8_nocuda) (push) Has been cancelled
Details
Build Packages / build:rpm (ubuntu2404_nocuda) (push) Has been cancelled
Details
Build Packages / build:rpm (rocky9_sls9) (push) Has been cancelled
Details
Build Packages / build:rpm (rocky8_sls9) (push) Has been cancelled
Details
Build Packages / build:rpm (rocky8) (push) Has been cancelled
Details
Build Packages / build:rpm (rocky9) (push) Has been cancelled
Details
Build Packages / build:rpm (ubuntu2204_nocuda) (push) Has been cancelled
Details

Browse Source
This commit is contained in:
leonarski_f
2026-03-05 12:28:37 +01:00
parent 4ede10aa6a
commit 343e9a1172
34 changed files with 559 additions and 79 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/TCPImagePusherTest.cpp
+2 -2
View File
@@ -410,7 +410,7 @@ TEST_CASE("TCPImageCommTest_AutoPort_StarBind", "[TCP]") {
std::vector<uint16_t> image1(x.GetPixelsNum() * nframes, 7u);
TCPStreamPusher pusher("tcp://127.0.0.1:*", 1);
TCPImagePuller puller(pusher.GetAddress(), 64 * 1024 * 1024);
TCPImagePuller puller(pusher.GetAddress()[0], 64 * 1024 * 1024);
std::thread receiver([&] {
bool seen_end = false;
@@ -473,7 +473,7 @@ TEST_CASE("TCPImageCommTest_DisconnectMidWrite_NoHang", "[TCP]") {
std::vector<uint16_t> image1(x.GetPixelsNum() * nframes, 11u);
TCPStreamPusher pusher("tcp://127.0.0.1:*", 1);
TCPImagePuller puller(pusher.GetAddress(), 64 * 1024 * 1024);
TCPImagePuller puller(pusher.GetAddress()[0], 64 * 1024 * 1024);
std::thread receiver([&] {
bool disconnected = false;