Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ErrServerClosed (0.14 sec)

  1. internal/logger/utils.go

    	if color.IsTerminal() {
    		ansiEscape("8")
    	}
    }
    
    // logIgnoreError if true,the error will ignore.
    func logIgnoreError(err error) bool {
    	return err == nil || errors.Is(err, context.Canceled) || errors.Is(err, http.ErrServerClosed) || err.Error() == "drive not found"
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Aug 04 23:10:08 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  2. pkg/network/error.go

    	"errors"
    	"net"
    	"net/http"
    )
    
    func IsUnexpectedListenerError(err error) bool {
    	if err == nil {
    		return false
    	}
    	if errors.Is(err, net.ErrClosed) {
    		return false
    	}
    	if errors.Is(err, http.ErrServerClosed) {
    		return false
    	}
    	return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 21 08:25:27 UTC 2023
    - 858 bytes
    - Viewed (0)
  3. internal/http/server.go

    func (srv *Server) Shutdown() error {
    	srv.listenerMutex.Lock()
    	if srv.listener == nil {
    		srv.listenerMutex.Unlock()
    		return http.ErrServerClosed
    	}
    	srv.listenerMutex.Unlock()
    
    	if atomic.AddUint32(&srv.inShutdown, 1) > 1 {
    		// shutdown in progress
    		return http.ErrServerClosed
    	}
    
    	// Close underneath HTTP listener.
    	srv.listenerMutex.Lock()
    	err := srv.listener.Close()
    	srv.listenerMutex.Unlock()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Feb 09 21:25:16 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. pkg/proxy/healthcheck/service_health.go

    		go func(hcI *hcInstance, listener net.Listener, httpSrv httpServer) {
    			// Serve() will exit and return ErrServerClosed when the http server is closed.
    			klog.V(3).InfoS("Starting goroutine for healthcheck", "service", hcI.nsn, "address", listener.Addr())
    			if err := httpSrv.Serve(listener); err != nil && err != http.ErrServerClosed {
    				klog.ErrorS(err, "Healthcheck closed", "service", hcI.nsn)
    				return
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 30 09:25:48 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  5. cmd/signals.go

    		// 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 {
    			shutdownLogIf(context.Background(), objAPI.Shutdown(context.Background()))
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 01 17:57:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  6. pkg/test/fakes/gce_metadata_server/main.go

    	r.HandleFunc(attrPath, handleAttrs(attrs)).Methods("GET")
    
    	srv := &http.Server{Addr: addr, Handler: r}
    
    	go func() {
    		if err := srv.ListenAndServe(); err != http.ErrServerClosed {
    			log.Fatalf("listen: %v\n", err)
    		}
    	}()
    	return srv
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Dec 04 22:47:52 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. src/net/http/example_test.go

    			// Error from closing listeners, or context timeout:
    			log.Printf("HTTP server Shutdown: %v", err)
    		}
    		close(idleConnsClosed)
    	}()
    
    	if err := srv.ListenAndServe(); err != http.ErrServerClosed {
    		// Error starting or closing listener:
    		log.Fatalf("HTTP server ListenAndServe: %v", err)
    	}
    
    	<-idleConnsClosed
    }
    
    func ExampleListenAndServeTLS() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 19 16:12:45 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  8. src/net/http/server.go

    // If srv.Addr is blank, ":http" is used.
    //
    // ListenAndServe always returns a non-nil error. After [Server.Shutdown] or [Server.Close],
    // the returned error is [ErrServerClosed].
    func (srv *Server) ListenAndServe() error {
    	if srv.shuttingDown() {
    		return ErrServerClosed
    	}
    	addr := srv.Addr
    	if addr == "" {
    		addr = ":http"
    	}
    	ln, err := net.Listen("tcp", addr)
    	if err != nil {
    		return err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  9. api/go1.8.txt

    pkg net/http, type Server struct, ReadHeaderTimeout time.Duration
    pkg net/http, type Transport struct, ProxyConnectHeader Header
    pkg net/http, var ErrAbortHandler error
    pkg net/http, var ErrServerClosed error
    pkg net/http, var NoBody noBody
    pkg net/mail, func ParseDate(string) (time.Time, error)
    pkg net, method (*Buffers) Read([]uint8) (int, error)
    pkg net, method (*Buffers) WriteTo(io.Writer) (int64, error)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Dec 21 05:25:57 UTC 2016
    - 16.3K bytes
    - Viewed (0)
  10. cmd/storage-rest-client.go

    	switch {
    	// A peer node can be in shut down phase and proactively
    	// return 503 server closed error, consider it as an offline node
    	case strings.Contains(err.Error(), http.ErrServerClosed.Error()):
    		return true
    	// Corner case, the server closed the connection with a keep-alive timeout
    	// some requests are not retried internally, such as POST request with written body
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
Back to top