Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for httpServers (0.08 sec)

  1. cmd/update_test.go

    func TestDownloadReleaseData(t *testing.T) {
    	httpServer1 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
    	defer httpServer1.Close()
    	httpServer2 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		fmt.Fprintln(w, "fbe246edbd382902db9a4035df7dce8cb441357d minio.RELEASE.2016-10-07T01-16-39Z")
    	}))
    	defer httpServer2.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. scripts/docs.py

    import json
    import logging
    import os
    import re
    import shutil
    import subprocess
    from functools import lru_cache
    from http.server import HTTPServer, SimpleHTTPRequestHandler
    from importlib import metadata
    from multiprocessing import Pool
    from pathlib import Path
    from typing import Any, Dict, List, Optional, Union
    
    import mkdocs.utils
    import typer
    import yaml
    from jinja2 import Template
    from ruff.__main__ import find_ruff_bin
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 08 11:01:17 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. cmd/server-main.go

    			UseBaseContext(GlobalContext).
    			UseCustomLogger(log.New(io.Discard, "", 0)). // Turn-off random logging by Go stdlib
    			UseTCPOptions(globalTCPOptions)
    
    		httpServer.TCPOptions.Trace = bootstrapTraceMsg
    		go func() {
    			serveFn, err := httpServer.Init(GlobalContext, func(listenAddr string, err error) {
    				bootLogIf(GlobalContext, fmt.Errorf("Unable to listen on `%s`: %v", listenAddr, err))
    			})
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top