Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 88 for Channels (0.06 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/main/java/jcifs/internal/smb2/Smb2Constants.java

         */
        public static final long UNSPECIFIED_SESSIONID = 0xFFFFFFFFFFFFFFFFL;
    
        /**
         * SMB2 Channel constant for RDMA V1
         * Used in SMB2 READ and WRITE requests to indicate RDMA channel
         */
        public static final int SMB2_CHANNEL_RDMA_V1 = 0x00000001;
    
        /**
         * SMB2 Channel constant for RDMA V1 invalidate
         * Used to indicate RDMA with invalidation
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 4.5K 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. src/test/java/jcifs/smb/MultiChannelManagerBasicTest.java

            // This should fail because localhost doesn't support SMB multi-channel
            // but the method should not throw NullPointerException
            try {
                method.invoke(multiChannelManager, localhost, loopback);
                // If it doesn't throw, that's unexpected for localhost
                fail("Expected CIFSException for localhost multi-channel attempt");
            } catch (java.lang.reflect.InvocationTargetException e) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 4K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top