Package org.apache.cassandra.streaming

Class SessionInfo

java.lang.Object

org.apache.cassandra.streaming.SessionInfo

All Implemented Interfaces:

Serializable

public final class SessionInfo
extends Object
implements Serializable

Stream session info.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
final InetSocketAddress	connecting
final String	failureReason
final InetSocketAddress	peer
final Collection<StreamSummary>	receivingSummaries	Immutable collection of receiving summaries
final Collection<StreamSummary>	sendingSummaries	Immutable collection of sending summaries
final int	sessionIndex
final StreamSession.State	state	Current session state

Constructor Summary

Constructors

Constructor	Description
SessionInfo(InetSocketAddress peer, int sessionIndex, InetSocketAddress connecting, Collection<StreamSummary> receivingSummaries, Collection<StreamSummary> sendingSummaries, StreamSession.State state, String failureReason)
SessionInfo(SessionInfo other)

Method Summary

Modifier and Type	Method	Description
SessionSummary	createSummary()
String	getFailureReason()
Collection<ProgressInfo>	getReceivingFiles()
Collection<ProgressInfo>	getSendingFiles()
long	getTotalFilesReceived()
long	getTotalFilesSent()
long	getTotalFilesToReceive()
long	getTotalFilesToSend()
long	getTotalSizeReceived()
long	getTotalSizeSent()
long	getTotalSizeToReceive()
long	getTotalSizeToSend()
boolean	isAborted()
boolean	isFailed()
void	updateProgress(ProgressInfo newProgress)	Update progress of receiving/sending stream.

Methods inherited from class java.lang.Object

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

Field Details

peer

public final InetSocketAddress peer

sessionIndex

public final int sessionIndex

connecting

public final InetSocketAddress connecting

receivingSummaries

public final Collection<StreamSummary> receivingSummaries

Immutable collection of receiving summaries

sendingSummaries

public final Collection<StreamSummary> sendingSummaries

Immutable collection of sending summaries

state

public final StreamSession.State state

Current session state

failureReason

public final String failureReason

Constructor Details

SessionInfo

public SessionInfo(InetSocketAddress peer,
 int sessionIndex,
 InetSocketAddress connecting,
 Collection<StreamSummary> receivingSummaries,
 Collection<StreamSummary> sendingSummaries,
 StreamSession.State state,
 String failureReason)

SessionInfo

public SessionInfo(SessionInfo other)

Method Details

isFailed

public boolean isFailed()

isAborted

public boolean isAborted()

updateProgress

public void updateProgress(ProgressInfo newProgress)

Update progress of receiving/sending stream.

Parameters:

newProgress - new progress info

getReceivingFiles

public Collection<ProgressInfo> getReceivingFiles()

getSendingFiles

public Collection<ProgressInfo> getSendingFiles()

getTotalFilesReceived

public long getTotalFilesReceived()

Returns:

total number of files already received.

getTotalFilesSent

public long getTotalFilesSent()

Returns:

total number of files already sent.

getTotalSizeReceived

public long getTotalSizeReceived()

Returns:

total size(in bytes) already received.

getTotalSizeSent

public long getTotalSizeSent()

Returns:

total size(in bytes) already sent.

getTotalFilesToReceive

public long getTotalFilesToReceive()

Returns:

total number of files to receive in the session

getTotalFilesToSend

public long getTotalFilesToSend()

Returns:

total number of files to send in the session

getTotalSizeToReceive

public long getTotalSizeToReceive()

Returns:

total size(in bytes) to receive in the session

getTotalSizeToSend

public long getTotalSizeToSend()

Returns:

total size(in bytes) to send in the session

createSummary

public SessionSummary createSummary()

getFailureReason

public String getFailureReason()