com.fr.third.jgroups.protocols.pbcast

类 STATE

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

com.fr.third.jgroups.protocols.pbcast.STATE

所有已实现的接口:

ProcessingQueue.Handler<Address>

public class STATE
extends StreamingStateTransfer

STATE streams the state (written to an OutputStream) to the state requester in chunks (defined by chunk_size). Every chunk is sent via a unicast message. The state requester writes the chunks into a blocking input stream (BlockingInputStream) from which the MessageListener.setState(java.io.InputStream) reads it. The size of the BlockingInputStream is buffer_size bytes.

When implementing MessageListener.getState(java.io.OutputStream), the state should be written in sizeable chunks, because the underlying output stream generates 1 message / write. So if there are 1000 writes of 1 byte each, this would generate 1000 messages ! We suggest using a BufferedOutputStream over the output stream handed to the application as argument of the callback.

When implementing the MessageListener.setState(java.io.InputStream) callback, there is no need to use a BufferedOutputStream, as the input stream handed to the application already buffers incoming data internally.

从以下版本开始:

2.4

作者:

Bela Ban, Vladimir Blagojevic

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	STATE.StateOutputStream

从类继承的嵌套类/接口 com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

StreamingStateTransfer.StateGetter, StreamingStateTransfer.StateHeader

字段概要

字段

限定符和类型	字段和说明
protected BlockingInputStream	input_stream If use_default_transport is true, we consume bytes off of this blocking queue.

从类继承的字段 com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

avg_state_size, buffer_size, flushProtocolInStack, local_addr, max_pool, members, num_bytes_sent, num_state_reqs, pool_thread_keep_alive, state_provider, state_requesters, thread_pool

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
STATE()

方法概要

方法

限定符和类型	方法和说明
protected Tuple<java.io.InputStream,java.lang.Object>	createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr) Creates an InputStream to the state provider to read the state.
protected void	createStreamToRequester(Address requester) Creates an OutputStream to the state requester to write the state
protected void	handleEOF(Address sender)
protected void	handleException(java.lang.Throwable exception)
protected void	handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	handleViewChange(View v)
protected boolean	useAsyncStateDelivery()

从类继承的方法 com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

close, closeBarrierAndSuspendStable, closeHoleFor, createThreadPool, destroy, determineCoordinator, down, getAverageStateSize, getNumberOfStateBytesSent, getNumberOfStateRequests, getStateFromApplication, getThreadPoolCompletedTasks, getThreadPoolSize, handle, handleConfig, handleStateReq, handleStateRsp, init, isDigestNeeded, modifyStateResponseHeader, openBarrier, openBarrierAndResumeStable, punchHoleFor, requiredDownServices, resetStats, resumeStable, sendEof, sendException, setStateInApplication, start, stop, up

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

input_stream

protected volatile BlockingInputStream input_stream

If use_default_transport is true, we consume bytes off of this blocking queue. Used on the state requester side only. Note that we cannot use a PipedInputStream as we have multiple writer threads pushing data into the input stream

构造器详细资料

STATE

public STATE()

方法详细资料

handleViewChange

protected void handleViewChange(View v)

覆盖:

handleViewChange 在类中 StreamingStateTransfer

handleEOF

protected void handleEOF(Address sender)

覆盖:

handleEOF 在类中 StreamingStateTransfer

handleException

protected void handleException(java.lang.Throwable exception)

覆盖:

handleException 在类中 StreamingStateTransfer

handleStateChunk

protected void handleStateChunk(Address sender,
                    byte[] buffer,
                    int offset,
                    int length)

覆盖:

handleStateChunk 在类中 StreamingStateTransfer

createStreamToRequester

protected void createStreamToRequester(Address requester)

从类复制的说明: StreamingStateTransfer

Creates an OutputStream to the state requester to write the state

覆盖:

createStreamToRequester 在类中 StreamingStateTransfer

createStreamToProvider

protected Tuple<java.io.InputStream,java.lang.Object> createStreamToProvider(Address provider,
                                                                 StreamingStateTransfer.StateHeader hdr)

从类复制的说明: StreamingStateTransfer

Creates an InputStream to the state provider to read the state. Return the input stream and a handback object as a tuple. The handback object is handed back to the subclass when done, or in case of an error (e.g. to clean up resources)

指定者:

createStreamToProvider 在类中 StreamingStateTransfer

useAsyncStateDelivery

protected boolean useAsyncStateDelivery()

覆盖:

useAsyncStateDelivery 在类中 StreamingStateTransfer