Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 198 for channel1 (0.2 seconds)

  1. build-tools-internal/src/main/resources/forbidden/es-server-signatures.txt

    java.lang.System#gc()
    
    @defaultMessage Use Channels.* methods to write to channels. Do not write directly.
    java.nio.channels.WritableByteChannel#write(java.nio.ByteBuffer)
    java.nio.channels.FileChannel#write(java.nio.ByteBuffer, long)
    java.nio.channels.GatheringByteChannel#write(java.nio.ByteBuffer[], int, int)
    java.nio.channels.GatheringByteChannel#write(java.nio.ByteBuffer[])
    java.nio.channels.ReadableByteChannel#read(java.nio.ByteBuffer)
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 08 16:53:28 GMT 2021
    - 7.6K bytes
    - Click Count (0)
  2. 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());
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  3. 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 {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 12 16:33:52 GMT 2019
    - 1.9K bytes
    - Click Count (0)
  4. 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;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt

      }
    
      @Test
      fun testHttp(socketMode: SocketMode = burstValues(Channel, Standard)) {
        testConnection(socketMode)
      }
    
      @Test
      fun testHttps(
        provider: Provider = Provider.JSSE,
        protocol: Protocol = burstValues(HTTP_1_1, HTTP_2),
        tlsVersion: TlsVersion = burstValues(TLS_1_3, TLS_1_2),
        socketMode: SocketMode = burstValues(Channel, Standard),
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 7.9K bytes
    - Click Count (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) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 4K bytes
    - Click Count (0)
  7. 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;
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  8. 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
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  9. internal/grid/stream.go

    // If the call is canceled through the context,
    // the appropriate error will be returned.
    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jun 07 15:51:52 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  10. 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 };
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 2.4K bytes
    - Click Count (0)
Back to Top