From 0bdcdb1303597072bffe383bca645b2b1735a271 Mon Sep 17 00:00:00 2001 From: Ciprian Dorin Craciun Date: Sat, 18 Dec 2021 17:54:06 +0200 Subject: [PATCH] [server] Add initial stats reporting support. --- sources/cmd/server/server.go | 160 +++++++++++++++++++++++++++++++++++ 1 file changed, 160 insertions(+) diff --git a/sources/cmd/server/server.go b/sources/cmd/server/server.go index 17dec02..3f40a38 100644 --- a/sources/cmd/server/server.go +++ b/sources/cmd/server/server.go @@ -1881,6 +1881,18 @@ func main_0 () (error) { } () } + if _reportStatsEnabled { + _reportStatsQuiet = _quiet + go func () () { + reportStatsLoop () + } () + } + + if !_quiet { + time.Sleep (100 * time.Millisecond) + log.Printf ("[--] [ ]\n") + } + { _waiter.Add (1) _signals := make (chan os.Signal, 32) @@ -1888,6 +1900,10 @@ func main_0 () (error) { go func () () { defer _waiter.Done () <- _signals + _reportStatsStop = true + if !_quiet { + log.Printf ("[--] [ ]\n") + } if !_quiet { log.Printf ("[ii] [691cb695] [shutdown] terminating...\n") } @@ -2037,6 +2053,150 @@ var _statsRequests5xx uint64 +func reportStatsLoop () { + reportStats () + for { + if _reportStatsStop { + break + } + time.Sleep (1000 * time.Millisecond) + reportStats () + } +} + + +func reportStats () () { + + _timestamp := RuntimeNanoseconds () + + _reportHeartbeatCounter += 1 + + _shouldLog := false + if !_reportStatsQuiet { + _shouldLog = _shouldLog || ((_reportHeartbeatCounter % 30) == 0) + } else { + _shouldLog = _shouldLog || ((_reportHeartbeatCounter % 360) == 0) + } + + _reportHeartbeat.Update (_timestamp) + if _reportHeartbeat.Speed1paLast < 0.001 { + _reportHeartbeat.Changed = false + } + + _invalid := false + _changed := false + + _reportRequestsTotal.Update2 (_timestamp, &_changed, &_invalid) + _reportRequestsFast.Update2 (_timestamp, &_changed, &_invalid) + _reportRequestsSlow.Update2 (_timestamp, &_changed, &_invalid) + _reportRequests1xx.Update2 (_timestamp, &_changed, &_invalid) + _reportRequests2xx.Update2 (_timestamp, &_changed, &_invalid) + _reportRequests3xx.Update2 (_timestamp, &_changed, &_invalid) + _reportRequests4xx.Update2 (_timestamp, &_changed, &_invalid) + _reportRequests5xx.Update2 (_timestamp, &_changed, &_invalid) + + if _invalid || (!_shouldLog && !_changed) { + return + } + + if _shouldLog && !_reportStatsQuiet { + log.Printf ("[--] [ ]\n") + } + if (_shouldLog || _reportHeartbeat.Changed) && _reportHeartbeat.Touched { + log.Printf ("[ii] [addc4553] [stats...] uptime %6.2fh | tps %7.2f %+.1f%%\n", + _reportHeartbeat.ValueLast / 3600, _reportHeartbeat.Speed1Last, _reportHeartbeat.Speed1prLast) + } + if (_shouldLog || _reportRequestsTotal.Changed) && _reportRequestsTotal.Touched { + log.Printf ("[ii] [870f4146] [stats...] requests %6.2fM | krps %7.2f %+.1f%% (%+.1f%%)\n", + _reportRequestsTotal.ValueLast, _reportRequestsTotal.Speed1Last, _reportRequestsTotal.Speed1prLast, _reportRequestsTotal.Speed1prWindow) + } + if (_shouldLog || _reportRequests1xx.Changed) && _reportRequests1xx.Touched { + log.Printf ("[ii] [d12ebda3] [stats...] resp-1xx %6.2fM | krps %7.2f %+.1f%% (%+.1f%%)\n", + _reportRequests1xx.ValueLast, _reportRequests1xx.Speed1Last, _reportRequests1xx.Speed1prLast, _reportRequests1xx.Speed1prWindow) + } + if (_shouldLog || _reportRequests2xx.Changed) && _reportRequests2xx.Touched { + log.Printf ("[ii] [2464e4c2] [stats...] resp-2xx %6.2fM | krps %7.2f %+.1f%% (%+.1f%%)\n", + _reportRequests2xx.ValueLast, _reportRequests2xx.Speed1Last, _reportRequests2xx.Speed1prLast, _reportRequests2xx.Speed1prWindow) + } + if (_shouldLog || _reportRequests3xx.Changed) && _reportRequests3xx.Touched { + log.Printf ("[ii] [59bea970] [stats...] resp-3xx %6.2fM | krps %7.2f %+.1f%% (%+.1f%%)\n", + _reportRequests3xx.ValueLast, _reportRequests3xx.Speed1Last, _reportRequests3xx.Speed1prLast, _reportRequests3xx.Speed1prWindow) + } + if (_shouldLog || _reportRequests4xx.Changed) && _reportRequests4xx.Touched { + log.Printf ("[ii] [babb043c] [stats...] resp-4xx %6.2fM | krps %7.2f %+.1f%% (%+.1f%%)\n", + _reportRequests4xx.ValueLast, _reportRequests4xx.Speed1Last, _reportRequests4xx.Speed1prLast, _reportRequests4xx.Speed1prWindow) + } + if (_shouldLog || _reportRequests5xx.Changed) && _reportRequests5xx.Touched { + log.Printf ("[ii] [047ba05b] [stats...] resp-5xx %6.2fM | krps %7.2f %+.1f%% (%+.1f%%)\n", + _reportRequests5xx.ValueLast, _reportRequests5xx.Speed1Last, _reportRequests5xx.Speed1prLast, _reportRequests5xx.Speed1prWindow) + } + if _shouldLog && !_reportStatsQuiet { + log.Printf ("[--] [ ]\n") + } +} + + +var _reportStatsEnabled = true +var _reportStatsQuiet = false +var _reportStatsStop = false + +var _reportHeartbeatCounter uint64 +var _reportHeartbeat = & StatMetric { + MetricSource : &_reportHeartbeatCounter, + } + +var _reportRequestsTotal = & StatMetric { + MetricSource : &_statsRequestsTotal, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 0.1, + } +var _reportRequestsFast = & StatMetric { + MetricSource : &_statsRequestsFast, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 1.0, + } +var _reportRequestsSlow = & StatMetric { + MetricSource : &_statsRequestsSlow, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 1.0, + } +var _reportRequests1xx = & StatMetric { + MetricSource : &_statsRequests1xx, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 0.01, + } +var _reportRequests2xx = & StatMetric { + MetricSource : &_statsRequests2xx, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 1.0, + } +var _reportRequests3xx = & StatMetric { + MetricSource : &_statsRequests3xx, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 0.01, + } +var _reportRequests4xx = & StatMetric { + MetricSource : &_statsRequests4xx, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 0.01, + } +var _reportRequests5xx = & StatMetric { + MetricSource : &_statsRequests5xx, + ValueScale : 1000 * 1000, + SpeedScale : 1000, + SpeedThreshold : 0.01, + } + + + + //go:embed usage.txt var usageText string