From db6fd64601ad181dbb8f5faf8c673b12733e83f3 Mon Sep 17 00:00:00 2001 From: Ian Roddis Date: Fri, 7 Jan 2022 17:38:29 -0400 Subject: [PATCH] Fixing dagrun counts --- daggyd/libdaggyd/src/Server.cpp | 4 ++-- daggyr/libdaggyr/src/Server.cpp | 4 ++-- libdaggy/src/loggers/dag_run/OStreamLogger.cpp | 1 + 3 files changed, 5 insertions(+), 4 deletions(-) diff --git a/daggyd/libdaggyd/src/Server.cpp b/daggyd/libdaggyd/src/Server.cpp index 50a9823..965e7d6 100644 --- a/daggyd/libdaggyd/src/Server.cpp +++ b/daggyd/libdaggyd/src/Server.cpp @@ -34,8 +34,8 @@ namespace daggy::daggyd { { auto opts = Http::Endpoint::options() .threads(threads) - // .flags(Pistache::Tcp::Options::ReuseAddr | - // Pistache::Tcp::Options::ReusePort) + .flags(Pistache::Tcp::Options::ReuseAddr | + Pistache::Tcp::Options::ReusePort) .maxRequestSize(4294967296) .maxResponseSize(4294967296); endpoint_.init(opts); diff --git a/daggyr/libdaggyr/src/Server.cpp b/daggyr/libdaggyr/src/Server.cpp index ac4f7e0..2b72ef9 100644 --- a/daggyr/libdaggyr/src/Server.cpp +++ b/daggyr/libdaggyr/src/Server.cpp @@ -23,8 +23,8 @@ namespace daggy::daggyr { { auto opts = Http::Endpoint::options() .threads(threads) - //.flags(Pistache::Tcp::Options::ReuseAddr | - //Pistache::Tcp::Options::ReusePort) + .flags(Pistache::Tcp::Options::ReuseAddr | + Pistache::Tcp::Options::ReusePort) .maxRequestSize(102400) .maxResponseSize(102400); endpoint_.init(opts); diff --git a/libdaggy/src/loggers/dag_run/OStreamLogger.cpp b/libdaggy/src/loggers/dag_run/OStreamLogger.cpp index 062127c..7490dbd 100644 --- a/libdaggy/src/loggers/dag_run/OStreamLogger.cpp +++ b/libdaggy/src/loggers/dag_run/OStreamLogger.cpp @@ -148,6 +148,7 @@ namespace daggy::loggers::dag_run { } summaries.emplace_back(summary); + ++i; } return summaries; }