- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 157 for channel1 (0.05 sec)
-
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) -
.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) -
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) -
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) -
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/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/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/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) -
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)