Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for HTTPServer (0.2 sec)

  1. 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)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  2. cmd/signals.go

    			os.Exit(0)
    		}
    
    		os.Exit(1)
    	}
    
    	stopProcess := func() bool {
    		// 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  3. 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) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  4. build-logic/documentation/src/main/groovy/gradlebuild/docs/ServeDocs.java

                JavaExecHandleBuilder builder = getExecActionFactory().newJavaExec();
                builder.setExecutable(getJavaLauncher().get().getExecutablePath().getAsFile());
                builder.getMainModule().set("jdk.httpserver");
                builder.setStandardOutput(System.out);
                builder.setErrorOutput(System.err);
                builder.setArgs(Arrays.asList("-p", getPort().get(), "-d", getDocsDirectory().get().getAsFile().getAbsolutePath()));
    Java
    - Registered: Wed Apr 24 11:36:11 GMT 2024
    - Last Modified: Thu Apr 18 12:38:47 GMT 2024
    - 2.9K 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.commands.build
    import mkdocs.commands.serve
    import mkdocs.config
    import mkdocs.utils
    import typer
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Mon Jan 22 19:26:14 GMT 2024
    - 10.9K bytes
    - Viewed (1)
  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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 33K bytes
    - Viewed (1)
Back to top