Jackson 2.18.2 · com.fasterxml.jackson.dataformat.smile.async.NonBlockingByteArrayParser

Modifier and Type	Field and Description
protected byte[]	_inputBuffer This buffer is actually provided via `NonBlockingInputFeeder`
protected int	_origBufferLen In addition to current buffer pointer, and end pointer, we will also need to know number of bytes originally contained.

Access	Constructor and Description
public	NonBlockingByteArrayParser(IOContext ctxt, int parserFeatures, int smileFeatures, ByteQuadsCanonicalizer sym)

Method Summary

Modifier and Type	Method and Description
private final boolean	_decode7BitEncoded()
protected final boolean	_decode7BitEncodedTail(int bytesToDecode, int buffered)
private final String	_decodeASCIIText(byte[] inBuf, int inPtr, int len)
private final String	_decodeLongUnicodeName(byte[] inBuf, int inPtr, int len)
private final String	_decodeShortUnicodeText(byte[] inBuf, int inPtr, int Length between 1 and 64 len) Helper method used to decode short Unicode string, length for which actual length (in bytes) is known
private final int	_decodeUTF8_2(int c, int d)
private final int	_decodeUTF8_3(int c, int d, int e)
private final int	_decodeUTF8_4(int c, int d, int e, int f)
private final int	_decodeVInt()
private final JsonToken	_finish7BitBinaryBody()
private final JsonToken	_finish7BitBinaryLen(int value, int bytesRead)
private final JsonToken	_finishBigDecimalBody()
private final JsonToken	_finishBigDecimalLen(int value, int bytesRead)
private final JsonToken	_finishBigDecimalScale(int value, int bytesRead)
private final JsonToken	_finishBigIntBody()
private final JsonToken	_finishBigIntLen(int value, int bytesRead)
protected final JsonToken	_finishDouble(long value, int bytesRead)
protected final JsonToken	_finishFloat(int value, int bytesRead)
protected JsonToken	_finishHeader(int state) Helper method that will decode information from a header block that has been detected.
private final JsonToken	_finishInt(int value, int bytesRead)
private final JsonToken	_finishLong(long value, int bytesRead)
private final JsonToken	_finishLongASCII()
private final JsonToken	_finishLongFieldName(int outPtr)
private final JsonToken	_finishLongUnicode()
private final boolean	_finishPartialUnicodeChar()
private final JsonToken	_finishRawBinaryBody()
private final JsonToken	_finishRawBinaryLen(int value, int bytesRead)
protected final JsonToken	_finishToken() Method called when a (scalar) value type has been detected, but not all of contents have been decoded due to incomplete input available.
private final int	_fourBytesToInt(int ptr)
private final JsonToken	_start7BitBinary()
private final JsonToken	_startBigDecimal()
private final JsonToken	_startBigInt()
protected final JsonToken	_startDouble()
protected final JsonToken	_startFieldName(int ch) Method that handles initial token type recognition for token that has to be either FIELD_NAME or END_OBJECT.
protected final JsonToken	_startFloat()
private final JsonToken	_startInt()
private final JsonToken	_startLong()
private final JsonToken	_startLongASCII()
protected final JsonToken	_startLongUnicode()
protected final JsonToken	_startRawBinary()
private final JsonToken	_startShortASCII(final int len)
private final JsonToken	_startShortUnicode(final int len)
private final JsonToken	_startValue(int ch) Helper method called to detect type of a value token (at any level), and possibly decode it if contained in input buffer.
public void	endOfInput() Implements com.fasterxml.jackson.core.async.NonBlockingInputFeeder.endOfInput. Method that should be called after last chunk of data to parse has been fed (with `feedInput` in sub-class); can be called regardless of what `needMoreInput` returns.
public void	feedInput(byte[] Byte array that contains data to feed: caller must ensure data remains stable until it is fully processed (which is true when `needMoreInput` returns true) buf, int Offset within array where input data to process starts start, int Offset after last byte contained in the input array end) Implements com.fasterxml.jackson.core.async.ByteArrayFeeder.feedInput. Method that can be called to feed more data, if (and only if) `needMoreInput` returns true.
public ByteArrayFeeder	getNonBlockingInputFeeder() Overrides com.fasterxml.jackson.core.JsonParser.getNonBlockingInputFeeder. Method that will either return a feeder instance (if parser uses non-blocking, aka asynchronous access); or `null` for parsers that use blocking I/O.
public final boolean	needMoreInput() Implements com.fasterxml.jackson.core.async.NonBlockingInputFeeder.needMoreInput. Method called to check whether it is ok to feed more data: parser returns true if it has no more content to parse (and it is ok to feed more); otherwise false (and no data should yet be fed).
public JsonToken	nextToken() Implements abstract com.fasterxml.jackson.core.base.ParserMinimalBase.nextToken. Main iteration method, which will advance stream enough to determine type of the next token, if any.
public int	releaseBuffered(OutputStream OutputStream to which buffered, undecoded content is written to out) Implements abstract com.fasterxml.jackson.dataformat.smile.async.NonBlockingParserBase.releaseBuffered. Method that can be called to push back any content that has been read but not consumed by the parser.

