- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for heartBeat (0.04 sec)
-
src/main/java/jcifs/internal/witness/WitnessHeartbeatMessage.java
} /** * Gets the heartbeat interval recommended by the server (in milliseconds). * The client can use this to adjust the heartbeat frequency. * * @return the heartbeat interval in milliseconds */ public long getHeartbeatInterval() { return heartbeatInterval; } /** * Sets the heartbeat interval. *
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 5.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessRegistration.java
return sequenceNumber.incrementAndGet(); } /** * Updates the heartbeat timestamp to current time and resets failure count. */ public void updateHeartbeat() { this.lastHeartbeat = System.currentTimeMillis(); this.heartbeatFailures = 0; } /** * Increments the heartbeat failure count. */ public void incrementHeartbeatFailures() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Mon Aug 25 14:34:10 UTC 2025 - 6.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessHeartbeatResponse.java
} /** * Gets the recommended heartbeat interval. * * @return the recommended heartbeat interval in milliseconds */ public long getRecommendedHeartbeatInterval() { return recommendedHeartbeatInterval; } /** * Sets the recommended heartbeat interval. * * @param recommendedHeartbeatInterval the recommended heartbeat interval in milliseconds */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessHeartbeatRequest.java
*/ package jcifs.internal.witness; /** * Represents a witness heartbeat request as defined in MS-SWN specification. * Used to maintain active witness registrations. */ public class WitnessHeartbeatRequest { /** * Creates a new witness heartbeat request. */ public WitnessHeartbeatRequest() { // Default constructor }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 2.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/witness/MockWitnessService.java
} catch (IOException e) { return "ncacn_ip_tcp:127.0.0.1[135]"; } } /** * Simulate heartbeat processing * * @param registrationId the registration ID * @param sequenceNumber the sequence number * @return true if heartbeat was successful */ public boolean processHeartbeat(String registrationId, long sequenceNumber) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 8.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/witness/WitnessRegistrationTest.java
registration.updateHeartbeat(); // After update, should not be expired with long timeout assertFalse(registration.isExpired(60000)); // Verify heartbeat was actually updated assertTrue(registration.getLastHeartbeat() > initialTime); } @Test void testExpiration() throws InterruptedException {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 5.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessRpcMessage.java
/** WitnessUnregister operation number */ public static final int WITNESS_UNREGISTER = 1; /** WitnessAsyncNotify operation number */ public static final int WITNESS_ASYNC_NOTIFY = 2; /** Witness heartbeat operation number */ public static final int WITNESS_HEARTBEAT = 3; // Common return codes from MS-SWN specification /** Operation completed successfully */ public static final int ERROR_SUCCESS = 0x00000000;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 5.5K bytes - Viewed (0)