|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.thrift.transport.TTransport
org.apache.thrift.transport.TFramedTransport
public class TFramedTransport
TFramedTransport is a buffered TTransport that ensures a fully read message every time by preceeding messages with a 4-byte frame size.
Nested Class Summary | |
---|---|
static class |
TFramedTransport.Factory
|
Field Summary | |
---|---|
protected static int |
DEFAULT_MAX_LENGTH
|
Constructor Summary | |
---|---|
TFramedTransport(TTransport transport)
|
|
TFramedTransport(TTransport transport,
int maxLength)
Constructor wraps around another tranpsort |
Method Summary | |
---|---|
void |
close()
Closes the transport. |
void |
consumeBuffer(int len)
Consume len bytes from the underlying buffer. |
void |
flush()
Flush any pending data out of a transport buffer. |
byte[] |
getBuffer()
Access the protocol's underlying buffer directly. |
int |
getBufferPosition()
Return the index within the underlying buffer that specifies the next spot that should be read from. |
int |
getBytesRemainingInBuffer()
Get the number of bytes remaining in the underlying buffer. |
boolean |
isOpen()
Queries whether the transport is open. |
void |
open()
Opens the transport for reading/writing. |
int |
read(byte[] buf,
int off,
int len)
Reads up to len bytes into buffer buf, starting att offset off. |
void |
write(byte[] buf,
int off,
int len)
Writes up to len bytes from the buffer. |
Methods inherited from class org.apache.thrift.transport.TTransport |
---|
peek, readAll, write |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final int DEFAULT_MAX_LENGTH
Constructor Detail |
---|
public TFramedTransport(TTransport transport, int maxLength)
public TFramedTransport(TTransport transport)
Method Detail |
---|
public void open() throws TTransportException
TTransport
open
in class TTransport
TTransportException
- if the transport could not be openedpublic boolean isOpen()
TTransport
isOpen
in class TTransport
public void close()
TTransport
close
in class TTransport
public int read(byte[] buf, int off, int len) throws TTransportException
TTransport
read
in class TTransport
buf
- Array to read intooff
- Index to start reading atlen
- Maximum number of bytes to read
TTransportException
- if there was an error reading datapublic byte[] getBuffer()
TTransport
getBuffer
in class TTransport
public int getBufferPosition()
TTransport
getBufferPosition
in class TTransport
public int getBytesRemainingInBuffer()
TTransport
getBytesRemainingInBuffer
in class TTransport
public void consumeBuffer(int len)
TTransport
consumeBuffer
in class TTransport
public void write(byte[] buf, int off, int len) throws TTransportException
TTransport
write
in class TTransport
buf
- The output data bufferoff
- The offset to start writing fromlen
- The number of bytes to write
TTransportException
- if there was an error writing datapublic void flush() throws TTransportException
TTransport
flush
in class TTransport
TTransportException
- if there was an error writing out data.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |