Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 134 for Channels (0.29 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt

                listOf(Channel, Standard).flatMap { socketMode ->
                  listOf(DISABLED, STANDARD).map { tlsExtensionMode ->
                    TlsInstance(provider, protocol, tlsVersion, socketMode, tlsExtensionMode)
                  }
                }
              }
            }
          } + Channel + Standard
      }
    }
    
    sealed class SocketMode
    
    object Channel : SocketMode() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 8K bytes
    - Viewed (0)
  2. src/test/java/jcifs/ntlmssp/av/AvChannelBindingsTest.java

    import static org.junit.jupiter.api.Assertions.assertNull;
    
    import org.junit.jupiter.api.Test;
    
    class AvChannelBindingsTest {
    
        /**
         * Test that the constructor correctly initializes with a valid channel binding hash.
         */
        @Test
        void testConstructorWithValidHash() {
            byte[] testHash = { 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08 };
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/multichannel/ChannelState.java

        /**
         * Channel binding in progress
         */
        BINDING(4),
    
        /**
         * Channel is actively transferring data
         */
        ACTIVE(5),
    
        /**
         * Channel connection has failed
         */
        FAILED(6),
    
        /**
         * Channel is being closed
         */
        CLOSING(7);
    
        private final int value;
    
        ChannelState(int value) {
            this.value = value;
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  4. cmd/service.go

    	// Close when we reach 0
    	globalServiceFreezeCnt--
    	if globalServiceFreezeCnt <= 0 {
    		// Set to a nil channel.
    		var _ch chan struct{}
    		if val := globalServiceFreeze.Swap(_ch); val != nil {
    			if ch, ok := val.(chan struct{}); ok && ch != nil {
    				// Close previous non-nil channel.
    				xioutil.SafeClose(ch)
    			}
    		}
    		globalServiceFreezeCnt = 0 // Don't risk going negative.
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/io/Smb2WriteRequest.java

            this.rdmaChannelInfo = new RdmaChannelInfo(remoteKey, address, length);
            this.channel = Smb2Constants.SMB2_CHANNEL_RDMA_V1;
        }
    
        /**
         * Get RDMA channel information
         *
         * @return RDMA channel info, or null if not using RDMA
         */
        public RdmaChannelInfo getRdmaChannelInfo() {
            return rdmaChannelInfo;
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbSessionImpl.java

                            // Handle potential multi-channel failure
                            if (isUseMultiChannel() && trans != this.transport) {
                                ChannelInfo channel = channelManager.getChannelForTransport(trans);
                                if (channel != null) {
                                    channelManager.handleChannelFailure(channel, e);
                                    // Retry with primary transport
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
  7. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java

      public UnixDomainSocketFactory(File path) {
        this.path = path;
      }
    
      @Override public Socket createSocket() throws IOException {
        UnixSocketChannel channel = UnixSocketChannel.open();
        return new TunnelingUnixSocket(path, channel);
      }
    
      @Override public Socket createSocket(String host, int port) throws IOException {
        Socket result = createSocket();
    
        try {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Dec 03 21:33:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt

          }
    
        val fileOperator = FileOperator(file!!.channel)
        fileOperator.write(0, header, FILE_HEADER_SIZE)
      }
    
      @Throws(IOException::class)
      private fun writeMetadata(upstreamSize: Long) {
        val metadataBuffer = Buffer()
        metadataBuffer.write(metadata)
    
        val fileOperator = FileOperator(file!!.channel)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 17:15:47 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/rdma/RdmaChannelInfo.java

     */
    package jcifs.internal.smb2.rdma;
    
    /**
     * RDMA channel information for SMB Direct operations.
     *
     * This class encapsulates RDMA channel metadata including remote memory keys,
     * addresses, and lengths for direct memory access operations.
     */
    public class RdmaChannelInfo {
    
        private final Smb2RdmaTransform transform;
    
        /**
         * Create new RDMA channel info
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  10. docs/security/README.md

    ##### Figure 1 - Secure Channel construction
    
    ```
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 13.8K bytes
    - Viewed (0)
Back to top