- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newHTTPServerFn (0.1 sec)
-
cmd/signals.go
// before stopping s3 operations // send signal to various go-routines that they need to quit. cancelGlobalContext() if httpServer := newHTTPServerFn(); httpServer != nil { if err := httpServer.Shutdown(); err != nil && !errors.Is(err, http.ErrServerClosed) { shutdownLogIf(context.Background(), err) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/background-heal-ops.go
time.Sleep(tmpMaxWait) return } time.Sleep(waitTick) tmpMaxWait -= waitTick } if tmpMaxWait <= 0 { return } } } func currentHTTPIO() int { httpServer := newHTTPServerFn() if httpServer == nil { return 0 } return httpServer.GetRequestCount() - activeListeners() } func waitForLowHTTPReq() { maxIO, maxWait, _ := globalHealConfig.Clone()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/api-router.go
"net" "net/http" consoleapi "github.com/minio/console/api" xhttp "github.com/minio/minio/internal/http" "github.com/minio/mux" "github.com/minio/pkg/v3/wildcard" "github.com/rs/cors" ) func newHTTPServerFn() *xhttp.Server { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalHTTPServer } func setHTTPServer(h *xhttp.Server) { globalObjLayerMutex.Lock() globalHTTPServer = h
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 15:25:16 UTC 2024 - 23.1K bytes - Viewed (0)