Searched refs:serverID (Results 1 - 25 of 138) sorted by relevance

123456

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DRoutableMsg.java61 * The serverID of the server that sends this message.
67 * @param serverID replication server id
70 public RoutableMsg(int serverID, int destination) argument
72 this.senderID = serverID;
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DRoutableMsg.java66 * The serverID of the server that sends this message.
72 * @param serverID replication server id
75 public RoutableMsg(int serverID, int destination) argument
77 this.senderID = serverID;
H A DDoneMsg.java42 * @param serverID The sender server of this message.
45 public DoneMsg(int serverID, int i) argument
47 super(serverID, i);
H A DEntryMsg.java46 * @param serverID The sender of this message.
51 public EntryMsg(int serverID, int destination, byte[] entryBytes, int msgId) argument
53 this(serverID, destination, entryBytes, 0, entryBytes.length, msgId);
59 * @param serverID The sender of this message.
66 public EntryMsg(int serverID, int destination, byte[] entryBytes, int startPos, argument
69 super(serverID, destination);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DRoutableMsg.java67 * The serverID of the server that sends this message.
73 * @param serverID replication server id
76 public RoutableMsg(int serverID, int destination) argument
78 this.senderID = serverID;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DRoutableMsg.java61 * The serverID of the server that sends this message.
67 * @param serverID replication server id
70 public RoutableMsg(int serverID, int destination) argument
72 this.senderID = serverID;
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DRoutableMsg.java66 * The serverID of the server that sends this message.
72 * @param serverID replication server id
75 public RoutableMsg(int serverID, int destination) argument
77 this.senderID = serverID;
H A DDoneMsg.java42 * @param serverID The sender server of this message.
45 public DoneMsg(int serverID, int i) argument
47 super(serverID, i);
H A DEntryMsg.java46 * @param serverID The sender of this message.
51 public EntryMsg(int serverID, int destination, byte[] entryBytes, int msgId) argument
53 this(serverID, destination, entryBytes, 0, entryBytes.length, msgId);
59 * @param serverID The sender of this message.
66 public EntryMsg(int serverID, int destination, byte[] entryBytes, int startPos, argument
69 super(serverID, destination);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DRoutableMsg.java68 * The serverID of the server that sends this message.
74 * @param serverID replication server id
77 public RoutableMsg(int serverID, int destination) argument
79 this.senderID = serverID;
H A DDoneMsg.java42 * @param serverID The sender server of this message.
45 public DoneMsg(int serverID, int i) argument
47 super(serverID, i);
H A DEntryMsg.java47 * @param serverID The sender of this message.
52 public EntryMsg(int serverID, int destination, byte[] entryBytes, int msgId) argument
54 this(serverID, destination, entryBytes, 0, entryBytes.length, msgId);
60 * @param serverID The sender of this message.
67 public EntryMsg(int serverID, int destination, byte[] entryBytes, int startPos, argument
70 super(serverID, destination);
/forgerock/openam-v13/openam-core/src/test/java/com/iplanet/dpro/session/service/
H A DWebtopNamingSiteUtilsTest.java56 String serverID = "SERVER";
58 given(mockSessionID.getSessionServerID()).willReturn(serverID);
59 given(mockQuery.getSiteID(eq(serverID))).willReturn(siteID);
71 String serverID = "SERVER";
72 given(mockSessionID.getSessionServerID()).willReturn(serverID);
73 given(mockQuery.getSiteID(eq(serverID))).willReturn(null);
79 result.contains(serverID);
85 String serverID = "SERVER";
87 given(mockSessionID.getSessionServerID()).willReturn(serverID);
88 given(mockQuery.getSiteID(eq(serverID)))
[all...]
/forgerock/openam/openam-core/src/test/java/com/iplanet/dpro/session/service/
H A DWebtopNamingSiteUtilsTest.java56 String serverID = "SERVER";
58 given(mockSessionID.getSessionServerID()).willReturn(serverID);
59 given(mockQuery.getSiteID(eq(serverID))).willReturn(siteID);
71 String serverID = "SERVER";
72 given(mockSessionID.getSessionServerID()).willReturn(serverID);
73 given(mockQuery.getSiteID(eq(serverID))).willReturn(null);
79 result.contains(serverID);
85 String serverID = "SERVER";
87 given(mockSessionID.getSessionServerID()).willReturn(serverID);
88 given(mockQuery.getSiteID(eq(serverID)))
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DHeartbeatMonitor.java59 private final int serverID; field in class:HeartbeatMonitor
72 * @param serverID
84 HeartbeatMonitor(int serverID, int replicationServerID, argument
88 + serverID + ") heartbeat monitor for domain \""
91 this.serverID = serverID;
132 logger.warn(WARN_HEARTBEAT_FAILURE, serverID,
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DHeartbeatMonitor.java67 private final int serverID; field in class:HeartbeatMonitor
83 * @param serverID
95 HeartbeatMonitor(int serverID, int replicationServerID, argument
99 + serverID + ") heartbeat monitor for domain \""
102 this.serverID = serverID;
145 logError(WARN_HEARTBEAT_FAILURE.get(serverID,
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DHeartbeatMonitor.java66 private final int serverID; field in class:HeartbeatMonitor
82 * @param serverID
94 HeartbeatMonitor(int serverID, int replicationServerID, argument
98 + serverID + ") heartbeat monitor for domain \""
101 this.serverID = serverID;
144 logError(WARN_HEARTBEAT_FAILURE.get(serverID,
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DHeartbeatMonitor.java67 private final int serverID; field in class:HeartbeatMonitor
83 * @param serverID
95 HeartbeatMonitor(int serverID, int replicationServerID, argument
99 + serverID + ") heartbeat monitor for domain \""
102 this.serverID = serverID;
145 logError(WARN_HEARTBEAT_FAILURE.get(serverID,
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DHeartbeatMonitor.java67 private final int serverID; field in class:HeartbeatMonitor
83 * @param serverID
95 HeartbeatMonitor(int serverID, int replicationServerID, argument
99 + serverID + ") heartbeat monitor for domain \""
102 this.serverID = serverID;
145 logError(WARN_HEARTBEAT_FAILURE.get(serverID,
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DHeartbeatMonitor.java66 private final int serverID; field in class:HeartbeatMonitor
82 * @param serverID
94 HeartbeatMonitor(int serverID, int replicationServerID, argument
98 + serverID + ") heartbeat monitor for domain \""
101 this.serverID = serverID;
144 logError(WARN_HEARTBEAT_FAILURE.get(serverID,
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/
H A DMultiServerClusterMonitor.java127 public boolean checkServerUp(String serverID) { argument
128 return ((serverID == null) || (serverID.isEmpty())) ? false : clusterStateService.checkServerUp(serverID);
137 String serverID = locateCurrentHostServer(sid);
138 if (serverID == null) {
142 return serverID;
201 for (String serverID : serverIDs) {
202 String serverURL = serverConfig.getServerFromID(serverID);
203 if ((serverID
[all...]
H A DSingleServerClusterMonitor.java54 public boolean checkServerUp(String serverID) { argument
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/
H A DMultiServerClusterMonitor.java118 public boolean checkServerUp(String serverID) { argument
119 return ((serverID == null) || (serverID.isEmpty())) ? false : clusterStateService.checkServerUp(serverID);
127 String serverID = locateCurrentHostServer(sid);
128 if (serverID == null) {
132 return serverID;
188 for (String serverID : serverIDs) {
189 String serverURL = serverConfig.getServerFromID(serverID);
190 if ((serverID
[all...]
H A DSingleServerClusterMonitor.java54 public boolean checkServerUp(String serverID) { argument
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DFakeReplicationDomain.java68 private FakeReplicationDomain(DN baseDN, int serverID, argument
72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId);
77 private static DomainFakeCfg newConfig(DN baseDN, int serverID, argument
80 DomainFakeCfg fakeCfg = new DomainFakeCfg(baseDN, serverID, replicationServers);
87 public FakeReplicationDomain(DN baseDN, int serverID, argument
91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId);
94 FakeReplicationDomain(DN baseDN, int serverID, argument
98 this(baseDN, serverID, replicationServers, window, heartbeatInterval, 1);
102 FakeReplicationDomain(DN baseDN, int serverID, argument
107 this(baseDN, serverID, replicationServer
[all...]

Completed in 290 milliseconds

123456