diff options
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/filer_server_handlers.go | 5 | ||||
| -rw-r--r-- | weed/server/volume_server_handlers.go | 4 |
2 files changed, 9 insertions, 0 deletions
diff --git a/weed/server/filer_server_handlers.go b/weed/server/filer_server_handlers.go index 69774ce27..1c5c89dcf 100644 --- a/weed/server/filer_server_handlers.go +++ b/weed/server/filer_server_handlers.go @@ -21,6 +21,11 @@ import ( func (fs *FilerServer) filerHandler(w http.ResponseWriter, r *http.Request) { start := time.Now() + + inFlightGauge := stats.FilerInFlightRequestsGauge.WithLabelValues(r.Method) + inFlightGauge.Inc() + defer inFlightGauge.Dec() + statusRecorder := stats.NewStatusResponseWriter(w) w = statusRecorder origin := r.Header.Get("Origin") diff --git a/weed/server/volume_server_handlers.go b/weed/server/volume_server_handlers.go index 85fb9ba81..22ef0e1c8 100644 --- a/weed/server/volume_server_handlers.go +++ b/weed/server/volume_server_handlers.go @@ -31,6 +31,10 @@ security settings: */ func (vs *VolumeServer) privateStoreHandler(w http.ResponseWriter, r *http.Request) { + inFlightGauge := stats.VolumeServerInFlightRequestsGauge.WithLabelValues(r.Method) + inFlightGauge.Inc() + defer inFlightGauge.Dec() + statusRecorder := stats.NewStatusResponseWriter(w) w = statusRecorder w.Header().Set("Server", "SeaweedFS Volume "+util.VERSION) |