- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for activeConns (0.17 sec)
-
src/net/http/h2_bundle.go
} type http2serverInternalState struct { mu sync.Mutex activeConns map[*http2serverConn]struct{} } func (s *http2serverInternalState) registerConn(sc *http2serverConn) { if s == nil { return // if the Server was used without calling ConfigureServer } s.mu.Lock() s.activeConns[sc] = struct{}{} s.mu.Unlock() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/net/http/export_test.go
s.mu.Lock() defer s.mu.Unlock() for c := range s.activeConn { st, unixSec := c.getState() if unixSec == 0 || st != StateIdle { return false } } return true } func (s *Server) ExportAllConnsByState() map[ConnState]int { states := map[ConnState]int{} s.mu.Lock() defer s.mu.Unlock() for c := range s.activeConn { st, _ := c.getState() states[st] += 1 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/proxy/ipvs/util/ipvs_linux.go
if dst == nil { return nil, errors.New("ipvs destination should not be empty") } return &RealServer{ Address: dst.Address, Port: dst.Port, Weight: dst.Weight, ActiveConn: dst.ActiveConnections, InactiveConn: dst.InactiveConnections, }, nil } // toIPVSService converts a VirtualServer to the equivalent IPVS Service structure.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 9K bytes - Viewed (0) -
src/net/http/server.go
} return true } func (s *Server) trackConn(c *conn, add bool) { s.mu.Lock() defer s.mu.Unlock() if s.activeConn == nil { s.activeConn = make(map[*conn]struct{}) } if add { s.activeConn[c] = struct{}{} } else { delete(s.activeConn, c) } } func (s *Server) idleTimeout() time.Duration { if s.IdleTimeout != 0 { return s.IdleTimeout }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
rss := []*utilipvs.RealServer{ { Address: netutils.ParseIPSloppy("10.10.10.10"), Port: 56, ActiveConn: 0, InactiveConn: 0, }, { Address: netutils.ParseIPSloppy("11.11.11.11"), Port: 56, ActiveConn: 0, InactiveConn: 0, }, } for _, rs := range rss { fp.ipvs.AddRealServer(vs, rs) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0)