Searched refs:heartbeatInterval (Results 1 - 25 of 72) sorted by relevance

123

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DHeartbeatMonitor.java56 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 DCTHeartbeatPublisherThread.java57 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 DHeartbeatThread.java66 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 DCTHeartbeatPublisherThread.java63 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 DHeartbeatMonitor.java64 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 DHeartbeatThread.java67 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 DServerStartMsg.java56 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 DCTHeartbeatPublisherThread.java63 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 DHeartbeatMonitor.java63 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 DHeartbeatThread.java66 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 DCTHeartbeatPublisherThread.java63 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 DHeartbeatMonitor.java64 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 DHeartbeatThread.java66 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 DCTHeartbeatPublisherThread.java63 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 DHeartbeatMonitor.java64 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 DHeartbeatThread.java67 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 DServerStartMsg.java56 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 DCTHeartbeatPublisherThread.java63 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 DHeartbeatMonitor.java63 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 DHeartbeatThread.java61 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 DServerStartMsg.java56 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 DFakeReplicationDomain.java69 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 DFakeReplicationDomain.java69 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 DFakeReplicationDomain.java69 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 DFakeReplicationDomain.java75 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

Completed in 62 milliseconds

123