Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 32 for established (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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 success
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
Back to top