- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ErrServerClosed (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
src/net/http/serve_test.go
func TestServerShutdownThenServe(t *testing.T) { var srv Server cl := &countCloseListener{Listener: nil} srv.Shutdown(context.Background()) got := srv.Serve(cl) if got != ErrServerClosed { t.Errorf("Serve err = %v; want ErrServerClosed", got) } nclose := atomic.LoadInt32(&cl.closes) if nclose != 1 { t.Errorf("Close calls = %v; want 1", nclose) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"ErrMissingFile", Var, 0}, {"ErrNoCookie", Var, 0}, {"ErrNoLocation", Var, 0}, {"ErrNotMultipart", Var, 0}, {"ErrNotSupported", Var, 0}, {"ErrSchemeMismatch", Var, 21}, {"ErrServerClosed", Var, 8}, {"ErrShortBody", Var, 0}, {"ErrSkipAltProtocol", Var, 6}, {"ErrUnexpectedTrailer", Var, 0}, {"ErrUseLastResponse", Var, 7}, {"ErrWriteAfterFlush", Var, 0}, {"Error", Func, 0},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0)