org.apache.storm.security.auth.kerberos

Class NoOpTTrasport

java.lang.Object

org.apache.storm.thrift.transport.TTransport

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	org.apache.storm.thrift.transport.TSaslTransport.NegotiationStatus
protected static class	org.apache.storm.thrift.transport.TSaslTransport.SaslResponse
protected static class	org.apache.storm.thrift.transport.TSaslTransport.SaslRole

Nested classes/interfaces inherited from class org.apache.storm.thrift.transport.TSaslServerTransport

org.apache.storm.thrift.transport.TSaslServerTransport.Factory

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_MAX_LENGTH
protected static int	MECHANISM_NAME_BYTES
protected static int	PAYLOAD_LENGTH_BYTES
protected static int	STATUS_BYTES
protected org.apache.storm.thrift.transport.TTransport	underlyingTransport

Constructor Summary

Constructors

Constructor and Description
NoOpTTrasport(org.apache.storm.thrift.transport.TTransport transport)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isOpen()
void	open()
int	read(byte[] bytes, int i, int i1)
protected int	readLength()
protected org.apache.storm.thrift.transport.TSaslTransport.SaslResponse	receiveSaslMessage()
protected org.apache.storm.thrift.transport.TTransportException	sendAndThrowMessage(org.apache.storm.thrift.transport.TSaslTransport.NegotiationStatus arg0, String arg1)
protected void	sendSaslMessage(org.apache.storm.thrift.transport.TSaslTransport.NegotiationStatus arg0, byte[] arg1)
protected void	setSaslServer(SaslServer arg0)
void	write(byte[] bytes, int i, int i1)
protected void	writeLength(int arg0)

Methods inherited from class org.apache.storm.thrift.transport.TSaslServerTransport

addServerDefinition, getRole, handleSaslStartMessage

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

consumeBuffer, getBuffer, getBufferPosition, getBytesRemainingInBuffer, peek, readAll, write

Methods inherited from class java.lang.Object

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

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

Constructor Detail

NoOpTTrasport

public NoOpTTrasport(org.apache.storm.thrift.transport.TTransport transport)

Method Detail

isOpen

public boolean isOpen()

Overrides:

isOpen in class org.apache.storm.thrift.transport.TSaslServerTransport

open

public void open()
          throws org.apache.storm.thrift.transport.TTransportException

Overrides:

open in class org.apache.storm.thrift.transport.TSaslServerTransport

Throws:

org.apache.storm.thrift.transport.TTransportException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.apache.storm.thrift.transport.TSaslServerTransport

read

public int read(byte[] bytes,
                int i,
                int i1)
         throws org.apache.storm.thrift.transport.TTransportException

Overrides:

read in class org.apache.storm.thrift.transport.TSaslServerTransport

Throws:

org.apache.storm.thrift.transport.TTransportException

write

public void write(byte[] bytes,
                  int i,
                  int i1)
           throws org.apache.storm.thrift.transport.TTransportException

Overrides:

write in class org.apache.storm.thrift.transport.TSaslServerTransport

Throws:

org.apache.storm.thrift.transport.TTransportException

setSaslServer

protected void setSaslServer(SaslServer arg0)

sendSaslMessage

protected void sendSaslMessage(org.apache.storm.thrift.transport.TSaslTransport.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.TSaslTransport.NegotiationStatus arg0,
                                                                                    String arg1)
                                                                             throws org.apache.storm.thrift.transport.TTransportException

Throws:

org.apache.storm.thrift.transport.TTransportException

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