- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 53 for Setstat (0.08 seconds)
-
src/test/java/jcifs/internal/witness/WitnessRegistrationTest.java
registration.setState(WitnessRegistrationState.REGISTERED); assertEquals(WitnessRegistrationState.REGISTERED, registration.getState()); registration.setState(WitnessRegistrationState.UNREGISTERING); assertEquals(WitnessRegistrationState.UNREGISTERING, registration.getState()); registration.setState(WitnessRegistrationState.FAILED);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 23 09:06:40 GMT 2025 - 5.1K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java
assertEquals(ChannelState.ESTABLISHED, channelInfo.getState()); assertTrue(channelInfo.isHealthy()); channelInfo.setState(ChannelState.ACTIVE); assertTrue(channelInfo.isHealthy()); channelInfo.setState(ChannelState.FAILED); assertFalse(channelInfo.isHealthy()); } @Test void testActivityTracking() {
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 7.4K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java
channel.setState(ChannelState.ESTABLISHED); // Simulate failure IOException failure = new IOException("Connection lost"); failover.handleFailure(channel, failure); // Verify channel state changed assertFalse(channel.isHealthy()); assertEquals(ChannelState.FAILED, channel.getState()); } @TestCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 8.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
WitnessRegisterResponse response = rpcClient.register(request); if (response != null && response.isSuccess()) { registration.setState(WitnessRegistrationState.REGISTERED); registration.setContextHandle(response.getContextHandle()); registrations.put(registration.getRegistrationId(), registration);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 20.8K bytes - Click Count (0) -
docs/smb3-features/06-witness-protocol-design.md
public InetAddress getServerAddress() { return serverAddress; } public WitnessServiceType getServiceType() { return serviceType; } public WitnessRegistrationState getState() { return state; } public void setState(WitnessRegistrationState state) { this.state = state; } } ``` ### 4.2 Witness Notification ```java package jcifs.internal.witness; import java.util.List;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 42K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java
failedChannel.setState(ChannelState.ESTABLISHED); when(mockChannelManager.getLoadBalancer()).thenReturn(mockLoadBalancer); } @Test void testHandleFailure() { IOException error = new IOException("Connection failed"); failover.handleFailure(failedChannel, error); assertEquals(ChannelState.FAILED, failedChannel.getState());Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 7.7K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessRegistration.java
* * @return the current registration state */ public WitnessRegistrationState getState() { return state; } /** * Sets the registration state. * * @param state the new registration state */ public void setState(WitnessRegistrationState state) { this.state = state; } /** * Gets the registration flags.Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Mon Aug 25 14:34:10 GMT 2025 - 6.7K bytes - Click Count (0) -
docs/smb3-features/03-multi-channel-design.md
// Establish connection channel.setState(ChannelState.CONNECTING); transport.connect(); // Perform channel binding performChannelBinding(channel); // Add to active channels channels.put(channelId, channel); channel.setState(ChannelState.ESTABLISHED);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 39.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java
} /** * Get current channel state * * @return channel state */ public ChannelState getState() { return state; } /** * Set channel state * * @param state new state */ public void setState(ChannelState state) { this.state = state; } /** * Get the time when channel was established *Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 10.6K bytes - Click Count (0) -
src/test/java/jcifs/util/SimpleCircuitBreakerTest.java
assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState()); // Wait for timeout Thread.sleep(150); // Next call should transition to HALF_OPEN String result = circuitBreaker.call(() -> "success"); assertEquals("success", result); assertEquals(SimpleCircuitBreaker.State.HALF_OPEN, circuitBreaker.getState()); } @Test
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 10.6K bytes - Click Count (0)