public abstract class SASLBaseOperationImpl extends BaseOperationImpl
Modifier and Type | Field and Description |
---|---|
protected javax.security.auth.callback.CallbackHandler |
cbh |
protected byte[] |
challenge |
protected static byte |
DUMMY_OPCODE |
protected static byte[] |
EMPTY_BYTES |
protected static int |
ERR_2BIG |
protected static int |
ERR_BUSY |
protected static int |
ERR_DELTA_BADVAL |
protected static int |
ERR_EXISTS |
protected static int |
ERR_INTERNAL |
protected static int |
ERR_INVAL |
protected static int |
ERR_NO_MEM |
protected static int |
ERR_NOT_FOUND |
protected static int |
ERR_NOT_MY_VBUCKET |
protected static int |
ERR_NOT_STORED |
protected static int |
ERR_NOT_SUPPORTED |
protected static int |
ERR_TEMP_FAIL |
protected static int |
ERR_UNKNOWN_COMMAND |
protected int |
errorCode |
protected int |
keyLen |
protected java.lang.String[] |
mech |
protected static int |
MIN_RECV_PACKET |
protected int |
opaque |
protected java.util.Map<java.lang.String,?> |
props |
protected static byte |
REQ_MAGIC |
protected static byte |
RES_MAGIC |
protected long |
responseCas |
protected byte |
responseCmd |
protected int |
responseOpaque |
protected java.lang.String |
serverName |
protected static OperationStatus |
STATUS_OK |
protected static int |
SUCCESS
Error code for operations.
|
protected short |
vbucket |
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
Constructor and Description |
---|
SASLBaseOperationImpl(byte c,
java.lang.String[] m,
byte[] ch,
java.lang.String s,
java.util.Map<java.lang.String,?> p,
javax.security.auth.callback.CallbackHandler h,
OperationCallback cb) |
Modifier and Type | Method and Description |
---|---|
protected abstract byte[] |
buildResponse(javax.security.sasl.SaslClient sc) |
protected void |
decodePayload(byte[] pl)
Decode the given payload for this command.
|
protected void |
finishedPayload(byte[] pl) |
protected OperationStatus |
getStatusForErrorCode(int errCode,
byte[] errPl)
Get the OperationStatus object for the given error code.
|
void |
initialize()
Initialize this operation.
|
protected boolean |
opaqueIsValid()
Validate an opaque value from the header.
|
protected void |
prepareBuffer(java.lang.String key,
long cas,
byte[] val,
java.lang.Object... extraHeaders)
Prepare a send buffer.
|
void |
readFromBuffer(java.nio.ByteBuffer b)
Read data from the given byte buffer and dispatch to the appropriate read
mechanism.
|
protected void |
resetInput() |
java.lang.String |
toString() |
cancel, getBuffer, getCallback, getException, getHandlingNode, getState, handleError, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setHandlingNode, timeOut, transitionState, wasCancelled, writeComplete, writing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
cancel, getBuffer, getCallback, getException, getHandlingNode, getState, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setHandlingNode, timeOut, writeComplete, writing
protected final java.lang.String[] mech
protected final byte[] challenge
protected final java.lang.String serverName
protected final java.util.Map<java.lang.String,?> props
protected final javax.security.auth.callback.CallbackHandler cbh
protected static final byte REQ_MAGIC
protected static final byte RES_MAGIC
protected static final byte DUMMY_OPCODE
protected static final int MIN_RECV_PACKET
protected static final int SUCCESS
protected static final int ERR_NOT_FOUND
protected static final int ERR_EXISTS
protected static final int ERR_2BIG
protected static final int ERR_INVAL
protected static final int ERR_NOT_STORED
protected static final int ERR_DELTA_BADVAL
protected static final int ERR_NOT_MY_VBUCKET
protected static final int ERR_UNKNOWN_COMMAND
protected static final int ERR_NO_MEM
protected static final int ERR_NOT_SUPPORTED
protected static final int ERR_INTERNAL
protected static final int ERR_BUSY
protected static final int ERR_TEMP_FAIL
protected static final byte[] EMPTY_BYTES
protected static final OperationStatus STATUS_OK
protected short vbucket
protected final int opaque
protected int keyLen
protected byte responseCmd
protected int errorCode
protected int responseOpaque
protected long responseCas
public SASLBaseOperationImpl(byte c, java.lang.String[] m, byte[] ch, java.lang.String s, java.util.Map<java.lang.String,?> p, javax.security.auth.callback.CallbackHandler h, OperationCallback cb)
public void initialize()
Operation
initialize
in interface Operation
initialize
in class BaseOperationImpl
protected abstract byte[] buildResponse(javax.security.sasl.SaslClient sc) throws javax.security.sasl.SaslException
javax.security.sasl.SaslException
protected void decodePayload(byte[] pl)
pl
- the payload.protected void finishedPayload(byte[] pl) throws java.io.IOException
java.io.IOException
public java.lang.String toString()
protected void resetInput()
public void readFromBuffer(java.nio.ByteBuffer b) throws java.io.IOException
Operation
readFromBuffer
in interface Operation
readFromBuffer
in class BaseOperationImpl
java.io.IOException
protected OperationStatus getStatusForErrorCode(int errCode, byte[] errPl) throws java.io.IOException
errCode
- the error codejava.io.IOException
protected boolean opaqueIsValid()
protected void prepareBuffer(java.lang.String key, long cas, byte[] val, java.lang.Object... extraHeaders)
key
- the key (for keyed ops)cas
- the cas valueval
- the data payloadextraHeaders
- any additional headers that need to be sentCopyright © 2006-2009 Dustin Sallings, 2009-2013 Couchbase, Inc.