Searched defs:csMsg (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java216 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus, INVALID_STATUS);
222 + " for baseDN=" + getBaseDNString() + ":\n" + csMsg);
225 session.publish(csMsg);
313 * @param csMsg The message containing the new status
316 public ServerStatus processNewStatus(ChangeStatusMsg csMsg) argument
319 ServerStatus reqStatus = csMsg.getNewStatus();
653 * @param csMsg The message containing the new status
655 public void receiveNewStatus(ChangeStatusMsg csMsg) argument
657 replicationServerDomain.processNewStatus(this, csMsg);
H A DReplicationServerDomain.java1910 * @param csMsg The message containing the new status
1913 ChangeStatusMsg csMsg)
1918 + ":\n" + csMsg);
1937 ServerStatus newStatus = senderHandler.processNewStatus(csMsg);
1912 processNewStatus(DataServerHandler senderHandler, ChangeStatusMsg csMsg) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java214 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
223 " for baseDn " + getServiceId() + ":\n" + csMsg);
226 session.publish(csMsg);
257 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
266 " for baseDn " + getServiceId() + ":\n" + csMsg);
269 session.publish(csMsg);
365 * @param csMsg The message containing the new status
368 public ServerStatus processNewStatus(ChangeStatusMsg csMsg) argument
371 ServerStatus reqStatus = csMsg.getNewStatus();
735 * @param csMsg Th
737 receiveNewStatus(ChangeStatusMsg csMsg) argument
[all...]
H A DReplicationServerDomain.java2191 * @param csMsg The message containing the new status
2194 ChangeStatusMsg csMsg)
2201 " for baseDn " + baseDn + ":\n" + csMsg);
2220 ServerStatus newStatus = senderHandler.processNewStatus(csMsg);
2193 processNewStatus(DataServerHandler senderHandler, ChangeStatusMsg csMsg) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java216 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus, INVALID_STATUS);
222 + " for baseDN=" + getBaseDNString() + ":\n" + csMsg);
225 session.publish(csMsg);
313 * @param csMsg The message containing the new status
316 public ServerStatus processNewStatus(ChangeStatusMsg csMsg) argument
319 ServerStatus reqStatus = csMsg.getNewStatus();
653 * @param csMsg The message containing the new status
655 public void receiveNewStatus(ChangeStatusMsg csMsg) argument
657 replicationServerDomain.processNewStatus(this, csMsg);
H A DReplicationServerDomain.java1910 * @param csMsg The message containing the new status
1913 ChangeStatusMsg csMsg)
1918 + ":\n" + csMsg);
1937 ServerStatus newStatus = senderHandler.processNewStatus(csMsg);
1912 processNewStatus(DataServerHandler senderHandler, ChangeStatusMsg csMsg) argument
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java215 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
224 " for baseDn " + getServiceId() + ":\n" + csMsg);
227 session.publish(csMsg);
258 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
267 " for baseDn " + getServiceId() + ":\n" + csMsg);
270 session.publish(csMsg);
374 * @param csMsg The message containing the new status
377 public ServerStatus processNewStatus(ChangeStatusMsg csMsg) argument
380 ServerStatus reqStatus = csMsg.getNewStatus();
771 * @param csMsg Th
773 receiveNewStatus(ChangeStatusMsg csMsg) argument
[all...]
H A DReplicationServerDomain.java2188 * @param csMsg The message containing the new status
2191 ChangeStatusMsg csMsg)
2198 " for baseDn " + baseDn + ":\n" + csMsg);
2217 ServerStatus newStatus = senderHandler.processNewStatus(csMsg);
2190 processNewStatus(DataServerHandler senderHandler, ChangeStatusMsg csMsg) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java215 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
224 " for baseDn " + getServiceId() + ":\n" + csMsg);
227 session.publish(csMsg);
258 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
267 " for baseDn " + getServiceId() + ":\n" + csMsg);
270 session.publish(csMsg);
374 * @param csMsg The message containing the new status
377 public ServerStatus processNewStatus(ChangeStatusMsg csMsg) argument
380 ServerStatus reqStatus = csMsg.getNewStatus();
771 * @param csMsg Th
773 receiveNewStatus(ChangeStatusMsg csMsg) argument
[all...]
H A DReplicationServerDomain.java2188 * @param csMsg The message containing the new status
2191 ChangeStatusMsg csMsg)
2198 " for baseDn " + baseDn + ":\n" + csMsg);
2217 ServerStatus newStatus = senderHandler.processNewStatus(csMsg);
2190 processNewStatus(DataServerHandler senderHandler, ChangeStatusMsg csMsg) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DDataServerHandler.java210 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus, INVALID_STATUS);
216 + " for baseDN=" + getBaseDN() + ":\n" + csMsg);
219 session.publish(csMsg);
300 * @param csMsg The message containing the new status
303 public ServerStatus processNewStatus(ChangeStatusMsg csMsg) argument
306 ServerStatus reqStatus = csMsg.getNewStatus();
621 * @param csMsg The message containing the new status
623 public void receiveNewStatus(ChangeStatusMsg csMsg) argument
625 replicationServerDomain.processNewStatus(this, csMsg);
H A DReplicationServerDomain.java1856 * @param csMsg The message containing the new status
1859 ChangeStatusMsg csMsg)
1864 + ":\n" + csMsg);
1883 ServerStatus newStatus = senderHandler.processNewStatus(csMsg);
1858 processNewStatus(DataServerHandler senderHandler, ChangeStatusMsg csMsg) argument
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java406 * @param csMsg The received status message
408 private void receiveChangeStatus(ChangeStatusMsg csMsg) argument
412 " received change status message:\n" + csMsg);
414 ServerStatus reqStatus = csMsg.getRequestedStatus();
821 ChangeStatusMsg csMsg = (ChangeStatusMsg)msg;
822 receiveChangeStatus(csMsg);
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java460 * @param csMsg The received status message
462 private void receiveChangeStatus(ChangeStatusMsg csMsg) argument
466 " received change status message:\n" + csMsg);
468 ServerStatus reqStatus = csMsg.getRequestedStatus();
856 ChangeStatusMsg csMsg = (ChangeStatusMsg)msg;
857 receiveChangeStatus(csMsg);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java407 * @param csMsg The received status message
409 private void receiveChangeStatus(ChangeStatusMsg csMsg) argument
413 " received change status message:\n" + csMsg);
415 ServerStatus reqStatus = csMsg.getRequestedStatus();
822 ChangeStatusMsg csMsg = (ChangeStatusMsg)msg;
823 receiveChangeStatus(csMsg);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java406 * @param csMsg The received status message
408 private void receiveChangeStatus(ChangeStatusMsg csMsg) argument
412 " received change status message:\n" + csMsg);
414 ServerStatus reqStatus = csMsg.getRequestedStatus();
821 ChangeStatusMsg csMsg = (ChangeStatusMsg)msg;
822 receiveChangeStatus(csMsg);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java460 * @param csMsg The received status message
462 private void receiveChangeStatus(ChangeStatusMsg csMsg) argument
466 " received change status message:\n" + csMsg);
468 ServerStatus reqStatus = csMsg.getRequestedStatus();
856 ChangeStatusMsg csMsg = (ChangeStatusMsg)msg;
857 receiveChangeStatus(csMsg);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationDomain.java438 * @param csMsg The received status message
440 private void receiveChangeStatus(ChangeStatusMsg csMsg) argument
445 " received change status message:\n" + csMsg);
448 ServerStatus reqStatus = csMsg.getRequestedStatus();
828 ChangeStatusMsg csMsg = (ChangeStatusMsg)msg;
829 receiveChangeStatus(csMsg);

Completed in 145 milliseconds