Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 157 for channel1 (0.05 sec)

  1. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

      private final File path;
      private InetSocketAddress inetSocketAddress;
    
      TunnelingUnixSocket(File path, UnixSocketChannel channel) {
        super(channel);
        this.path = path;
      }
    
      TunnelingUnixSocket(File path, UnixSocketChannel channel, InetSocketAddress address) {
        this(path, channel);
        this.inetSocketAddress = address;
      }
    
      @Override public void connect(SocketAddress endpoint) throws IOException {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  2. .teamcity/src/main/kotlin/model/PerformanceTestSpec.kt

            model: CIBuildModel,
            bucket: String,
        ): String
    
        fun channel(): String
    }
    
    interface PerformanceTestProjectSpec {
        val os: Os
        val type: PerformanceTestType
        val failsStage: Boolean
    
        fun asConfigurationId(model: CIBuildModel): String
    
        fun asName(): String
    
        fun channel(): String
    }
    
    data class PerformanceTestPartialTrigger(
        val triggerName: String,
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 12 09:12:03 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java

            remoteInterface = new NetworkInterfaceInfo(remoteAddr, 1000);
    
            channelInfo = new ChannelInfo("test-channel", mockTransport, localInterface, remoteInterface);
        }
    
        @Test
        void testConstructor() {
            assertEquals("test-channel", channelInfo.getChannelId());
            assertEquals(mockTransport, channelInfo.getTransport());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top