_inputBuffer	back to summary
protected byte[] _inputBuffer This buffer is actually provided via `NonBlockingInputFeeder`

_origBufferLen	back to summary
protected int _origBufferLen In addition to current buffer pointer, and end pointer, we will also need to know number of bytes originally contained. This is needed to correctly update location information when the block has been completed.

NonBlockingByteArrayParser	back to summary
public NonBlockingByteArrayParser(IOContext ctxt, int parserFeatures, int smileFeatures, ByteQuadsCanonicalizer sym)

Method Detail

_decode7BitEncoded	back to summary
private final boolean _decode7BitEncoded() throws IOException

_decode7BitEncodedTail	back to summary
protected final boolean _decode7BitEncodedTail(int bytesToDecode, int buffered) throws IOException

_decodeASCIIText	back to summary
private final String _decodeASCIIText(byte[] inBuf, int inPtr, int len) throws IOException

_decodeLongUnicodeName	back to summary
private final String _decodeLongUnicodeName(byte[] inBuf, int inPtr, int len) throws IOException

_decodeShortUnicodeText	back to summary
private final String _decodeShortUnicodeText(byte[] inBuf, int inPtr, int len) throws IOException Helper method used to decode short Unicode string, length for which actual length (in bytes) is known Parameters len:int Length between 1 and 64

_decodeShortUnicodeText

back to summary

private final String _decodeShortUnicodeText(byte[] inBuf, int inPtr, int len) throws IOException

Helper method used to decode short Unicode string, length for which actual length (in bytes) is known

Parameters

len:int: Length between 1 and 64

_decodeUTF8_2	back to summary
private final int _decodeUTF8_2(int c, int d) throws IOException

_decodeUTF8_3	back to summary
private final int _decodeUTF8_3(int c, int d, int e) throws IOException

_decodeUTF8_4	back to summary
private final int _decodeUTF8_4(int c, int d, int e, int f) throws IOException

_decodeVInt	back to summary
private final int _decodeVInt() throws IOException

_finish7BitBinaryBody	back to summary
private final JsonToken _finish7BitBinaryBody() throws IOException

_finish7BitBinaryLen	back to summary
private final JsonToken _finish7BitBinaryLen(int value, int bytesRead) throws IOException

_finishBigDecimalBody	back to summary
private final JsonToken _finishBigDecimalBody() throws IOException

_finishBigDecimalLen	back to summary
private final JsonToken _finishBigDecimalLen(int value, int bytesRead) throws IOException

_finishBigDecimalScale	back to summary
private final JsonToken _finishBigDecimalScale(int value, int bytesRead) throws IOException

_finishBigIntBody	back to summary
private final JsonToken _finishBigIntBody() throws IOException

_finishBigIntLen	back to summary
private final JsonToken _finishBigIntLen(int value, int bytesRead) throws IOException

_finishDouble	back to summary
protected final JsonToken _finishDouble(long value, int bytesRead) throws IOException

_finishFloat	back to summary
protected final JsonToken _finishFloat(int value, int bytesRead) throws IOException

_finishHeader	back to summary
protected JsonToken _finishHeader(int state) throws IOException Helper method that will decode information from a header block that has been detected.

_finishInt	back to summary
private final JsonToken _finishInt(int value, int bytesRead) throws IOException

_finishLong	back to summary
private final JsonToken _finishLong(long value, int bytesRead) throws IOException

_finishLongASCII	back to summary
private final JsonToken _finishLongASCII() throws IOException

_finishLongFieldName	back to summary
private final JsonToken _finishLongFieldName(int outPtr) throws IOException

_finishLongUnicode	back to summary
private final JsonToken _finishLongUnicode() throws IOException

_finishPartialUnicodeChar	back to summary
private final boolean _finishPartialUnicodeChar() throws IOException

_finishRawBinaryBody	back to summary
private final JsonToken _finishRawBinaryBody() throws IOException

_finishRawBinaryLen	back to summary
private final JsonToken _finishRawBinaryLen(int value, int bytesRead) throws IOException

_finishToken	back to summary
protected final JsonToken _finishToken() throws IOException Method called when a (scalar) value type has been detected, but not all of contents have been decoded due to incomplete input available.

_fourBytesToInt	back to summary
private final int _fourBytesToInt(int ptr) throws IOException

_start7BitBinary	back to summary
private final JsonToken _start7BitBinary() throws IOException

_startBigDecimal	back to summary
private final JsonToken _startBigDecimal() throws IOException

_startBigInt	back to summary
private final JsonToken _startBigInt() throws IOException

_startDouble	back to summary
protected final JsonToken _startDouble() throws IOException

_startFieldName	back to summary
protected final JsonToken _startFieldName(int ch) throws IOException Method that handles initial token type recognition for token that has to be either FIELD_NAME or END_OBJECT.

