- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for established (0.04 sec)
-
src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java
} } @Override public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException { if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) { throw new IOException("Connection not established"); } try { // In real implementation, this would send using DiSNI:Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 10.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java
*/ public enum RdmaConnectionState { /** Connection is not established */ DISCONNECTED, /** Connection is being established */ CONNECTING, /** Connection is established but not ready for RDMA operations */ CONNECTED, /** Connection is fully established and ready for RDMA operations */ ESTABLISHED, /** Connection encountered an error */ ERROR,Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 8.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java
log.debug("TCP RDMA connection established to {}", remoteAddress); } catch (IOException e) { state = RdmaConnectionState.ERROR; throw new IOException("TCP RDMA connection failed", e); } } @Override public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException { if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java
void testStateTransitions() { assertEquals(ChannelState.DISCONNECTED, channelInfo.getState()); assertFalse(channelInfo.isHealthy()); channelInfo.setState(ChannelState.ESTABLISHED); assertEquals(ChannelState.ESTABLISHED, channelInfo.getState()); assertTrue(channelInfo.isHealthy()); channelInfo.setState(ChannelState.ACTIVE); assertTrue(channelInfo.isHealthy());
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/multichannel/ChannelInfo.java
* Set channel state * * @param state new state */ public void setState(ChannelState state) { this.state = state; } /** * Get the time when channel was established * * @return establishment time in milliseconds */ public long getEstablishedTime() { return establishedTime; } /** * Get the last activity time *Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 10.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelState.java
* Connection establishment in progress */ CONNECTING(1), /** * Authentication in progress */ AUTHENTICATING(2), /** * Channel is established and ready for use */ ESTABLISHED(3), /** * Channel binding in progress */ BINDING(4), /** * Channel is actively transferring data */ ACTIVE(5), /**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/internal/smb2/multichannel/ChannelLoadBalancerTest.java
channel1 = new ChannelInfo("channel1", mockTransport1, local, remote1); channel1.setState(ChannelState.ESTABLISHED); channel2 = new ChannelInfo("channel2", mockTransport2, local, remote2); channel2.setState(ChannelState.ESTABLISHED); } @Test void testSingleChannelSelection() {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 7.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java
channel.setState(ChannelState.ESTABLISHED); // Verify channel properties assertEquals("test-channel", channel.getChannelId()); assertEquals(mockTransport, channel.getTransport()); assertEquals(localNic, channel.getLocalInterface()); assertEquals(remoteNic, channel.getRemoteInterface()); assertEquals(ChannelState.ESTABLISHED, channel.getState());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 8.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaProvider.java
/** * Connect to a remote RDMA endpoint * * @param hostname remote hostname or IP address * @param port remote port number * @return established RDMA connection * @throws IOException if connection fails */ RdmaConnection connect(String hostname, int port) throws IOException; /** * Register memory region for RDMA operations *Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
// Connection would be ensured through proper transport interface // Re-establish channel binding manager.performChannelBinding(channel); // Update channel with new transport channel.setTransport(newTransport); channel.setState(ChannelState.ESTABLISHED); // Clear failover state on successRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K bytes - Viewed (0)