Searched refs:receive (Results 1 - 25 of 148) sorted by relevance

123456

/forgerock/authenticator-android-v2/app/src/androidTest/java/com/forgerock/authenticator/
H A DPushAuthActivityTest.java139 Calendar receive = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
145 baseNotificationBuilder = baseNotificationBuilder.setTimeAdded(receive);
161 Calendar receive = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
167 baseNotificationBuilder = baseNotificationBuilder.setTimeAdded(receive);
195 Calendar receive = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
201 baseNotificationBuilder = baseNotificationBuilder.setTimeAdded(receive);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DListenerThread.java97 while (!shutdown.get() && ((updateMsg = repDomain.receive()) != null))
113 * catch all exceptions happening in repDomain.receive so that the
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DListenerThread.java97 while (!shutdown.get() && ((updateMsg = repDomain.receive()) != null))
113 * catch all exceptions happening in repDomain.receive so that the
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DListenerThread.java97 while (!shutdown.get() && ((updateMsg = repDomain.receive()) != null))
113 * catch all exceptions happening in repDomain.receive so that the
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DSchemaReplicationTest.java137 ReplicationMsg msg = broker.receive();
166 msg = broker.receive();
244 // receive the message on the broker side.
245 ReplicationMsg msg = broker.receive();
H A DProtocolWindowTest.java85 * - receive all messages from the ReplicationBroker, check that
105 + "ds-cfg-receive-status: true\n"
137 ReplicationMsg msg = broker.receive();
164 broker.receive();
H A DStressTest.java106 ReplicationMsg msg = broker.receive();
192 + "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n";
275 ReplicationMsg msg = broker.receive();
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DSchemaReplicationTest.java137 ReplicationMsg msg = broker.receive();
166 msg = broker.receive();
244 // receive the message on the broker side.
245 ReplicationMsg msg = broker.receive();
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java261 * Send and receive a Delete Msg from server 1 to server 2
267 ReplicationMsg msg2 = server2.receive();
272 * Send and receive a second Delete Msg
276 msg2 = server2.receive();
281 * Send and receive a Delete Msg from server 2 to server 1
287 msg2 = server1.receive();
292 * Send and receive a second Delete Msg
296 msg2 = server1.receive();
340 ReplicationMsg msg2 = broker.receive();
356 * Test that a client that has already seen some changes now receive
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java261 * Send and receive a Delete Msg from server 1 to server 2
267 ReplicationMsg msg2 = server2.receive();
272 * Send and receive a second Delete Msg
276 msg2 = server2.receive();
281 * Send and receive a Delete Msg from server 2 to server 1
287 msg2 = server1.receive();
292 * Send and receive a second Delete Msg
296 msg2 = server1.receive();
340 ReplicationMsg msg2 = broker.receive();
356 * Test that a client that has already seen some changes now receive
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DSchemaReplicationTest.java159 ReplicationMsg msg = broker.receive();
202 msg = broker.receive();
284 // receive the message on the broker side.
285 ReplicationMsg msg = broker.receive();
H A DGenerationIdTest.java283 // Expect the broker to receive the entries
291 msg = broker.receive();
400 + "ds-cfg-receive-status: true\n"
783 broker3.receive();
807 ReplicationMsg msg = broker3.receive();
893 // Broker 2 and 3 should receive 1 change status message to order them
899 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +
907 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +
954 ReplicationMsg msg = broker2.receive();
960 ReplicationMsg msg = broker3.receive();
[all...]
H A DStressTest.java121 ReplicationMsg msg = broker.receive();
220 + "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n";
306 ReplicationMsg msg = broker.receive();
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java179 "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n" +
225 "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n" +
244 * This fake replication server is able to receive a DS connection only.
434 ServerStartMsg serverStartMsg = (ServerStartMsg) session.receive();
456 ReplicationMsg msg = session.receive();
600 return (AckMsg)session.receive();
621 UpdateMsg updateMsg = (UpdateMsg) session.receive();
641 UpdateMsg updateMsg = (UpdateMsg) session.receive();
665 UpdateMsg updateMsg = (UpdateMsg) session.receive();
709 UpdateMsg updateMsg = (UpdateMsg) session.receive();
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DSchemaReplicationTest.java159 ReplicationMsg msg = broker.receive();
202 msg = broker.receive();
284 // receive the message on the broker side.
285 ReplicationMsg msg = broker.receive();
H A DGenerationIdTest.java283 // Expect the broker to receive the entries
291 msg = broker.receive();
400 + "ds-cfg-receive-status: true\n"
783 broker3.receive();
807 ReplicationMsg msg = broker3.receive();
893 // Broker 2 and 3 should receive 1 change status message to order them
899 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +
907 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +
954 ReplicationMsg msg = broker2.receive();
960 ReplicationMsg msg = broker3.receive();
[all...]
H A DStressTest.java121 ReplicationMsg msg = broker.receive();
220 + "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n";
306 ReplicationMsg msg = broker.receive();
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java179 "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n" +
225 "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n" +
244 * This fake replication server is able to receive a DS connection only.
434 ServerStartMsg serverStartMsg = (ServerStartMsg) session.receive();
456 ReplicationMsg msg = session.receive();
600 return (AckMsg)session.receive();
621 UpdateMsg updateMsg = (UpdateMsg) session.receive();
641 UpdateMsg updateMsg = (UpdateMsg) session.receive();
665 UpdateMsg updateMsg = (UpdateMsg) session.receive();
709 UpdateMsg updateMsg = (UpdateMsg) session.receive();
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java261 * Send and receive a Delete Msg from server 1 to server 2
267 ReplicationMsg msg2 = server2.receive();
272 * Send and receive a second Delete Msg
276 msg2 = server2.receive();
281 * Send and receive a Delete Msg from server 2 to server 1
287 msg2 = server1.receive();
292 * Send and receive a second Delete Msg
296 msg2 = server1.receive();
340 ReplicationMsg msg2 = broker.receive();
356 * Test that a client that has already seen some changes now receive
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DSchemaReplicationTest.java159 ReplicationMsg msg = broker.receive();
202 msg = broker.receive();
284 // receive the message on the broker side.
285 ReplicationMsg msg = broker.receive();
H A DGenerationIdTest.java283 // Expect the broker to receive the entries
291 msg = broker.receive();
400 + "ds-cfg-receive-status: true\n"
783 broker3.receive();
807 ReplicationMsg msg = broker3.receive();
893 // Broker 2 and 3 should receive 1 change status message to order them
899 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +
907 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +
954 ReplicationMsg msg = broker2.receive();
960 ReplicationMsg msg = broker3.receive();
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java179 "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n" +
225 "ds-cfg-server-id: 1\n" + "ds-cfg-receive-status: true\n" +
244 * This fake replication server is able to receive a DS connection only.
434 ServerStartMsg serverStartMsg = (ServerStartMsg) session.receive();
456 ReplicationMsg msg = session.receive();
600 return (AckMsg)session.receive();
621 UpdateMsg updateMsg = (UpdateMsg) session.receive();
641 UpdateMsg updateMsg = (UpdateMsg) session.receive();
665 UpdateMsg updateMsg = (UpdateMsg) session.receive();
709 UpdateMsg updateMsg = (UpdateMsg) session.receive();
[all...]
/forgerock/openam-v13/openam-authentication/openam-auth-radius/src/main/java/com/sun/identity/authentication/modules/radius/client/
H A DRadiusConn.java264 res = receive();
361 private Packet receive() method in class:RadiusConn
365 socket.receive(dp);
470 testSocket.receive(dp);
/forgerock/openam/openam-authentication/openam-auth-radius/src/main/java/com/sun/identity/authentication/modules/radius/client/
H A DRadiusConn.java263 res = receive();
360 private Packet receive() method in class:RadiusConn
364 socket.receive(dp);
469 testSocket.receive(dp);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java260 // Send and receive a Delete Msg from server 2 to server 1
273 ReplicationMsg receivedMsg = receiver.receive();
336 ReplicationMsg receivedMsg = broker.receive();
348 * Test that a client that has already seen some changes now receive
363 ReplicationMsg receivedMsg = broker.receive();
438 * now receive it.
844 ReplicationMsg msg = broker2.receive();
855 fail("Broker receive failed: " + e.getMessage() + "#Msg:" + i);
912 ReplServerStartDSMsg replStartDSMsg = (ReplServerStartDSMsg) session.receive();
926 ReplicationMsg repMsg = session.receive();
[all...]

Completed in 105 milliseconds

123456