Kinesin/daggy
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixing dagrun counts

Browse Source
This commit is contained in:
Ian Roddis
2022-01-07 17:38:29 -04:00
parent d58dc2fc35
commit db6fd64601
3 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
daggyd/libdaggyd/src/Server.cpp
View File

@@ -34,8 +34,8 @@ namespace daggy::daggyd {
{ {
auto opts = Http::Endpoint::options() auto opts = Http::Endpoint::options()
.threads(threads) .threads(threads)
// .flags(Pistache::Tcp::Options::ReuseAddr | .flags(Pistache::Tcp::Options::ReuseAddr |
// Pistache::Tcp::Options::ReusePort) Pistache::Tcp::Options::ReusePort)
.maxRequestSize(4294967296) .maxRequestSize(4294967296)
.maxResponseSize(4294967296); .maxResponseSize(4294967296);
endpoint_.init(opts); endpoint_.init(opts);

4
daggyr/libdaggyr/src/Server.cpp
View File

@@ -23,8 +23,8 @@ namespace daggy::daggyr {
{ {
auto opts = Http::Endpoint::options() auto opts = Http::Endpoint::options()
.threads(threads) .threads(threads)
//.flags(Pistache::Tcp::Options::ReuseAddr | .flags(Pistache::Tcp::Options::ReuseAddr |
//Pistache::Tcp::Options::ReusePort) Pistache::Tcp::Options::ReusePort)
.maxRequestSize(102400) .maxRequestSize(102400)
.maxResponseSize(102400); .maxResponseSize(102400);
endpoint_.init(opts); endpoint_.init(opts);

1
libdaggy/src/loggers/dag_run/OStreamLogger.cpp
View File

@@ -148,6 +148,7 @@ namespace daggy::loggers::dag_run {
} }
summaries.emplace_back(summary); summaries.emplace_back(summary);
++i;
} }
return summaries; return summaries;
} }