- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 88 for Channels (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)