- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ErrServerClosed (0.12 sec)
-
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) -
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) -
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) -
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) -
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/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)