Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 311 for Closed1 (0.07 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

       *
       * If the call's connection exists and is eligible for another exchange, it is returned. If it
       * exists but cannot be used for another exchange, it is closed and this returns null.
       */
      private fun planReuseCallConnection(): ReusePlan? {
        // This may be mutated by releaseConnectionNoEvents()!
        val candidate = connectionUser.candidateConnection() ?: return null
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

        clientReaderWithCompression.close()
        assertFailsWith<Exception> {
          clientReaderWithCompression.processNextFrame()
        }.also { expected ->
          assertThat(expected.message!!).contains("closed")
        }
      }
    
      private fun binaryData(length: Int): ByteString {
        val junk = ByteArray(length)
        random.nextBytes(junk)
        return junk.toByteString()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

        handler: Handler,
        length: Int,
        flags: Int,
        streamId: Int,
      ) {
        if (streamId == 0) throw IOException("PROTOCOL_ERROR: TYPE_DATA streamId == 0")
    
        // TODO: checkState open or half-closed (local) or raise STREAM_CLOSED
        val inFinished = flags and FLAG_END_STREAM != 0
        val gzipped = flags and FLAG_COMPRESSED != 0
        if (gzipped) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server_test.go

    			return
    		case <-time.After(time.Second):
    			t.Fatal("Wait group timed out!\n")
    		}
    	}
    }
    
    func (wg *WaitGroup) Add(i int32) {
    	select {
    	case <-wg.done:
    		panic("use of an already closed WaitGroup")
    	default:
    	}
    	atomic.AddInt32(&wg.count, i)
    }
    
    func (wg *WaitGroup) Done() {
    	i := atomic.AddInt32(&wg.count, -1)
    	if i == 0 {
    		close(wg.done)
    	}
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. internal/grid/manager.go

    	Incoming     func(n int64) // Record incoming bytes.
    	Outgoing     func(n int64) // Record outgoing bytes.
    	BlockConnect chan struct{} // If set, incoming and outgoing connections will be blocked until closed.
    	RoutePath    string
    	TraceTo      *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]
    	Dialer       ConnDialer
    	// Sign a token for the given audience.
    	AuthFn AuthFn
    	// Callbacks to validate incoming connections.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. schema/schema.go

    		cacheStore:       cacheStore,
    		namer:            namer,
    		initialized:      make(chan struct{}),
    	}
    	// When the schema initialization is completed, the channel will be closed
    	defer close(schema.initialized)
    
    	// Load exist schema cache, return if exists
    	if v, ok := cacheStore.Load(schemaCacheKey); ok {
    		s := v.(*Schema)
    		// Wait for the initialization of other goroutines to complete
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 12:19:31 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbTransportImpl.java

             */
            try {
                this.socket.setSoTimeout(this.transportContext.getConfig().getConnTimeout());
                if ( peekKey() == null ) /* try to read header */
                    throw new IOException("transport closed in negotiate");
            }
            finally {
                this.socket.setSoTimeout(this.transportContext.getConfig().getSoTimeout());
            }
            int size = Encdec.dec_uint16be(this.sbuf, 2) & 0xFFFF;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  8. docs/changelogs/changelog_4x.md

     *  Upgrade: [Kotlin 1.6.20][kotlin_1_6_20].
     *  Upgrade: [Okio 3.0.0][okio_3_0_0].
     *  Fix: Recover gracefully when Android's `NativeCrypto` crashes with `"ssl == null"`. This occurs
        when OkHttp retrieves ALPN state on a closed connection.
    
    
    ## Version 4.9.3
    
    _2021-11-21_
    
     *  Fix: Don't fail HTTP/2 responses if they complete before a `RST_STREAM` is sent.
    
    
    ## Version 4.9.2
    
    _2021-09-30_
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/FinalizableReferenceQueue.java

     *
     * <p>As an example of how this is used, imagine you have a class {@code MyServer} that creates a
     * {@link java.net.ServerSocket ServerSocket}, and you would like to ensure that the {@code
     * ServerSocket} is closed even if the {@code MyServer} object is garbage-collected without calling
     * its {@code close} method. You could use a finalizer to accomplish this, but that has a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jul 11 20:51:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  10. CHANGELOG.md

        of unacknowledged data per stream and no per-connection limit.
    
     *  Fix: Don't close a `Deflater` while we're still using it to compress a web socket message. We
        had a severe bug where web sockets were closed on the wrong thread, which caused
        `NullPointerException` crashes in `Deflater`.
    
     *  Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
Back to top