- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for activeConnection (0.32 sec)
-
cmd/perf-tests.go
activeConnections uint64 sync.RWMutex } func (n *netPerfRX) Connect() { n.Lock() defer n.Unlock() n.activeConnections++ atomic.StoreUint64(&n.RX, 0) n.lastToConnect = time.Now() } func (n *netPerfRX) Disconnect() { n.Lock() defer n.Unlock() n.activeConnections-- if n.firstToDisconnect.IsZero() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/envoy/agent.go
if err != nil { log.Warnf("failed parsing Envoy stat %s (error: %s) line: %s", parts[0], err.Error(), line) continue } activeConnections += int(val) } if activeConnections > 0 { log.Debugf("Active connections stats: %s", stats.String()) } return activeConnections, nil } // runWait runs the start-up command as a go routine and waits for it to finish func (a *Agent) runWait(abortCh <-chan error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
pkg/proxy/ipvs/util/ipvs_linux.go
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. func toIPVSService(vs *VirtualServer) (*libipvs.Service, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 9K bytes - Viewed (0)