Skip to content

Commit f30450b

Browse files
committed
local socket speed test
1 parent b206dd3 commit f30450b

File tree

1 file changed

+9
-7
lines changed

1 file changed

+9
-7
lines changed

src/testMonitor.cxx

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,18 +21,20 @@ int main()
2121
{
2222

2323
std::unique_ptr<Monitoring> monitoringCollector;
24-
monitoringCollector = MonitoringFactory::Get("influxdb-udp://aido2mon-gpn.cern.ch:8088");
25-
monitoringCollector->enableProcessMonitoring(1);
24+
//monitoringCollector = MonitoringFactory::Get("influxdb-udp://aido2mon-gpn.cern.ch:8088");
25+
//monitoringCollector = MonitoringFactory::Get("influxdb-unix:///tmp/unix_dgram_server.sock");
26+
monitoringCollector = MonitoringFactory::Get("influxdb-stdout:///tmp/telegraf.sock");
27+
//monitoringCollector->enableProcessMonitoring(1);
2628

2729
uint64_t bytesTotal = 0;
2830

29-
for (;;) {
30-
bytesTotal += 1000000000;
31+
for (int n=0;n<100000;n++) {
32+
bytesTotal += 1;
3133
monitoringCollector->send({ bytesTotal, "readout.BytesTotal" });
32-
monitoringCollector->send({ bytesTotal, "readout.BytesTotal" }, DerivedMetricMode::RATE);
33-
printf(".");
34+
//monitoringCollector->send({ bytesTotal, "readout.BytesTotal" }, DerivedMetricMode::RATE);
35+
printf("%d\n",n);
3436
fflush(stdout);
35-
sleep(1);
37+
//sleep(1);
3638
}
3739

3840
return 0;

0 commit comments

Comments
 (0)