aboutsummaryrefslogtreecommitdiffstats
path: root/host/tests/streamer_benchmark.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'host/tests/streamer_benchmark.cpp')
-rw-r--r--host/tests/streamer_benchmark.cpp12
1 files changed, 10 insertions, 2 deletions
diff --git a/host/tests/streamer_benchmark.cpp b/host/tests/streamer_benchmark.cpp
index 706ecee10..88dd9665b 100644
--- a/host/tests/streamer_benchmark.cpp
+++ b/host/tests/streamer_benchmark.cpp
@@ -302,7 +302,11 @@ static std::shared_ptr<rx_streamer_mock_link> make_rx_streamer_mock_link(
pkt_factory,
epids,
send_link->get_num_send_frames(),
- fc_params);
+ fc_params,
+ [io_srv = io_srv, recv_link, send_link]() {
+ io_srv->detach_recv_link(recv_link);
+ io_srv->detach_send_link(send_link);
+ });
streamer->connect_channel(0, std::move(xport));
return streamer;
@@ -341,7 +345,11 @@ static std::shared_ptr<tx_streamer_mock_link> make_tx_streamer_mock_link(
pkt_factory,
epids,
send_link->get_num_send_frames(),
- fc_params);
+ fc_params,
+ [io_srv = io_srv, recv_link, send_link]() {
+ io_srv->detach_recv_link(recv_link);
+ io_srv->detach_send_link(send_link);
+ });
streamer->connect_channel(0, std::move(xport));
return streamer;