Searched refs:StartECLSessionMsg (Results 1 - 25 of 33) sorted by relevance

12

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DExternalChangeLogSessionImpl.java33 import org.opends.server.replication.protocol.StartECLSessionMsg;
56 StartECLSessionMsg startECLSessionMsg)
H A DECLServerWriter.java45 import org.opends.server.replication.protocol.StartECLSessionMsg;
253 if (handler.isPersistent() == StartECLSessionMsg.NON_PERSISTENT)
H A DECLServerHandler.java427 StartECLSessionMsg startECLSessionMsg)
477 StartECLSessionMsg inStartECLSessionMsg =
520 private StartECLSessionMsg waitAndProcessStartSessionECLFromRemoteServer()
533 else if (!(msg instanceof StartECLSessionMsg))
536 .raw("Protocol error: StartECLSessionMsg required." + msg
544 return (StartECLSessionMsg) msg;
762 StartECLSessionMsg.PERSISTENT_CHANGES_ONLY)
1052 public void initialize(StartECLSessionMsg startECLSessionMsg)
1079 StartECLSessionMsg.REQUEST_TYPE_FROM_COOKIE)
1085 StartECLSessionMsg
[all...]
H A DServerHandler.java58 import org.opends.server.replication.protocol.StartECLSessionMsg;
1261 StartECLSessionMsg inStartECLSessionMsg)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DExternalChangeLogSessionImpl.java33 import org.opends.server.replication.protocol.StartECLSessionMsg;
56 StartECLSessionMsg startECLSessionMsg)
H A DECLServerWriter.java45 import org.opends.server.replication.protocol.StartECLSessionMsg;
253 if (handler.isPersistent() == StartECLSessionMsg.NON_PERSISTENT)
H A DECLServerHandler.java427 StartECLSessionMsg startECLSessionMsg)
477 StartECLSessionMsg inStartECLSessionMsg =
520 private StartECLSessionMsg waitAndProcessStartSessionECLFromRemoteServer()
533 else if (!(msg instanceof StartECLSessionMsg))
536 .raw("Protocol error: StartECLSessionMsg required." + msg
544 return (StartECLSessionMsg) msg;
762 StartECLSessionMsg.PERSISTENT_CHANGES_ONLY)
1052 public void initialize(StartECLSessionMsg startECLSessionMsg)
1079 StartECLSessionMsg.REQUEST_TYPE_FROM_COOKIE)
1085 StartECLSessionMsg
[all...]
H A DServerHandler.java60 import org.opends.server.replication.protocol.StartECLSessionMsg;
1278 StartECLSessionMsg inStartECLSessionMsg)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DExternalChangeLogSessionImpl.java33 import org.opends.server.replication.protocol.StartECLSessionMsg;
56 StartECLSessionMsg startECLSessionMsg)
H A DECLServerWriter.java45 import org.opends.server.replication.protocol.StartECLSessionMsg;
253 if (handler.isPersistent() == StartECLSessionMsg.NON_PERSISTENT)
H A DECLServerHandler.java427 StartECLSessionMsg startECLSessionMsg)
477 StartECLSessionMsg inStartECLSessionMsg =
520 private StartECLSessionMsg waitAndProcessStartSessionECLFromRemoteServer()
533 else if (!(msg instanceof StartECLSessionMsg))
536 .raw("Protocol error: StartECLSessionMsg required." + msg
544 return (StartECLSessionMsg) msg;
762 StartECLSessionMsg.PERSISTENT_CHANGES_ONLY)
1052 public void initialize(StartECLSessionMsg startECLSessionMsg)
1079 StartECLSessionMsg.REQUEST_TYPE_FROM_COOKIE)
1085 StartECLSessionMsg
[all...]
H A DServerHandler.java58 import org.opends.server.replication.protocol.StartECLSessionMsg;
1261 StartECLSessionMsg inStartECLSessionMsg)
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DStartECLSessionMsg.java44 public class StartECLSessionMsg extends ReplicationMsg class in inherits:ReplicationMsg
118 public StartECLSessionMsg(byte[] in) throws DataFormatException method in class:StartECLSessionMsg
199 public StartECLSessionMsg() method in class:StartECLSessionMsg
H A DReplicationMsg.java203 return new StartECLSessionMsg(buffer);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DStartECLSessionMsg.java44 public class StartECLSessionMsg extends ReplicationMsg class in inherits:ReplicationMsg
118 public StartECLSessionMsg(byte[] in) throws DataFormatException method in class:StartECLSessionMsg
199 public StartECLSessionMsg() method in class:StartECLSessionMsg
H A DReplicationMsg.java203 return new StartECLSessionMsg(buffer);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DStartECLSessionMsg.java44 public class StartECLSessionMsg extends ReplicationMsg class in inherits:ReplicationMsg
118 public StartECLSessionMsg(byte[] in) throws DataFormatException method in class:StartECLSessionMsg
199 public StartECLSessionMsg() method in class:StartECLSessionMsg
H A DReplicationMsg.java203 return new StartECLSessionMsg(buffer);
/forgerock/opendj-b2.6/src/server/org/opends/server/workflowelement/externalchangelog/
H A DECLSearchOperation.java85 private StartECLSessionMsg startECLSessionMsg;
229 startECLSessionMsg = new StartECLSessionMsg();
234 StartECLSessionMsg.REQUEST_TYPE_FROM_DRAFT_CHANGE_NUMBER);
436 StartECLSessionMsg.REQUEST_TYPE_FROM_COOKIE);
562 StartECLSessionMsg.PERSISTENT_CHANGES_ONLY);
565 StartECLSessionMsg.PERSISTENT);
1321 * When found, populate the provided StartECLSessionMsg.
1327 public static void evaluateSearchParameters(StartECLSessionMsg startCLmsg,
1375 StartECLSessionMsg msg = evaluateSearchParameters2(sf);
1381 private static StartECLSessionMsg evaluateSearchParameters
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/workflowelement/externalchangelog/
H A DECLSearchOperation.java87 private StartECLSessionMsg startECLSessionMsg;
231 startECLSessionMsg = new StartECLSessionMsg();
236 StartECLSessionMsg.REQUEST_TYPE_FROM_DRAFT_CHANGE_NUMBER);
435 StartECLSessionMsg.REQUEST_TYPE_FROM_COOKIE);
561 StartECLSessionMsg.PERSISTENT_CHANGES_ONLY);
564 StartECLSessionMsg.PERSISTENT);
1343 * When found, populate the provided StartECLSessionMsg.
1349 public static void evaluateSearchParameters(StartECLSessionMsg startCLmsg,
1397 StartECLSessionMsg msg = evaluateSearchParameters2(sf);
1403 private static StartECLSessionMsg evaluateSearchParameters
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/workflowelement/externalchangelog/
H A DECLSearchOperation.java85 private StartECLSessionMsg startECLSessionMsg;
229 startECLSessionMsg = new StartECLSessionMsg();
234 StartECLSessionMsg.REQUEST_TYPE_FROM_DRAFT_CHANGE_NUMBER);
436 StartECLSessionMsg.REQUEST_TYPE_FROM_COOKIE);
562 StartECLSessionMsg.PERSISTENT_CHANGES_ONLY);
565 StartECLSessionMsg.PERSISTENT);
1321 * When found, populate the provided StartECLSessionMsg.
1327 public static void evaluateSearchParameters(StartECLSessionMsg startCLmsg,
1375 StartECLSessionMsg msg = evaluateSearchParameters2(sf);
1381 private static StartECLSessionMsg evaluateSearchParameters
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1458 StartECLSessionMsg msg = new StartECLSessionMsg();
1461 msg.setPersistent(StartECLSessionMsg.PERSISTENT);
1473 StartECLSessionMsg newMsg = new StartECLSessionMsg(msg.getBytes(getCurrentVersion()));
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1458 StartECLSessionMsg msg = new StartECLSessionMsg();
1461 msg.setPersistent(StartECLSessionMsg.PERSISTENT);
1473 StartECLSessionMsg newMsg = new StartECLSessionMsg(msg.getBytes(getCurrentVersion()));
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1458 StartECLSessionMsg msg = new StartECLSessionMsg();
1461 msg.setPersistent(StartECLSessionMsg.PERSISTENT);
1473 StartECLSessionMsg newMsg = new StartECLSessionMsg(msg.getBytes(getCurrentVersion()));
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1405 StartECLSessionMsg startECLSessionMsg = new StartECLSessionMsg();

Completed in 124 milliseconds

12