_startFloat	back to summary
protected final JsonToken _startFloat() throws IOException

_startInt	back to summary
private final JsonToken _startInt() throws IOException

_startLong	back to summary
private final JsonToken _startLong() throws IOException

_startLongASCII	back to summary
private final JsonToken _startLongASCII() throws IOException

_startLongUnicode	back to summary
protected final JsonToken _startLongUnicode() throws IOException

_startRawBinary	back to summary
protected final JsonToken _startRawBinary() throws IOException

_startShortASCII	back to summary
private final JsonToken _startShortASCII(final int len) throws IOException

_startShortUnicode	back to summary
private final JsonToken _startShortUnicode(final int len) throws IOException

_startValue	back to summary
private final JsonToken _startValue(int ch) throws IOException Helper method called to detect type of a value token (at any level), and possibly decode it if contained in input buffer. Note that possible header has been ruled out by caller and is not checked here.

endOfInput back to summary

endOfInput	back to summary
public void endOfInput() Implements com.fasterxml.jackson.core.async.NonBlockingInputFeeder.endOfInput. Doc from com.fasterxml.jackson.core.async.NonBlockingInputFeeder.endOfInput. Method that should be called after last chunk of data to parse has been fed (with `feedInput` in sub-class); can be called regardless of what `needMoreInput` returns. After calling this method, no more data can be fed; and parser assumes no more data will be available. Annotations @Override

public void endOfInput()

Implements com.fasterxml.jackson.core.async.NonBlockingInputFeeder.endOfInput.

Doc from com.fasterxml.jackson.core.async.NonBlockingInputFeeder.endOfInput.

Method that should be called after last chunk of data to parse has been fed (with feedInput in sub-class); can be called regardless of what needMoreInput returns. After calling this method, no more data can be fed; and parser assumes no more data will be available.

Annotations

@Override

feedInput back to summary

public void feedInput(byte[] buf, int start, int end) throws IOException

Implements com.fasterxml.jackson.core.async.ByteArrayFeeder.feedInput.

Doc from com.fasterxml.jackson.core.async.ByteArrayFeeder.feedInput.

Method that can be called to feed more data, if (and only if) needMoreInput returns true.

Parameters

buf:byte[]: Byte array that contains data to feed: caller must ensure data remains stable until it is fully processed (which is true when needMoreInput returns true)
start:int: Offset within array where input data to process starts
end:int: Offset after last byte contained in the input array

Annotations

@Override

Exceptions

IOException:: if the state is such that this method should not be called (has not yet consumed existing input data, or has been marked as closed)

getNonBlockingInputFeeder back to summary

public ByteArrayFeeder getNonBlockingInputFeeder()

Overrides com.fasterxml.jackson.core.JsonParser.getNonBlockingInputFeeder.

Doc from com.fasterxml.jackson.core.JsonParser.getNonBlockingInputFeeder.

Method that will either return a feeder instance (if parser uses non-blocking, aka asynchronous access); or null for parsers that use blocking I/O.

Returns:ByteArrayFeeder

Input feeder to use with non-blocking (async) parsing

Annotations

@Override

needMoreInput back to summary

public final boolean needMoreInput()

Implements com.fasterxml.jackson.core.async.NonBlockingInputFeeder.needMoreInput.

Doc from com.fasterxml.jackson.core.async.NonBlockingInputFeeder.needMoreInput.

Method called to check whether it is ok to feed more data: parser returns true if it has no more content to parse (and it is ok to feed more); otherwise false (and no data should yet be fed).

Returns:boolean

True if more input is needed (and can be fed); false if there is still some input to decode

Annotations

@Override

nextToken back to summary

public JsonToken nextToken() throws IOException

Implements abstract com.fasterxml.jackson.core.base.ParserMinimalBase.nextToken.

Doc from com.fasterxml.jackson.core.JsonParser.nextToken.

Main iteration method, which will advance stream enough to determine type of the next token, if any. If none remaining (stream has no content other than possible white space before ending), null will be returned.

Returns:JsonToken

Next token from the stream, if any found, or null to indicate end-of-input

Annotations

@Override

Exceptions

IOException:: for low-level read issues, or JsonParseException for decoding problems

releaseBuffered back to summary

public int releaseBuffered(OutputStream out) throws IOException

Implements abstract com.fasterxml.jackson.dataformat.smile.async.NonBlockingParserBase.releaseBuffered.

Doc from com.fasterxml.jackson.core.JsonParser.releaseBuffered.

Method that can be called to push back any content that has been read but not consumed by the parser. This is usually done after reading all content of interest using parser. Content is released by writing it to given stream if possible; if underlying input is byte-based it can released, if not (char-based) it can not.

Parameters

out:OutputStream: OutputStream to which buffered, undecoded content is written to

Returns:int

-1 if the underlying content source is not byte based (that is, input can not be sent to OutputStream; otherwise number of bytes released (0 if there was nothing to release)

Annotations

@Override

Exceptions

IOException:: if write to stream threw exception

public Class NonBlockingByteArrayParser

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail