- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for closeConnection (0.18 sec)
-
pilot/pkg/xds/ads.go
// proxy defer con.MarkInitialized() // Complete full initialization of the proxy if err := s.initializeProxy(con); err != nil { s.closeConnection(con) return err } return nil } func (s *DiscoveryServer) closeConnection(con *Connection) { if con.ID() == "" { return } s.removeCon(con.ID()) if s.StatusReporter != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
return } if err := s.initConnection(req.Node, con, identities); err != nil { con.ErrorCh() <- err return } defer s.closeConnection(con) deltaLog.Infof("ADS: new delta connection for node:%s", con.ID()) } select { case con.deltaReqChan <- req: case <-con.deltaStream.Context().Done():
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(pool.closeConnections(50L)).isEqualTo(100L) assertThat(pool.connectionCount()).isEqualTo(1) assertThat(c1.socket().isClosed).isFalse() // Running at time 60, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(60L)).isEqualTo(90L) assertThat(pool.connectionCount()).isEqualTo(1)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
private val cleanupQueue: TaskQueue = taskRunner.newQueue() private val cleanupTask = object : Task("$okHttpName ConnectionPool connection closer") { override fun runOnce(): Long = closeConnections(System.nanoTime()) } private fun AddressState.scheduleOpener() { queue.schedule( object : Task("$okHttpName ConnectionPool connection opener") {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0)