Searched defs:gen (Results 1 - 25 of 42) sorted by relevance

12

/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DDependencyTest.java142 CSNGenerator gen = new CSNGenerator(brokerId, 0L);
151 broker.publish(addMsg(addDN, entry, sequence + 1, sequence, gen));
152 broker.publish(modifyMsg(addDN, sequence + 1, generatemods("description", "test"), gen));
191 broker.publish(delMsg(deleteDN, sequence + 1, gen));
215 private AddMsg addMsg(DN addDN, Entry entry, int uniqueId, int parentId, CSNGenerator gen) argument
217 return new AddMsg(gen.newCSN(), addDN, stringUID(uniqueId), stringUID(parentId),
221 private ModifyMsg modifyMsg(DN dn, int entryUUID, List<Modification> mods, CSNGenerator gen) argument
223 return new ModifyMsg(gen.newCSN(), dn, mods, stringUID(entryUUID));
226 private DeleteMsg delMsg(DN delDN, int entryUUID, CSNGenerator gen) argument
228 return new DeleteMsg(delDN, gen
231 modDNMsg(DN dn, String newRDN, int entryUUID, int newSuperiorEntryUUID, CSNGenerator gen) argument
[all...]
H A DUpdateOperationTest.java308 CSNGenerator gen = new CSNGenerator(serverId, 0);
314 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
323 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
331 new DeleteMsg(personWithUUIDEntry.getName(), gen.newCSN(), user1entryUUID));
342 private AddMsg addMsg(CSNGenerator gen, Entry entry, String uniqueId, String parentId) argument
344 return new AddMsg(gen.newCSN(), entry.getName(), uniqueId, parentId,
369 CSNGenerator gen = new CSNGenerator(serverId, 0);
372 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
379 ModifyMsg modMsg = new ModifyMsg(gen.newCSN(),
394 modMsg = new ModifyMsg(gen
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DNamingConflictTest.java66 private CSNGenerator gen; field in class:NamingConflictTest
84 gen = new CSNGenerator(201, 0);
114 CSN csn1 = gen.newCSN();
115 CSN csn2 = gen.newCSN();
145 CSN csn1 = gen.newCSN();
184 CSN csn1 = gen.newCSN();
267 CSN csn2 = gen.newCSN();
290 CSN csn2 = gen.newCSN();
315 CSN csn1 = gen.newCSN();
H A DStateMachineTest.java517 * DS2 sends a reset gen id order with wrong gen id:
521 resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
525 * DS2 sends again a reset gen id order with right id: DS1 should be disconnected by RS
531 shutdown(br); // Reader could reconnect broker, but gen id would be bad: need to recreate a
546 * DS2 sends reset gen id order with bad gen id: DS1 should go in bad gen id status
554 * DS2 engages full update (while DS1 in bad gen id status),
563 * and come back to normal status (RS genid was -1 so RS will adopt new gen i
825 private CSNGenerator gen; field in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java692 * DS2 sends a reset gen id order with wrong gen id: DS1 should go into bad generation id status
695 resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
699 * DS2 sends again a reset gen id order with right id: DS1 should be disconnected
705 br.shutdown(); // Reader could reconnect broker, but gen id would be bad: need to recreate a broker to send changex
721 * DS2 sends reset gen id order with bad gen id: DS1 should go in bad gen id
729 * DS2 engages full update (while DS1 in bad gen id status), DS1 should go
746 ds2.stop(); // will need a new broker with another gen i
1031 ChangeNumberGenerator gen = null; field in class:StateMachineTest.BrokerWriter
[all...]
H A DAssuredReplicationPluginTest.java281 private ChangeNumberGenerator gen = null; field in class:AssuredReplicationPluginTest.FakeReplicationServer
329 gen = new ChangeNumberGenerator(3, 0L);
588 new AddMsg(gen.newChangeNumber(), entry.getDN().toString(), UUID.randomUUID().toString(),
H A DFractionalReplicationTest.java99 private ChangeNumberGenerator gen = null; field in class:FractionalReplicationTest
494 gen = new ChangeNumberGenerator(DS2_ID, 0L);
839 AddMsg addMsg = new AddMsg(gen.newChangeNumber(),
892 ModifyMsg modifyMsg = new ModifyMsg(gen.newChangeNumber(), entryDn, mods,
1154 // The domain should go in bad gen as backend is not initialized with
1398 // The domain should go in bad gen as backend is not initialized with
1569 AddMsg addMsg = new AddMsg(gen.newChangeNumber(),
1621 addMsg = new AddMsg(gen.newChangeNumber(),
1700 AddMsg addMsg = new AddMsg(gen.newChangeNumber(),
1754 addMsg = new AddMsg(gen
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java534 ChangeNumberGenerator gen = new ChangeNumberGenerator(5 , 0);
577 new DeleteMsg("o=example," + TEST_ROOT_DN_STRING, gen.newChangeNumber(),
645 ChangeNumberGenerator gen = new ChangeNumberGenerator(serverId , 0);
652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
1132 ChangeNumberGenerator gen; field in class:ReplicationServerTest.BrokerWriter
1134 public BrokerWriter(ReplicationBroker broker, ChangeNumberGenerator gen, argument
1139 this.gen = gen;
1159 new DeleteMsg("o=example," + TEST_ROOT_DN_STRING, gen.newChangeNumber(),
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DUpdateOperationTest.java285 CSNGenerator gen = new CSNGenerator(serverId, 0);
291 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
300 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
308 new DeleteMsg(personWithUUIDEntry.getDN(), gen.newCSN(), user1entryUUID));
319 private AddMsg addMsg(CSNGenerator gen, Entry entry, String uniqueId, String parentId) argument
321 return new AddMsg(gen.newCSN(), entry.getDN(), uniqueId, parentId,
347 CSNGenerator gen = new CSNGenerator(serverId, 0);
350 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
357 ModifyMsg modMsg = new ModifyMsg(gen.newCSN(),
373 modMsg = new ModifyMsg(gen
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java549 * DS2 sends a reset gen id order with wrong gen id: DS1 should go into bad generation id status
552 resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
556 * DS2 sends again a reset gen id order with right id: DS1 should be disconnected
562 br.shutdown(); // Reader could reconnect broker, but gen id would be bad: need to recreate a broker to send changex
578 * DS2 sends reset gen id order with bad gen id: DS1 should go in bad gen id
586 * DS2 engages full update (while DS1 in bad gen id status), DS1 should go
603 ds2.stop(); // will need a new broker with another gen i
874 CSNGenerator gen = null; field in class:StateMachineTest.BrokerWriter
[all...]
H A DAssuredReplicationPluginTest.java310 private CSNGenerator gen; field in class:AssuredReplicationPluginTest.FakeReplicationServer
359 gen = new CSNGenerator(3, 0L);
590 new AddMsg(gen.newCSN(), entry.getDN(), UUID.randomUUID().toString(),
H A DFractionalReplicationTest.java85 private CSNGenerator gen; field in class:FractionalReplicationTest
391 gen = new CSNGenerator(DS2_ID, 0L);
603 AddMsg addMsg = new AddMsg(gen.newCSN(),
648 ModifyMsg modifyMsg = new ModifyMsg(gen.newCSN(), entryDn, mods, ENTRY_UUID);
886 // The domain should go in bad gen as backend is not initialized with
1124 // The domain should go in bad gen as backend is not initialized with
1254 AddMsg addMsg = new AddMsg(gen.newCSN(),
1290 addMsg = new AddMsg(gen.newCSN(),
1350 AddMsg addMsg = new AddMsg(gen.newCSN(),
1388 addMsg = new AddMsg(gen
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java494 CSNGenerator gen = new CSNGenerator(5 , 0);
529 server.publish(new DeleteMsg(EXAMPLE_DN, gen.newCSN(), "uid"));
584 CSNGenerator gen = new CSNGenerator(serverId , 0);
588 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
1057 private CSNGenerator gen; field in class:ReplicationServerTest.BrokerWriter
1059 public BrokerWriter(ReplicationBroker broker, CSNGenerator gen, int count) argument
1063 this.gen = gen;
1082 DeleteMsg msg = new DeleteMsg(EXAMPLE_DN, gen.newCSN(), "uid");
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java692 * DS2 sends a reset gen id order with wrong gen id: DS1 should go into bad generation id status
695 resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
699 * DS2 sends again a reset gen id order with right id: DS1 should be disconnected
705 br.shutdown(); // Reader could reconnect broker, but gen id would be bad: need to recreate a broker to send changex
721 * DS2 sends reset gen id order with bad gen id: DS1 should go in bad gen id
729 * DS2 engages full update (while DS1 in bad gen id status), DS1 should go
746 ds2.stop(); // will need a new broker with another gen i
1031 ChangeNumberGenerator gen = null; field in class:StateMachineTest.BrokerWriter
[all...]
H A DAssuredReplicationPluginTest.java281 private ChangeNumberGenerator gen = null; field in class:AssuredReplicationPluginTest.FakeReplicationServer
329 gen = new ChangeNumberGenerator(3, 0L);
588 new AddMsg(gen.newChangeNumber(), entry.getDN().toString(), UUID.randomUUID().toString(),
H A DFractionalReplicationTest.java99 private ChangeNumberGenerator gen = null; field in class:FractionalReplicationTest
494 gen = new ChangeNumberGenerator(DS2_ID, 0L);
839 AddMsg addMsg = new AddMsg(gen.newChangeNumber(),
892 ModifyMsg modifyMsg = new ModifyMsg(gen.newChangeNumber(), entryDn, mods,
1154 // The domain should go in bad gen as backend is not initialized with
1398 // The domain should go in bad gen as backend is not initialized with
1569 AddMsg addMsg = new AddMsg(gen.newChangeNumber(),
1621 addMsg = new AddMsg(gen.newChangeNumber(),
1700 AddMsg addMsg = new AddMsg(gen.newChangeNumber(),
1754 addMsg = new AddMsg(gen
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java534 ChangeNumberGenerator gen = new ChangeNumberGenerator(5 , 0);
577 new DeleteMsg("o=example," + TEST_ROOT_DN_STRING, gen.newChangeNumber(),
645 ChangeNumberGenerator gen = new ChangeNumberGenerator(serverId , 0);
652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
1132 ChangeNumberGenerator gen; field in class:ReplicationServerTest.BrokerWriter
1134 public BrokerWriter(ReplicationBroker broker, ChangeNumberGenerator gen, argument
1139 this.gen = gen;
1159 new DeleteMsg("o=example," + TEST_ROOT_DN_STRING, gen.newChangeNumber(),
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DUpdateOperationTest.java285 CSNGenerator gen = new CSNGenerator(serverId, 0);
291 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
300 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
308 new DeleteMsg(personWithUUIDEntry.getDN(), gen.newCSN(), user1entryUUID));
319 private AddMsg addMsg(CSNGenerator gen, Entry entry, String uniqueId, String parentId) argument
321 return new AddMsg(gen.newCSN(), entry.getDN(), uniqueId, parentId,
347 CSNGenerator gen = new CSNGenerator(serverId, 0);
350 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
357 ModifyMsg modMsg = new ModifyMsg(gen.newCSN(),
373 modMsg = new ModifyMsg(gen
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java549 * DS2 sends a reset gen id order with wrong gen id: DS1 should go into bad generation id status
552 resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
556 * DS2 sends again a reset gen id order with right id: DS1 should be disconnected
562 br.shutdown(); // Reader could reconnect broker, but gen id would be bad: need to recreate a broker to send changex
578 * DS2 sends reset gen id order with bad gen id: DS1 should go in bad gen id
586 * DS2 engages full update (while DS1 in bad gen id status), DS1 should go
603 ds2.stop(); // will need a new broker with another gen i
874 CSNGenerator gen = null; field in class:StateMachineTest.BrokerWriter
[all...]
H A DAssuredReplicationPluginTest.java310 private CSNGenerator gen; field in class:AssuredReplicationPluginTest.FakeReplicationServer
359 gen = new CSNGenerator(3, 0L);
590 new AddMsg(gen.newCSN(), entry.getDN(), UUID.randomUUID().toString(),
H A DFractionalReplicationTest.java85 private CSNGenerator gen; field in class:FractionalReplicationTest
391 gen = new CSNGenerator(DS2_ID, 0L);
603 AddMsg addMsg = new AddMsg(gen.newCSN(),
648 ModifyMsg modifyMsg = new ModifyMsg(gen.newCSN(), entryDn, mods, ENTRY_UUID);
886 // The domain should go in bad gen as backend is not initialized with
1124 // The domain should go in bad gen as backend is not initialized with
1254 AddMsg addMsg = new AddMsg(gen.newCSN(),
1290 addMsg = new AddMsg(gen.newCSN(),
1350 AddMsg addMsg = new AddMsg(gen.newCSN(),
1388 addMsg = new AddMsg(gen
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java494 CSNGenerator gen = new CSNGenerator(5 , 0);
529 server.publish(new DeleteMsg(EXAMPLE_DN, gen.newCSN(), "uid"));
584 CSNGenerator gen = new CSNGenerator(serverId , 0);
588 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
1057 private CSNGenerator gen; field in class:ReplicationServerTest.BrokerWriter
1059 public BrokerWriter(ReplicationBroker broker, CSNGenerator gen, int count) argument
1063 this.gen = gen;
1082 DeleteMsg msg = new DeleteMsg(EXAMPLE_DN, gen.newCSN(), "uid");
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java692 * DS2 sends a reset gen id order with wrong gen id: DS1 should go into bad generation id status
695 resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
699 * DS2 sends again a reset gen id order with right id: DS1 should be disconnected
705 br.shutdown(); // Reader could reconnect broker, but gen id would be bad: need to recreate a broker to send changex
721 * DS2 sends reset gen id order with bad gen id: DS1 should go in bad gen id
729 * DS2 engages full update (while DS1 in bad gen id status), DS1 should go
746 ds2.stop(); // will need a new broker with another gen i
1031 ChangeNumberGenerator gen = null; field in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java534 ChangeNumberGenerator gen = new ChangeNumberGenerator(5 , 0);
577 new DeleteMsg("o=example," + TEST_ROOT_DN_STRING, gen.newChangeNumber(),
645 ChangeNumberGenerator gen = new ChangeNumberGenerator(serverId , 0);
652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
1132 ChangeNumberGenerator gen; field in class:ReplicationServerTest.BrokerWriter
1134 public BrokerWriter(ReplicationBroker broker, ChangeNumberGenerator gen, argument
1139 this.gen = gen;
1159 new DeleteMsg("o=example," + TEST_ROOT_DN_STRING, gen.newChangeNumber(),
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplicationServerTest.java491 CSNGenerator gen = new CSNGenerator(5 , 0);
525 server.publish(new DeleteMsg(EXAMPLE_DN, gen.newCSN(), "uid"));
580 CSNGenerator gen = new CSNGenerator(serverId , 0);
584 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
1059 private CSNGenerator gen; field in class:ReplicationServerTest.BrokerWriter
1061 public BrokerWriter(ReplicationBroker broker, CSNGenerator gen, int count) argument
1065 this.gen = gen;
1082 DeleteMsg msg = new DeleteMsg(EXAMPLE_DN, gen.newCSN(), "uid");

Completed in 360 milliseconds

12