Uses of Class
com.bigdata.ha.pipeline.ImmediateDownstreamReplicationException

Packages that use ImmediateDownstreamReplicationException

Package	Description
com.bigdata.ha.pipeline	This package provides services for sending and receiving low-level write cache blocks among the members of a highly available quorum.

Uses of ImmediateDownstreamReplicationException in com.bigdata.ha.pipeline

Methods in com.bigdata.ha.pipeline that throw ImmediateDownstreamReplicationException

Modifier and Type	Method and Description
Future<Void>	HASendService.send(ByteBuffer buffer, byte[] marker) Send the bytes Buffer.remaining() in the buffer to the configured InetSocketAddress.
void	TestHASendAndReceive3Nodes.testChecksumError()
void	TestHASendAndReceive.testSimpleExchange() Should we expect concurrency of the Socket send and RMI? It seems that we should be able to handle it whatever the logical argument.
void	TestHASendAndReceive3Nodes.testSimpleExchange()
void	TestHASendAndReceive.testStress() Sends a large number of random buffers, confirming successful transmission.