| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | StateMachineTest.java | 887 private int destId = -1; // Server id of server to initialize field in class:StateMachineTest.BrokerInitializer
922 public void initFullUpdate(int destId, long nEntries) argument
930 debugInfo("Broker " + serverId + " initializer sending InitializeTargetMsg to server " + destId);
932 this.destId = destId;
939 new InitializeTargetMsg(EXAMPLE_DN, serverId, destId,
950 EntryMsg entryMsg = new EntryMsg(serverId, destId, topEntry.getBytes(), 1);
977 EntryMsg entryMsg = new EntryMsg(serverId, destId,
990 debugInfo("Broker " + serverId + " initializer starting sending entries to server " + destId);
1000 DoneMsg doneMsg = new DoneMsg(serverId, destId);
[all...] |
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | StateMachineTest.java | 741 private int destId = -1; // Server id of server to initialize field in class:StateMachineTest.BrokerInitializer
768 public void initFullUpdate(int destId, long nEntries) argument
776 debugInfo("Broker " + serverId + " initializer sending InitializeTargetMsg to server " + destId);
778 this.destId = destId;
783 EXAMPLE_DN_, serverId, destId, serverId, nEntries, initWindow);
792 EntryMsg entryMsg = new EntryMsg(serverId, destId, topEntry.getBytes(), 1);
819 return new EntryMsg(serverId, destId, entryWithUUIDldif.getBytes(),
830 debugInfo("Broker " + serverId + " initializer starting sending entries to server " + destId);
840 DoneMsg doneMsg = new DoneMsg(serverId, destId);
[all...] |
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | StateMachineTest.java | 887 private int destId = -1; // Server id of server to initialize field in class:StateMachineTest.BrokerInitializer
922 public void initFullUpdate(int destId, long nEntries) argument
930 debugInfo("Broker " + serverId + " initializer sending InitializeTargetMsg to server " + destId);
932 this.destId = destId;
939 new InitializeTargetMsg(EXAMPLE_DN, serverId, destId,
950 EntryMsg entryMsg = new EntryMsg(serverId, destId, topEntry.getBytes(), 1);
977 EntryMsg entryMsg = new EntryMsg(serverId, destId,
990 debugInfo("Broker " + serverId + " initializer starting sending entries to server " + destId);
1000 DoneMsg doneMsg = new DoneMsg(serverId, destId);
[all...] |
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | StateMachineTest.java | 741 private int destId = -1; // Server id of server to initialize field in class:StateMachineTest.BrokerInitializer
768 public void initFullUpdate(int destId, long nEntries) argument
776 debugInfo("Broker " + serverId + " initializer sending InitializeTargetMsg to server " + destId);
778 this.destId = destId;
783 EXAMPLE_DN_, serverId, destId, serverId, nEntries, initWindow);
792 EntryMsg entryMsg = new EntryMsg(serverId, destId, topEntry.getBytes(), 1);
819 return new EntryMsg(serverId, destId, entryWithUUIDldif.getBytes(),
830 debugInfo("Broker " + serverId + " initializer starting sending entries to server " + destId);
840 DoneMsg doneMsg = new DoneMsg(serverId, destId);
[all...] |
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | StateMachineTest.java | 887 private int destId = -1; // Server id of server to initialize field in class:StateMachineTest.BrokerInitializer
922 public void initFullUpdate(int destId, long nEntries) argument
930 debugInfo("Broker " + serverId + " initializer sending InitializeTargetMsg to server " + destId);
932 this.destId = destId;
939 new InitializeTargetMsg(EXAMPLE_DN, serverId, destId,
950 EntryMsg entryMsg = new EntryMsg(serverId, destId, topEntry.getBytes(), 1);
977 EntryMsg entryMsg = new EntryMsg(serverId, destId,
990 debugInfo("Broker " + serverId + " initializer starting sending entries to server " + destId);
1000 DoneMsg doneMsg = new DoneMsg(serverId, destId);
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
| H A D | StateMachineTest.java | 698 private int destId = -1; field in class:StateMachineTest.BrokerInitializer
722 public void initFullUpdate(int destId, long nEntries) argument
730 debugInfo("Broker " + serverId + " initializer sending InitializeTargetMsg to server " + destId);
732 this.destId = destId;
737 EXAMPLE_DN_, serverId, destId, serverId, nEntries, initWindow);
746 EntryMsg entryMsg = new EntryMsg(serverId, destId, topEntry.getBytes(), 1);
773 return new EntryMsg(serverId, destId, entryWithUUIDldif.getBytes(),
784 debugInfo("Broker " + serverId + " initializer starting sending entries to server " + destId);
794 DoneMsg doneMsg = new DoneMsg(serverId, destId);
[all...] |