/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | HeartbeatMonitor.java | 56 private final long heartbeatInterval; field in class:HeartbeatMonitor 80 * @param heartbeatInterval 85 String baseDN, Session session, long heartbeatInterval) 95 this.heartbeatInterval = heartbeatInterval; 117 heartbeatInterval); 127 if (now > lastReceiveTime + heartbeatInterval) 156 shutdownLock.wait(heartbeatInterval); 84 HeartbeatMonitor(int serverID, int replicationServerID, String baseDN, Session session, long heartbeatInterval) argument
|
H A D | CTHeartbeatPublisherThread.java | 57 private final long heartbeatInterval; field in class:CTHeartbeatPublisherThread 70 * @param heartbeatInterval The interval between heartbeats sent 75 long heartbeatInterval, int serverId) 79 this.heartbeatInterval = heartbeatInterval; 92 heartbeatInterval); 98 if (now > session.getLastPublishTime() + heartbeatInterval) 104 long sleepTime = session.getLastPublishTime() + heartbeatInterval - now; 107 sleepTime = heartbeatInterval; 74 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId) argument
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatThread.java | 66 private final long heartbeatInterval; field in class:HeartbeatThread 80 * @param heartbeatInterval The desired interval between heartbeats in 84 long heartbeatInterval) 88 this.heartbeatInterval = heartbeatInterval; 102 heartbeatInterval); 115 if (now > session.getLastPublishTime() + heartbeatInterval) 128 heartbeatInterval - now; 131 sleepTime = heartbeatInterval; 83 HeartbeatThread(String threadName, Session session, long heartbeatInterval) argument
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | CTHeartbeatPublisherThread.java | 63 private final long heartbeatInterval; field in class:CTHeartbeatPublisherThread 76 * @param heartbeatInterval The interval between heartbeats sent 81 long heartbeatInterval, int serverId2) 85 this.heartbeatInterval = heartbeatInterval; 100 heartbeatInterval); 110 if (now > session.getLastPublishTime() + heartbeatInterval) 116 heartbeatInterval - now; 119 sleepTime = heartbeatInterval; 80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId2) argument
|
H A D | HeartbeatMonitor.java | 64 private final long heartbeatInterval; field in class:HeartbeatMonitor 91 * @param heartbeatInterval 96 String baseDN, Session session, long heartbeatInterval) 106 this.heartbeatInterval = heartbeatInterval; 130 heartbeatInterval); 140 if (now > lastReceiveTime + heartbeatInterval) 170 shutdownLock.wait(heartbeatInterval); 95 HeartbeatMonitor(int serverID, int replicationServerID, String baseDN, Session session, long heartbeatInterval) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatThread.java | 67 private final long heartbeatInterval; field in class:HeartbeatThread 81 * @param heartbeatInterval The desired interval between heartbeats in 85 long heartbeatInterval) 89 this.heartbeatInterval = heartbeatInterval; 103 heartbeatInterval); 116 if (now > session.getLastPublishTime() + heartbeatInterval) 128 long sleepTime = session.getLastPublishTime() + heartbeatInterval - now; 131 sleepTime = heartbeatInterval; 84 HeartbeatThread(String threadName, Session session, long heartbeatInterval) argument
|
H A D | ServerStartMsg.java | 56 private final long heartbeatInterval; field in class:ServerStartMsg 74 * @param heartbeatInterval The requested heartbeat interval. 82 int windowSize, long heartbeatInterval, ServerState serverState, 96 this.heartbeatInterval = heartbeatInterval; 123 heartbeatInterval = scanner.nextIntUTF8(); 216 builder.appendLongUTF8(heartbeatInterval); 241 return heartbeatInterval; 265 "\nheartbeatInterval: " + heartbeatInterval + 81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | CTHeartbeatPublisherThread.java | 63 private final long heartbeatInterval; field in class:CTHeartbeatPublisherThread 76 * @param heartbeatInterval The interval between heartbeats sent 81 long heartbeatInterval, int serverId) 85 this.heartbeatInterval = heartbeatInterval; 101 heartbeatInterval); 107 if (now > session.getLastPublishTime() + heartbeatInterval) 114 long sleepTime = session.getLastPublishTime() + heartbeatInterval - now; 117 sleepTime = heartbeatInterval; 80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId) argument
|
H A D | HeartbeatMonitor.java | 63 private final long heartbeatInterval; field in class:HeartbeatMonitor 90 * @param heartbeatInterval 95 String baseDN, Session session, long heartbeatInterval) 105 this.heartbeatInterval = heartbeatInterval; 129 heartbeatInterval); 139 if (now > lastReceiveTime + heartbeatInterval) 169 shutdownLock.wait(heartbeatInterval); 94 HeartbeatMonitor(int serverID, int replicationServerID, String baseDN, Session session, long heartbeatInterval) argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatThread.java | 66 private final long heartbeatInterval; field in class:HeartbeatThread 80 * @param heartbeatInterval The desired interval between heartbeats in 84 long heartbeatInterval) 88 this.heartbeatInterval = heartbeatInterval; 102 heartbeatInterval); 115 if (now > session.getLastPublishTime() + heartbeatInterval) 128 heartbeatInterval - now; 131 sleepTime = heartbeatInterval; 83 HeartbeatThread(String threadName, Session session, long heartbeatInterval) argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | CTHeartbeatPublisherThread.java | 63 private final long heartbeatInterval; field in class:CTHeartbeatPublisherThread 76 * @param heartbeatInterval The interval between heartbeats sent 81 long heartbeatInterval, int serverId2) 85 this.heartbeatInterval = heartbeatInterval; 100 heartbeatInterval); 110 if (now > session.getLastPublishTime() + heartbeatInterval) 116 heartbeatInterval - now; 119 sleepTime = heartbeatInterval; 80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId2) argument
|
H A D | HeartbeatMonitor.java | 64 private final long heartbeatInterval; field in class:HeartbeatMonitor 91 * @param heartbeatInterval 96 String baseDN, Session session, long heartbeatInterval) 106 this.heartbeatInterval = heartbeatInterval; 130 heartbeatInterval); 140 if (now > lastReceiveTime + heartbeatInterval) 170 shutdownLock.wait(heartbeatInterval); 95 HeartbeatMonitor(int serverID, int replicationServerID, String baseDN, Session session, long heartbeatInterval) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatThread.java | 66 private final long heartbeatInterval; field in class:HeartbeatThread 80 * @param heartbeatInterval The desired interval between heartbeats in 84 long heartbeatInterval) 88 this.heartbeatInterval = heartbeatInterval; 102 heartbeatInterval); 115 if (now > session.getLastPublishTime() + heartbeatInterval) 128 heartbeatInterval - now; 131 sleepTime = heartbeatInterval; 83 HeartbeatThread(String threadName, Session session, long heartbeatInterval) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | CTHeartbeatPublisherThread.java | 63 private final long heartbeatInterval; field in class:CTHeartbeatPublisherThread 76 * @param heartbeatInterval The interval between heartbeats sent 81 long heartbeatInterval, int serverId2) 85 this.heartbeatInterval = heartbeatInterval; 100 heartbeatInterval); 110 if (now > session.getLastPublishTime() + heartbeatInterval) 116 heartbeatInterval - now; 119 sleepTime = heartbeatInterval; 80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId2) argument
|
H A D | HeartbeatMonitor.java | 64 private final long heartbeatInterval; field in class:HeartbeatMonitor 91 * @param heartbeatInterval 96 String baseDN, Session session, long heartbeatInterval) 106 this.heartbeatInterval = heartbeatInterval; 130 heartbeatInterval); 140 if (now > lastReceiveTime + heartbeatInterval) 170 shutdownLock.wait(heartbeatInterval); 95 HeartbeatMonitor(int serverID, int replicationServerID, String baseDN, Session session, long heartbeatInterval) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatThread.java | 67 private final long heartbeatInterval; field in class:HeartbeatThread 81 * @param heartbeatInterval The desired interval between heartbeats in 85 long heartbeatInterval) 89 this.heartbeatInterval = heartbeatInterval; 103 heartbeatInterval); 116 if (now > session.getLastPublishTime() + heartbeatInterval) 128 long sleepTime = session.getLastPublishTime() + heartbeatInterval - now; 131 sleepTime = heartbeatInterval; 84 HeartbeatThread(String threadName, Session session, long heartbeatInterval) argument
|
H A D | ServerStartMsg.java | 56 private final long heartbeatInterval; field in class:ServerStartMsg 74 * @param heartbeatInterval The requested heartbeat interval. 82 int windowSize, long heartbeatInterval, ServerState serverState, 96 this.heartbeatInterval = heartbeatInterval; 123 heartbeatInterval = scanner.nextIntUTF8(); 216 builder.appendLongUTF8(heartbeatInterval); 241 return heartbeatInterval; 265 "\nheartbeatInterval: " + heartbeatInterval + 81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | CTHeartbeatPublisherThread.java | 63 private final long heartbeatInterval; field in class:CTHeartbeatPublisherThread 76 * @param heartbeatInterval The interval between heartbeats sent 81 long heartbeatInterval, int serverId) 85 this.heartbeatInterval = heartbeatInterval; 101 heartbeatInterval); 107 if (now > session.getLastPublishTime() + heartbeatInterval) 114 long sleepTime = session.getLastPublishTime() + heartbeatInterval - now; 117 sleepTime = heartbeatInterval; 80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId) argument
|
H A D | HeartbeatMonitor.java | 63 private final long heartbeatInterval; field in class:HeartbeatMonitor 90 * @param heartbeatInterval 95 String baseDN, Session session, long heartbeatInterval) 105 this.heartbeatInterval = heartbeatInterval; 129 heartbeatInterval); 139 if (now > lastReceiveTime + heartbeatInterval) 169 shutdownLock.wait(heartbeatInterval); 94 HeartbeatMonitor(int serverID, int replicationServerID, String baseDN, Session session, long heartbeatInterval) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | HeartbeatThread.java | 61 private final long heartbeatInterval; field in class:HeartbeatThread 75 * @param heartbeatInterval The desired interval between heartbeats in 79 long heartbeatInterval) 83 this.heartbeatInterval = heartbeatInterval; 95 heartbeatInterval); 108 if (now > session.getLastPublishTime() + heartbeatInterval 118 long sleepTime = session.getLastPublishTime() + heartbeatInterval - now; 121 sleepTime = heartbeatInterval; 78 HeartbeatThread(String threadName, Session session, long heartbeatInterval) argument
|
H A D | ServerStartMsg.java | 56 private final long heartbeatInterval; field in class:ServerStartMsg 74 * @param heartbeatInterval The requested heartbeat interval. 82 int windowSize, long heartbeatInterval, ServerState serverState, 96 this.heartbeatInterval = heartbeatInterval; 123 heartbeatInterval = scanner.nextIntUTF8(); 216 builder.appendLongUTF8(heartbeatInterval); 241 return heartbeatInterval; 265 "\nheartbeatInterval: " + heartbeatInterval + 81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 69 SortedSet<String> replicationServers, int window, long heartbeatInterval, 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 78 SortedSet<String> replicationServers, int window, long heartbeatInterval) 81 fakeCfg.setHeartbeatInterval(heartbeatInterval); 88 SortedSet<String> replicationServers, long heartbeatInterval, 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 95 SortedSet<String> replicationServers, int window, long heartbeatInterval, 98 this(baseDN, serverID, replicationServers, window, heartbeatInterval, 1); 103 SortedSet<String> replicationServers, long heartbeatInterval, 107 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, 68 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, long generationId) argument 77 newConfig(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval) argument 87 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, long generationId) argument 94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument 102 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, String exportString, StringBuilder importString, int exportedEntryCount) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 69 SortedSet<String> replicationServers, int window, long heartbeatInterval, 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 78 SortedSet<String> replicationServers, int window, long heartbeatInterval) 81 fakeCfg.setHeartbeatInterval(heartbeatInterval); 88 SortedSet<String> replicationServers, long heartbeatInterval, 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 95 SortedSet<String> replicationServers, int window, long heartbeatInterval, 98 this(baseDN, serverID, replicationServers, window, heartbeatInterval, 1); 103 SortedSet<String> replicationServers, long heartbeatInterval, 107 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, 68 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, long generationId) argument 77 newConfig(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval) argument 87 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, long generationId) argument 94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument 102 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, String exportString, StringBuilder importString, int exportedEntryCount) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 69 SortedSet<String> replicationServers, int window, long heartbeatInterval, 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 78 SortedSet<String> replicationServers, int window, long heartbeatInterval) 81 fakeCfg.setHeartbeatInterval(heartbeatInterval); 88 SortedSet<String> replicationServers, long heartbeatInterval, 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 95 SortedSet<String> replicationServers, int window, long heartbeatInterval, 98 this(baseDN, serverID, replicationServers, window, heartbeatInterval, 1); 103 SortedSet<String> replicationServers, long heartbeatInterval, 107 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, 68 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, long generationId) argument 77 newConfig(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval) argument 87 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, long generationId) argument 94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument 102 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, String exportString, StringBuilder importString, int exportedEntryCount) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 75 long heartbeatInterval, 79 startPublishService(replicationServers, window, heartbeatInterval, 500); 89 long heartbeatInterval, 95 startPublishService(replicationServers, window, heartbeatInterval, 500); 70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument 84 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, String exportString, StringBuilder importString, int exportedEntryCount) argument
|