Searched refs:requestorID (Results 1 - 24 of 24) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java50 private final int requestorID; field in class:InitializeTargetMsg
60 * @param requestorID The server that initiates this export.
65 int destination, int requestorID, long entryCount, int initWindow)
68 this.requestorID = requestorID;
93 requestorID = scanner.nextIntUTF8();
120 return this.requestorID;
156 builder.appendIntUTF8(requestorID);
64 InitializeTargetMsg(DN baseDN, int serverID, int destination, int requestorID, long entryCount, int initWindow) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java50 private final int requestorID; field in class:InitializeTargetMsg
60 * @param requestorID The server that initiates this export.
65 int destination, int requestorID, long entryCount, int initWindow)
68 this.requestorID = requestorID;
93 requestorID = scanner.nextIntUTF8();
120 return this.requestorID;
156 builder.appendIntUTF8(requestorID);
64 InitializeTargetMsg(DN baseDN, int serverID, int destination, int requestorID, long entryCount, int initWindow) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java50 private final int requestorID; field in class:InitializeTargetMsg
60 * @param requestorID The server that initiates this export.
65 int destination, int requestorID, long entryCount, int initWindow)
68 this.requestorID = requestorID;
93 requestorID = scanner.nextIntUTF8();
120 return this.requestorID;
156 builder.appendIntUTF8(requestorID);
64 InitializeTargetMsg(DN baseDN, int serverID, int destination, int requestorID, long entryCount, int initWindow) argument
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java49 private int requestorID; field in class:InitializeTargetMsg
67 this.requestorID = target2;
112 requestorID = Integer.valueOf(requestorString);
154 return this.requestorID;
193 byte[] byteRequestor = String.valueOf(requestorID).getBytes("UTF-8");
223 /* put the requestorID */
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java49 private int requestorID; field in class:InitializeTargetMsg
67 this.requestorID = target2;
112 requestorID = Integer.valueOf(requestorString);
154 return this.requestorID;
193 byte[] byteRequestor = String.valueOf(requestorID).getBytes("UTF-8");
223 /* put the requestorID */
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java49 private int requestorID; field in class:InitializeTargetMsg
67 this.requestorID = target2;
112 requestorID = Integer.valueOf(requestorString);
154 return this.requestorID;
193 byte[] byteRequestor = String.valueOf(requestorID).getBytes("UTF-8");
223 /* put the requestorID */
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java390 * @param requestorID The initiator server.
393 int senderID, int destinationServerID, int requestorID)
397 requestorID, updatedEntries.length, initWindow);
392 makeBrokerPublishEntries(ReplicationBroker broker, int senderID, int destinationServerID, int requestorID) argument
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java390 * @param requestorID The initiator server.
393 int senderID, int destinationServerID, int requestorID)
397 requestorID, updatedEntries.length, initWindow);
392 makeBrokerPublishEntries(ReplicationBroker broker, int senderID, int destinationServerID, int requestorID) argument
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DInitOnLineTest.java372 * @param requestorID The initiator server.
375 int senderID, int destinationServerID, int requestorID)
379 requestorID, updatedEntries.length, initWindow);
374 makeBrokerPublishEntries(ReplicationBroker broker, int senderID, int destinationServerID, int requestorID) argument
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1110 int requestorID = 3;
1115 TEST_ROOT_DN, senderID, targetID, requestorID, entryCount, initWindow);
1125 assertEquals(requestorID, newMsg.getInitiatorID());
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1110 int requestorID = 3;
1115 TEST_ROOT_DN, senderID, targetID, requestorID, entryCount, initWindow);
1125 assertEquals(requestorID, newMsg.getInitiatorID());
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1107 int requestorID = 3;
1112 TEST_ROOT_DN, senderID, targetID, requestorID, entryCount, initWindow);
1122 assertEquals(requestorID, newMsg.getInitiatorID());
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java494 * @param requestorID The initiator server.
497 int senderID, int destinationServerID, int requestorID)
504 EXAMPLE_DN, server2ID, destinationServerID, requestorID,
496 makeBrokerPublishEntries(ReplicationBroker broker, int senderID, int destinationServerID, int requestorID) argument
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java494 * @param requestorID The initiator server.
497 int senderID, int destinationServerID, int requestorID)
504 EXAMPLE_DN, server2ID, destinationServerID, requestorID,
496 makeBrokerPublishEntries(ReplicationBroker broker, int senderID, int destinationServerID, int requestorID) argument
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java494 * @param requestorID The initiator server.
497 int senderID, int destinationServerID, int requestorID)
504 EXAMPLE_DN, server2ID, destinationServerID, requestorID,
496 makeBrokerPublishEntries(ReplicationBroker broker, int senderID, int destinationServerID, int requestorID) argument
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1353 int requestorID = 3;
1358 TEST_ROOT_DN_STRING, senderID, targetID, requestorID, entryCount, initWindow);
1368 assertEquals(requestorID, newMsg.getInitiatorID());
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1353 int requestorID = 3;
1358 TEST_ROOT_DN_STRING, senderID, targetID, requestorID, entryCount, initWindow);
1368 assertEquals(requestorID, newMsg.getInitiatorID());
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1353 int requestorID = 3;
1358 TEST_ROOT_DN_STRING, senderID, targetID, requestorID, entryCount, initWindow);
1368 assertEquals(requestorID, newMsg.getInitiatorID());
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1729 protected void initializeRemote(int target, int requestorID, argument
1739 super.initializeRemote(target, requestorID, initTask, this.initWindow);
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1536 protected void initializeRemote(int target, int requestorID, argument
1548 super.initializeRemote(target, requestorID, initTask, getInitWindow());
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1750 protected void initializeRemote(int target, int requestorID, argument
1760 super.initializeRemote(target, requestorID, initTask, this.initWindow);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1729 protected void initializeRemote(int target, int requestorID, argument
1739 super.initializeRemote(target, requestorID, initTask, this.initWindow);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1536 protected void initializeRemote(int target, int requestorID, argument
1548 super.initializeRemote(target, requestorID, initTask, getInitWindow());
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1517 protected void initializeRemote(int target, int requestorID, argument
1526 super.initializeRemote(target, requestorID, initTask, initWindow);

Completed in 601 milliseconds