- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for HTTPServer (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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)