org.apache.thrift.transport

Class TEndpointTransport

java.lang.Object

org.apache.thrift.transport.TTransport

org.apache.thrift.transport.TEndpointTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

AutoExpandingBufferReadTransport, AutoExpandingBufferWriteTransport, TByteBuffer, THttpClient, TIOStreamTransport, TMemoryBuffer, TMemoryInputTransport, TMemoryTransport, TNonblockingTransport, TSaslClientTransport, TSaslServerTransport, TSimpleFileTransport

public abstract class TEndpointTransport
extends TTransport

Field Summary

Fields

Modifier and Type	Field and Description
protected long	knownMessageSize
protected long	remainingMessageSize

Constructor Summary

Constructors

Constructor and Description
TEndpointTransport(TConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	checkReadBytesAvailable(long numBytes) Throws if there are not enough bytes in the input stream to satisfy a read of numBytes bytes of data
protected void	countConsumedMessageBytes(long numBytes) Consumes numBytes from the RemainingMessageSize.
TConfiguration	getConfiguration()
protected long	getMaxMessageSize()
protected void	resetConsumedMessageSize(long newSize) Resets RemainingMessageSize to the configured maximum
void	updateKnownMessageSize(long size) Updates RemainingMessageSize to reflect then known real message size (e.g.

Methods inherited from class org.apache.thrift.transport.TTransport

close, consumeBuffer, flush, getBuffer, getBufferPosition, getBytesRemainingInBuffer, isOpen, open, peek, read, read, readAll, write, write, write

Methods inherited from class java.lang.Object

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

Field Detail

knownMessageSize

protected long knownMessageSize

remainingMessageSize

protected long remainingMessageSize

Constructor Detail

TEndpointTransport

public TEndpointTransport(TConfiguration config)
                   throws TTransportException

Throws:

TTransportException

Method Detail

getMaxMessageSize

protected long getMaxMessageSize()

getConfiguration

public TConfiguration getConfiguration()

Specified by:

getConfiguration in class TTransport

resetConsumedMessageSize

protected void resetConsumedMessageSize(long newSize)
                                 throws TTransportException

Resets RemainingMessageSize to the configured maximum

Parameters:

newSize -

Throws:

TTransportException

updateKnownMessageSize

public void updateKnownMessageSize(long size)
                            throws TTransportException

Updates RemainingMessageSize to reflect then known real message size (e.g. framed transport). Will throw if we already consumed too many bytes or if the new size is larger than allowed.

Specified by:

updateKnownMessageSize in class TTransport

Parameters:

size -

Throws:

TTransportException

checkReadBytesAvailable

public void checkReadBytesAvailable(long numBytes)
                             throws TTransportException

Throws if there are not enough bytes in the input stream to satisfy a read of numBytes bytes of data

Specified by:

checkReadBytesAvailable in class TTransport

Parameters:

numBytes -

Throws:

TTransportException

countConsumedMessageBytes

protected void countConsumedMessageBytes(long numBytes)
                                  throws TTransportException

Consumes numBytes from the RemainingMessageSize.

Parameters:

numBytes -

Throws:

TTransportException