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, getWriteCompleteTimestamp, 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, getWriteCompleteTimestamp, 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.