Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newHTTPServerFn (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top