Searched defs:receive (Results 1 - 25 of 41) sorted by relevance

12

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DSession.java388 * Attempt to receive a ReplicationMsg.
402 public ReplicationMsg receive() throws IOException, method in class:Session
514 * With this option set to a non-zero value, calls to the receive() method
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DSession.java394 * Attempt to receive a ReplicationMsg.
408 public ReplicationMsg receive() throws IOException, method in class:Session
505 * With this option set to a non-zero value, calls to the receive() method
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DSession.java388 * Attempt to receive a ReplicationMsg.
402 public ReplicationMsg receive() throws IOException, method in class:Session
514 * With this option set to a non-zero value, calls to the receive() method
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DSession.java388 * Attempt to receive a ReplicationMsg.
402 public ReplicationMsg receive() throws IOException, method in class:Session
514 * With this option set to a non-zero value, calls to the receive() method
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DSession.java394 * Attempt to receive a ReplicationMsg.
408 public ReplicationMsg receive() throws IOException, method in class:Session
505 * With this option set to a non-zero value, calls to the receive() method
/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/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DSession.java388 * Attempt to receive a ReplicationMsg.
402 public ReplicationMsg receive() throws IOException, method in class:Session
484 * With this option set to a non-zero value, calls to the receive() method
/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/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java217 * @param window The size of the send and receive window to use.
1275 ReplicationMsg msg = localSession.receive();
1391 * StartSessionMsg and receive TopologyMsg messages exchange) and return the
1411 topologyMsg = (TopologyMsg) session.receive();
1438 * Performs the second phase handshake (send StartSessionMsg and receive
1483 topologyMsg = (TopologyMsg) session.receive();
2391 // The receive threads should handle reconnection or
2432 public ReplicationMsg receive() throws SocketTimeoutException method in class:ReplicationBroker
2434 return receive(false, true, false);
2454 public ReplicationMsg receive(boolea method in class:ReplicationBroker
[all...]
H A DReplicationDomain.java731 UpdateMsg receive() method in class:ReplicationDomain
741 msg = broker.receive(true, true, false);
770 because we are now going to receive a bunch of entries from the
852 broker.receive() method.
1025 * serverId of server that will receive entries
1812 msg = broker.receive(false, false, true);
2180 The context will be used when we (the listener thread) will receive
2195 The normal success processing is now to receive InitTargetMsg then
2199 - a remote error we will receive as an ErrorMsg
2615 * Get the maximum receive windo
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1109 ReplicationMsg msg = newSession.receive();
1196 * Performs the second phase handshake (send StartSessionMsg and receive
1225 final TopologyMsg topologyMsg = (TopologyMsg) session.receive();
2386 // The receive threads should handle reconnection or
2428 public ReplicationMsg receive() throws SocketTimeoutException method in class:ReplicationBroker
2430 return receive(false, true, false);
2450 ReplicationMsg receive(boolean reconnectToTheBestRS, method in class:ReplicationBroker
2477 ReplicationMsg msg = rs.session.receive();
2695 // Any error on the socket will be handled by the thread calling receive()
2722 * With this option set to a non-zero value, calls to the receive() metho
[all...]
H A DReplicationDomain.java764 private UpdateMsg receive() method in class:ReplicationDomain
774 msg = broker.receive(true, true, false);
804 because we are now going to receive a bunch of entries from the
888 broker.receive() method.
1067 * serverId of server that will receive entries
1899 msg = broker.receive(false, false, true);
2213 The context will be used when we (the listener thread) will receive
2226 The normal success processing is now to receive InitTargetMsg then
2230 - a remote error we will receive as an ErrorMsg
2636 * Get the maximum receive windo
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java214 * @param window The size of the send and receive window to use.
1277 ReplicationMsg msg = localSession.receive();
1392 * StartSessionMsg and receive TopologyMsg messages exchange) and return the
1412 topologyMsg = (TopologyMsg) session.receive();
1438 * Performs the second phase handshake (send StartSessionMsg and receive
1483 topologyMsg = (TopologyMsg) session.receive();
2649 // The receive threads should handle reconnection or
2690 public ReplicationMsg receive() throws SocketTimeoutException method in class:ReplicationBroker
2692 return receive(false, true, false);
2712 public ReplicationMsg receive(boolea method in class:ReplicationBroker
[all...]
H A DReplicationDomain.java732 UpdateMsg receive() method in class:ReplicationDomain
742 msg = broker.receive(true, true, false);
771 because we are now going to receive a bunch of entries from the
853 broker.receive() method.
1026 * serverId of server that will receive entries
1813 msg = broker.receive(false, false, true);
2181 The context will be used when we (the listener thread) will receive
2196 The normal success processing is now to receive InitTargetMsg then
2200 - a remote error we will receive as an ErrorMsg
2616 * Get the maximum receive windo
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java217 * @param window The size of the send and receive window to use.
1275 ReplicationMsg msg = localSession.receive();
1391 * StartSessionMsg and receive TopologyMsg messages exchange) and return the
1411 topologyMsg = (TopologyMsg) session.receive();
1438 * Performs the second phase handshake (send StartSessionMsg and receive
1483 topologyMsg = (TopologyMsg) session.receive();
2391 // The receive threads should handle reconnection or
2432 public ReplicationMsg receive() throws SocketTimeoutException method in class:ReplicationBroker
2434 return receive(false, true, false);
2454 public ReplicationMsg receive(boolea method in class:ReplicationBroker
[all...]
H A DReplicationDomain.java731 UpdateMsg receive() method in class:ReplicationDomain
741 msg = broker.receive(true, true, false);
770 because we are now going to receive a bunch of entries from the
852 broker.receive() method.
1025 * serverId of server that will receive entries
1812 msg = broker.receive(false, false, true);
2180 The context will be used when we (the listener thread) will receive
2195 The normal success processing is now to receive InitTargetMsg then
2199 - a remote error we will receive as an ErrorMsg
2615 * Get the maximum receive windo
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1109 ReplicationMsg msg = newSession.receive();
1196 * Performs the second phase handshake (send StartSessionMsg and receive
1225 final TopologyMsg topologyMsg = (TopologyMsg) session.receive();
2386 // The receive threads should handle reconnection or
2428 public ReplicationMsg receive() throws SocketTimeoutException method in class:ReplicationBroker
2430 return receive(false, true, false);
2450 ReplicationMsg receive(boolean reconnectToTheBestRS, method in class:ReplicationBroker
2477 ReplicationMsg msg = rs.session.receive();
2695 // Any error on the socket will be handled by the thread calling receive()
2722 * With this option set to a non-zero value, calls to the receive() metho
[all...]
H A DReplicationDomain.java764 private UpdateMsg receive() method in class:ReplicationDomain
774 msg = broker.receive(true, true, false);
804 because we are now going to receive a bunch of entries from the
888 broker.receive() method.
1067 * serverId of server that will receive entries
1899 msg = broker.receive(false, false, true);
2213 The context will be used when we (the listener thread) will receive
2226 The normal success processing is now to receive InitTargetMsg then
2230 - a remote error we will receive as an ErrorMsg
2636 * Get the maximum receive windo
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java1094 ReplicationMsg msg = newSession.receive();
1177 * Performs the second phase handshake (send StartSessionMsg and receive
1206 final TopologyMsg topologyMsg = (TopologyMsg) session.receive();
2360 // The receive threads should handle reconnection or
2402 public ReplicationMsg receive() throws SocketTimeoutException method in class:ReplicationBroker
2404 return receive(false, true, false);
2424 ReplicationMsg receive(boolean reconnectToTheBestRS, method in class:ReplicationBroker
2451 ReplicationMsg msg = rs.session.receive();
2660 // Any error on the socket will be handled by the thread calling receive()
2690 * With this option set to a non-zero value, calls to the receive() metho
[all...]
H A DReplicationDomain.java734 private UpdateMsg receive() method in class:ReplicationDomain
744 msg = broker.receive(true, true, false);
774 because we are now going to receive a bunch of entries from the
860 broker.receive() method.
1037 * serverId of server that will receive entries
1873 msg = broker.receive(false, false, true);
2185 The context will be used when we (the listener thread) will receive
2198 The normal success processing is now to receive InitTargetMsg then
2202 - a remote error we will receive as an ErrorMsg
2596 * Get the maximum receive windo
[all...]
/forgerock/opendj2/ext/svnkit/lib/
H A Dsvnkit-javahl16-1.8.5.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/apache/ org/ ...
H A Dsvnkit-cli-1.8.5.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/tmatesoft/ org/ ...
/forgerock/opendj2-hg/ext/svnkit/lib/
H A Dsvnkit-javahl16-1.8.5.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/apache/ org/ ...
H A Dsvnkit-cli-1.8.5.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/tmatesoft/ org/ ...
/forgerock/opendj-b2.6/ext/svnkit/
H A Dsvnkit-javahl.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/apache/ org/ ...

Completed in 220 milliseconds

12