Searched refs:serverState (Results 1 - 25 of 81) sorted by relevance

1234

/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java65 ServerState serverState = new ServerState() ;
68 // serverState.loadState() ;
72 assertFalse(serverState.update((ChangeNumber)null));
73 assertTrue(serverState.update(cn));
74 assertFalse(serverState.update(cn));
80 assertTrue(serverState.update(cn1)) ;
81 assertTrue(serverState.update(cn2)) ;
82 assertTrue(serverState.update(cn3)) ;
86 Set<String> stringSet = serverState.toStringSet();
91 assertEquals(cn2.compareTo(serverState
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java65 ServerState serverState = new ServerState() ;
68 // serverState.loadState() ;
72 assertFalse(serverState.update((ChangeNumber)null));
73 assertTrue(serverState.update(cn));
74 assertFalse(serverState.update(cn));
80 assertTrue(serverState.update(cn1)) ;
81 assertTrue(serverState.update(cn2)) ;
82 assertTrue(serverState.update(cn3)) ;
86 Set<String> stringSet = serverState.toStringSet();
91 assertEquals(cn2.compareTo(serverState
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java65 ServerState serverState = new ServerState() ;
68 // serverState.loadState() ;
72 assertFalse(serverState.update((ChangeNumber)null));
73 assertTrue(serverState.update(cn));
74 assertFalse(serverState.update(cn));
80 assertTrue(serverState.update(cn1)) ;
81 assertTrue(serverState.update(cn2)) ;
82 assertTrue(serverState.update(cn3)) ;
86 Set<String> stringSet = serverState.toStringSet();
91 assertEquals(cn2.compareTo(serverState
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java44 private final ServerState serverState; field in class:ReplServerStartMsg
74 * @param serverState our ServerState for this baseDN.
83 ServerState serverState,
94 this.serverState = serverState;
115 * <degradedStatusThreshold><serverState>
128 serverState = scanner.nextServerStateMustComeLast();
160 * Get the serverState.
161 * @return Returns the serverState.
165 return this.serverState;
81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java44 private final ServerState serverState; field in class:ReplServerStartDSMsg
76 * @param serverState our ServerState for this baseDN.
88 ServerState serverState,
101 this.serverState = serverState;
124 * <serverState>
134 serverState = scanner.nextServerStateMustComeLast();
166 * Get the serverState.
167 * @return Returns the serverState.
171 return this.serverState;
86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartMsg.java50 private final ServerState serverState; field in class:ServerStartMsg
75 * @param serverState The state of this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
98 this.serverState = serverState;
125 serverState = scanner.nextServerStateMustComeLast();
198 return serverState;
218 builder.appendServerStateMustComeLast(serverState);
271 "\nserverState: " + serverState +
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/protocol/
H A DReplServerStartMsg.java44 private final ServerState serverState; field in class:ReplServerStartMsg
74 * @param serverState our ServerState for this baseDN.
83 ServerState serverState,
94 this.serverState = serverState;
115 * <degradedStatusThreshold><serverState>
128 serverState = scanner.nextServerStateMustComeLast();
160 * Get the serverState.
161 * @return Returns the serverState.
165 return this.serverState;
81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java44 private final ServerState serverState; field in class:ReplServerStartDSMsg
76 * @param serverState our ServerState for this baseDN.
88 ServerState serverState,
101 this.serverState = serverState;
124 * <serverState>
134 serverState = scanner.nextServerStateMustComeLast();
166 * Get the serverState.
167 * @return Returns the serverState.
171 return this.serverState;
86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartMsg.java50 private final ServerState serverState; field in class:ServerStartMsg
75 * @param serverState The state of this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
98 this.serverState = serverState;
125 serverState = scanner.nextServerStateMustComeLast();
198 return serverState;
218 builder.appendServerStateMustComeLast(serverState);
271 "\nserverState: " + serverState +
81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java44 private final ServerState serverState; field in class:ReplServerStartMsg
74 * @param serverState our ServerState for this baseDN.
83 ServerState serverState,
94 this.serverState = serverState;
115 * <degradedStatusThreshold><serverState>
128 serverState = scanner.nextServerStateMustComeLast();
160 * Get the serverState.
161 * @return Returns the serverState.
165 return this.serverState;
81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java44 private final ServerState serverState; field in class:ReplServerStartDSMsg
76 * @param serverState our ServerState for this baseDN.
88 ServerState serverState,
101 this.serverState = serverState;
124 * <serverState>
134 serverState = scanner.nextServerStateMustComeLast();
166 * Get the serverState.
167 * @return Returns the serverState.
171 return this.serverState;
86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartMsg.java50 private final ServerState serverState; field in class:ServerStartMsg
75 * @param serverState The state of this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
98 this.serverState = serverState;
125 serverState = scanner.nextServerStateMustComeLast();
198 return serverState;
218 builder.appendServerStateMustComeLast(serverState);
271 "\nserverState: " + serverState +
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/common/
H A DMultiDomainServerState.java110 ServerState serverState = list.get(baseDN);
111 if (serverState == null)
113 serverState = new ServerState();
114 final ServerState existingSS = list.putIfAbsent(baseDN, serverState);
117 serverState = existingSS;
120 return serverState.update(csn);
129 * @param serverState
130 * The provided serverState.
132 public void update(DN baseDN, ServerState serverState) argument
134 for (CSN csn : serverState)
150 replace(DN baseDN, ServerState serverState) argument
[all...]
H A DServerState.java123 * @param serverState the server state to use for the update.
126 public boolean update(ServerState serverState) argument
128 if (serverState == null)
134 for (CSN csn : serverState.serverIdToCSN.values())
170 * @param serverState The ServerState.
174 public boolean reload(ServerState serverState) { argument
175 if (serverState == null) {
180 return update(serverState);
310 * Check that all the CSNs in the covered serverState are also in this
311 * serverState
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java64 ServerState serverState = new ServerState() ;
67 // serverState.loadState() ;
71 assertFalse(serverState.update((CSN)null));
72 assertTrue(serverState.update(csn));
73 assertFalse(serverState.update(csn));
78 assertTrue(serverState.update(csn1));
79 assertTrue(serverState.update(csn2));
80 assertTrue(serverState.update(csn3));
84 Set<String> stringSet = serverState.toStringSet();
89 assertEquals(csn2.compareTo(serverState
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java64 ServerState serverState = new ServerState() ;
67 // serverState.loadState() ;
71 assertFalse(serverState.update((CSN)null));
72 assertTrue(serverState.update(csn));
73 assertFalse(serverState.update(csn));
78 assertTrue(serverState.update(csn1));
79 assertTrue(serverState.update(csn2));
80 assertTrue(serverState.update(csn3));
84 Set<String> stringSet = serverState.toStringSet();
89 assertEquals(csn2.compareTo(serverState
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/
H A DMultiDomainServerState.java110 ServerState serverState = list.get(baseDN);
111 if (serverState == null)
113 serverState = new ServerState();
114 final ServerState existingSS = list.putIfAbsent(baseDN, serverState);
117 serverState = existingSS;
120 return serverState.update(csn);
129 * @param serverState
130 * The provided serverState.
132 public void update(DN baseDN, ServerState serverState) argument
134 for (CSN csn : serverState)
150 replace(DN baseDN, ServerState serverState) argument
[all...]
H A DServerState.java123 * @param serverState the server state to use for the update.
126 public boolean update(ServerState serverState) argument
128 if (serverState == null)
134 for (CSN csn : serverState.serverIdToCSN.values())
170 * @param serverState The ServerState.
174 public boolean reload(ServerState serverState) { argument
175 if (serverState == null) {
180 return update(serverState);
310 * Check that all the CSNs in the covered serverState are also in this
311 * serverState
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/
H A DMultiDomainServerState.java120 ServerState serverState = list.get(baseDN);
121 if (serverState == null)
123 serverState = new ServerState();
124 final ServerState existingSS = list.putIfAbsent(baseDN, serverState);
127 serverState = existingSS;
130 return serverState.update(csn);
139 * @param serverState
140 * The provided serverState.
142 public void update(DN baseDN, ServerState serverState) argument
144 for (CSN csn : serverState)
160 replace(DN baseDN, ServerState serverState) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/common/
H A DServerStateTest.java64 ServerState serverState = new ServerState() ;
67 // serverState.loadState() ;
71 assertFalse(serverState.update((CSN)null));
72 assertTrue(serverState.update(csn));
73 assertFalse(serverState.update(csn));
78 assertTrue(serverState.update(csn1));
79 assertTrue(serverState.update(csn2));
80 assertTrue(serverState.update(csn3));
84 Set<String> stringSet = serverState.toStringSet();
89 assertEquals(csn2.compareTo(serverState
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java45 private ServerState serverState; field in class:ReplServerStartMsg
75 * @param serverState our ServerState for this baseDn.
84 ServerState serverState,
98 this.serverState = serverState;
131 * <degradedStatusThreshold><serverState>
188 serverState = new ServerState(in, pos, in.length - 1);
210 * <serverState>
256 serverState = new ServerState(in, pos, in.length - 1);
292 * Get the serverState
82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java45 private ServerState serverState; field in class:ReplServerStartMsg
75 * @param serverState our ServerState for this baseDn.
84 ServerState serverState,
98 this.serverState = serverState;
131 * <degradedStatusThreshold><serverState>
188 serverState = new ServerState(in, pos, in.length - 1);
210 * <serverState>
256 serverState = new ServerState(in, pos, in.length - 1);
292 * Get the serverState
82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java45 private ServerState serverState; field in class:ReplServerStartMsg
75 * @param serverState our ServerState for this baseDn.
84 ServerState serverState,
98 this.serverState = serverState;
131 * <degradedStatusThreshold><serverState>
188 serverState = new ServerState(in, pos, in.length - 1);
210 * <serverState>
256 serverState = new ServerState(in, pos, in.length - 1);
292 * Get the serverState
82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DMessageHandler.java111 * Specifies the current serverState of this handler.
113 private ServerState serverState; field in class:MessageHandler
409 cursor = replicationServerDomain.getCursorFrom(serverState);
477 cursor = replicationServerDomain.getCursorFrom(serverState);
532 return ServerState.diffChanges(latestState, serverState);
543 return serverState;
602 * Set the initial value of the serverState for this handler.
605 * @param serverState the provided serverState.
608 public void setInitialServerState(ServerState serverState) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DMessageHandler.java111 * Specifies the current serverState of this handler.
113 private ServerState serverState; field in class:MessageHandler
409 cursor = replicationServerDomain.getCursorFrom(serverState);
477 cursor = replicationServerDomain.getCursorFrom(serverState);
532 return ServerState.diffChanges(latestState, serverState);
543 return serverState;
602 * Set the initial value of the serverState for this handler.
605 * @param serverState the provided serverState.
608 public void setInitialServerState(ServerState serverState) argument
[all...]

Completed in 154 milliseconds

1234