Class NoOpTTrasport
- java.lang.Object
-
- org.apache.storm.thrift.transport.TTransport
-
- org.apache.storm.thrift.transport.TEndpointTransport
-
- org.apache.storm.thrift.transport.TSaslServerTransport
-
- org.apache.storm.security.auth.kerberos.NoOpTTrasport
-
- All Implemented Interfaces:
Closeable,AutoCloseable
public class NoOpTTrasport extends org.apache.storm.thrift.transport.TSaslServerTransport
-
-
Field Summary
Fields Modifier and Type Field Description protected static intDEFAULT_MAX_LENGTHprotected static intMECHANISM_NAME_BYTESprotected static intPAYLOAD_LENGTH_BYTESprotected static intSTATUS_BYTESprotected org.apache.storm.thrift.transport.TTransportunderlyingTransport
-
Constructor Summary
Constructors Constructor Description NoOpTTrasport(org.apache.storm.thrift.transport.TTransport transport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidflush()SaslClientgetSaslClient()SaslServergetSaslServer()org.apache.storm.thrift.transport.TTransportgetUnderlyingTransport()booleanisOpen()voidopen()intread(byte[] bytes, int i, int i1)protected intreadLength()protected org.apache.storm.thrift.transport.TSaslTransport.SaslResponsereceiveSaslMessage()protected org.apache.storm.thrift.transport.TTransportExceptionsendAndThrowMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, String arg1)protected voidsendSaslMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, byte[] arg1)protected voidsetSaslServer(SaslServer arg0)voidwrite(byte[] bytes, int i, int i1)protected voidwriteLength(int arg0)-
Methods inherited from class org.apache.storm.thrift.transport.TSaslServerTransport
addServerDefinition, getRole, handleSaslStartMessage
-
Methods inherited from class org.apache.storm.thrift.transport.TEndpointTransport
checkReadBytesAvailable, countConsumedMessageBytes, getConfiguration, getMaxFrameSize, getMaxMessageSize, resetConsumedMessageSize, setMaxFrameSize, updateKnownMessageSize
-
-
-
-
Field Detail
-
DEFAULT_MAX_LENGTH
protected static final int DEFAULT_MAX_LENGTH
- See Also:
- Constant Field Values
-
MECHANISM_NAME_BYTES
protected static final int MECHANISM_NAME_BYTES
- See Also:
- Constant Field Values
-
STATUS_BYTES
protected static final int STATUS_BYTES
- See Also:
- Constant Field Values
-
PAYLOAD_LENGTH_BYTES
protected static final int PAYLOAD_LENGTH_BYTES
- See Also:
- Constant Field Values
-
underlyingTransport
protected org.apache.storm.thrift.transport.TTransport underlyingTransport
-
-
Method Detail
-
isOpen
public boolean isOpen()
-
open
public void open() throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
read
public int read(byte[] bytes, int i, int i1) throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
write
public void write(byte[] bytes, int i, int i1) throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
setSaslServer
protected void setSaslServer(SaslServer arg0)
-
sendSaslMessage
protected void sendSaslMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, byte[] arg1) throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
receiveSaslMessage
protected org.apache.storm.thrift.transport.TSaslTransport.SaslResponse receiveSaslMessage() throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
sendAndThrowMessage
protected org.apache.storm.thrift.transport.TTransportException sendAndThrowMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, String arg1) throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
getSaslClient
public SaslClient getSaslClient()
-
getUnderlyingTransport
public org.apache.storm.thrift.transport.TTransport getUnderlyingTransport()
-
getSaslServer
public SaslServer getSaslServer()
-
readLength
protected int readLength() throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
writeLength
protected void writeLength(int arg0) throws org.apache.storm.thrift.transport.TTransportException- Throws:
org.apache.storm.thrift.transport.TTransportException
-
flush
public void flush() throws org.apache.storm.thrift.transport.TTransportException- Overrides:
flushin classorg.apache.storm.thrift.transport.TTransport- Throws:
org.apache.storm.thrift.transport.TTransportException
-
-