- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for HTTPServer (0.16 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) } } if objAPI := newObjectLayerFn(); objAPI != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/background-heal-ops.go
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() waitForLowIO(maxIO, maxWait, currentHTTPIO) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 4.6K bytes - Viewed (0) -
internal/http/server.go
return srv } // NewServer - creates new HTTP server using given arguments. func NewServer(addrs []string) *Server { httpServer := &Server{ Addrs: addrs, } // This is not configurable for now. httpServer.MaxHeaderBytes = DefaultMaxHeaderBytes return httpServer } // SetMinIOVersion -- MinIO version from the main package is set here func SetMinIOVersion(version string) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.5K bytes - Viewed (0)