public class NoOpTTrasport
extends org.apache.storm.thrift.transport.TSaslServerTransport
| 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 |
| 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 and Description |
|---|
NoOpTTrasport(org.apache.storm.thrift.transport.TTransport transport) |
| 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) |
addServerDefinition, getRole, handleSaslStartMessageprotected static final int DEFAULT_MAX_LENGTH
protected static final int MECHANISM_NAME_BYTES
protected static final int STATUS_BYTES
protected static final int PAYLOAD_LENGTH_BYTES
protected org.apache.storm.thrift.transport.TTransport underlyingTransport
public NoOpTTrasport(org.apache.storm.thrift.transport.TTransport transport)
public boolean isOpen()
isOpen in class org.apache.storm.thrift.transport.TSaslServerTransportpublic void open()
throws org.apache.storm.thrift.transport.TTransportException
open in class org.apache.storm.thrift.transport.TSaslServerTransportorg.apache.storm.thrift.transport.TTransportExceptionpublic void close()
close in interface Closeableclose in interface AutoCloseableclose in class org.apache.storm.thrift.transport.TSaslServerTransportpublic int read(byte[] bytes,
int i,
int i1)
throws org.apache.storm.thrift.transport.TTransportException
read in class org.apache.storm.thrift.transport.TSaslServerTransportorg.apache.storm.thrift.transport.TTransportExceptionpublic void write(byte[] bytes,
int i,
int i1)
throws org.apache.storm.thrift.transport.TTransportException
write in class org.apache.storm.thrift.transport.TSaslServerTransportorg.apache.storm.thrift.transport.TTransportExceptionprotected void setSaslServer(SaslServer arg0)
protected void sendSaslMessage(org.apache.storm.thrift.transport.TSaslTransport.NegotiationStatus arg0,
byte[] arg1)
throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportExceptionprotected org.apache.storm.thrift.transport.TSaslTransport.SaslResponse receiveSaslMessage()
throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportExceptionprotected org.apache.storm.thrift.transport.TTransportException sendAndThrowMessage(org.apache.storm.thrift.transport.TSaslTransport.NegotiationStatus arg0,
String arg1)
throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportExceptionprotected int readLength()
throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportExceptionprotected void writeLength(int arg0)
throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.