Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for isClosed (0.12 sec)

  1. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        assertThat(c1.socket().isClosed).isFalse()
        assertThat(c2.socket().isClosed).isFalse()
    
        // Add a third connection
        val c3 = factory.newConnection(pool, routeC1, 75L)
    
        // The third connection bounces the first.
        assertThat(pool.closeConnections(100L)).isEqualTo(0L)
        assertThat(pool.connectionCount()).isEqualTo(2)
        assertThat(c1.socket().isClosed).isTrue()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/base/FinalizableReferenceQueue.java

     *     Reference<?> reference = new FinalizablePhantomReference<MyServer>(myServer, frq) {
     *       public void finalizeReferent() {
     *         references.remove(this):
     *         if (!serverSocket.isClosed()) {
     *           ...log a message about how nobody called close()...
     *           try {
     *             serverSocket.close();
     *           } catch (IOException e) {
     *             ...
     *           }
     *         }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jul 11 20:51:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		defer c.connMu.Unlock()
    		c.clientPingInterval = args[0].(time.Duration)
    	case debugAddToDeadline:
    		c.addDeadline = args[0].(time.Duration)
    	case debugIsOutgoingClosed:
    		// params: muxID uint64, isClosed func(bool)
    		muxID := args[0].(uint64)
    		resp := args[1].(func(b bool))
    		mid, ok := c.outgoing.Load(muxID)
    		if !ok || mid == nil {
    			resp(true)
    			return
    		}
    		mid.respMu.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top