- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 198 for channel1 (0.2 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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.CancelCauseFuncCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jun 07 15:51:52 GMT 2024 - 3.1K bytes - Click Count (0) -
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)