Skip to content

Commit 47167b5

Browse files
committed
Better value for fairmq buffers.
1 parent 32a9526 commit 47167b5

3 files changed

Lines changed: 6 additions & 6 deletions

File tree

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,8 +63,8 @@ The JSON `alfa.json` file contains a typical FairMQ device definition. One can
6363
"type": "pub",
6464
"method": "bind",
6565
"address": "tcp://*:5556",
66-
"sndBufSize": 10000,
67-
"rcvBufSize": 10000,
66+
"sndBufSize": 100,
67+
"rcvBufSize": 100,
6868
"rateLogging": 0
6969
}
7070
]

alfaTestReceiver.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@
1111
"type": "sub",
1212
"method": "connect",
1313
"address": "tcp://localhost:5556",
14-
"sndBufSize": 1000,
15-
"rcvBufSize": 1000,
14+
"sndBufSize": 100,
15+
"rcvBufSize": 100,
1616
"rateLogging": 0
1717
}
1818
]

src/SpyDevice.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,8 +89,8 @@ void SpyDevice::startChannel(std::string address, std::string type)
8989
FairMQChannel receivingChannel;
9090
receivingChannel.UpdateType(type);
9191
receivingChannel.UpdateAddress(address);
92-
receivingChannel.UpdateSndBufSize(10000);
93-
receivingChannel.UpdateRcvBufSize(10000);
92+
receivingChannel.UpdateSndBufSize(100);
93+
receivingChannel.UpdateRcvBufSize(100);
9494
receivingChannel.UpdateRateLogging(0);
9595
receivingChannel.UpdateMethod("connect");
9696
fChannels["data-in"].push_back(receivingChannel);

0 commit comments

Comments
 (0)