Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 101 for established (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/jcifs/internal/smb2/Smb2EncryptionContext.java

            }
    
            return needsRotation;
        }
    
        /**
         * Reset key rotation tracking after new keys are established
         */
        public void resetKeyRotationTracking() {
            bytesEncrypted.set(0);
            encryptionStartTime = System.currentTimeMillis();
            log.debug("Key rotation tracking reset");
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

       * from the remote peer. Existing streams are not impacted. This is intended to permit an endpoint
       * to gracefully stop accepting new requests without harming previously established streams.
       */
      @Throws(IOException::class)
      fun shutdown(statusCode: ErrorCode) {
        writer.withLock {
          val lastGoodStreamId: Int
          withLock {
            if (isShutdown) {
              return
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  3. docs/changelogs/changelog_3x.md

        duplex request bodies. Such interceptors should check `RequestBody.isDuplex()` and avoid
        accessing the request body when it is.
    
        Duplex calls require HTTP/2. If HTTP/1 is established instead the duplex call will fail. The
        most common use of duplex calls is [gRPC][grpc_http2].
    
     *  New: Prevent OkHttp from retransmitting a request body by overriding `RequestBody.isOneShot()`.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

            channel1 = new ChannelInfo("channel1", mockTransport1, local, remote1);
            channel1.setState(ChannelState.ESTABLISHED);
    
            channel2 = new ChannelInfo("channel2", mockTransport2, local, remote2);
            channel2.setState(ChannelState.ESTABLISHED);
        }
    
        @Test
        void testSingleChannelSelection() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  5. tensorflow/c/eager/c_api_experimental.h

    // after the limit is reached blocks until some inflight nodes finishes.
    // The effect is bounding the memory held by inflight TensorHandles that are
    // referenced by the inflight nodes.
    // A recommended value has not been established.
    // A value of 0 removes the limit, which is the behavior of TensorFlow 2.11.
    // When is_async is false, the value is ignored.
    TF_CAPI_EXPORT extern TFE_Executor* TFE_NewExecutor(
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Wed Feb 21 22:37:46 GMT 2024
    - 39.5K bytes
    - Click Count (1)
  6. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

                // Connection would be ensured through proper transport interface
    
                // Re-establish channel binding
                manager.performChannelBinding(channel);
    
                // Update channel with new transport
                channel.setTransport(newTransport);
                channel.setState(ChannelState.ESTABLISHED);
    
                // Clear failover state on success
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool.go

    			healthy := erasureSetUpCount[poolIdx][setIdx].online >= poolWriteQuorums[poolIdx]
    			if !healthy && !opts.NoLogging {
    				storageLogIf(logger.SetReqInfo(ctx, reqInfo),
    					fmt.Errorf("Write quorum could not be established on pool: %d, set: %d, expected write quorum: %d, drives-online: %d",
    						poolIdx, setIdx, poolWriteQuorums[poolIdx], erasureSetUpCount[poolIdx][setIdx].online), logger.FatalKind)
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java

            failedChannel = new ChannelInfo("failed-channel", mockTransport, localInterface, remoteInterface);
            failedChannel.setState(ChannelState.ESTABLISHED);
    
            when(mockChannelManager.getLoadBalancer()).thenReturn(mockLoadBalancer);
        }
    
        @Test
        void testHandleFailure() {
            IOException error = new IOException("Connection failed");
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java

            ChannelInfo healthyChannel = new ChannelInfo("test-channel", mockTransport, localInterface, remoteInterface);
            healthyChannel.setState(ChannelState.ESTABLISHED);
    
            // Use reflection or package-private method to add channel for testing
            // For now, just test the empty case
            assertEquals(0, channelManager.getHealthyChannels().size());
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb/SmbTransportImpl.java

                }
                switch (this.sbuf[0] & 0xFF) {
                case SessionServicePacket.POSITIVE_SESSION_RESPONSE:
                    if (log.isDebugEnabled()) {
                        log.debug("session established ok with " + this.address);
                    }
                    return;
                case SessionServicePacket.NEGATIVE_SESSION_RESPONSE:
                    final int errorCode = this.in.read() & 0xFF;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 69.8K bytes
    - Click Count (0)
Back to Top