in http2/src/main/java/org/apache/mina/http2/impl/Http2DataFrameDecoder.java [66:101]
public boolean consume(ByteBuffer buffer) {
while ((getValue() == null) && buffer.remaining() > 0) {
switch (state) {
case PAD_LENGTH:
padLength = buffer.get();
if ((getHeader().getLength() - 1 - padLength) > 0) {
state = State.DATA;
decoder = new BytePartialDecoder(getHeader().getLength() - 1 - padLength);
} else if (padLength > 0) {
state = State.PADDING;
decoder = new BytePartialDecoder(padLength);
} else {
setValue(builder.build());
}
break;
case DATA:
if (decoder.consume(buffer)) {
builder.data(((BytePartialDecoder)decoder).getValue());
if (isFlagSet(FLAGS_PADDING) && (padLength > 0)) {
state = State.PADDING;
decoder = new BytePartialDecoder(padLength);
} else {
setValue(builder.build());
}
}
break;
case PADDING:
if (decoder.consume(buffer)) {
builder.padding(((BytePartialDecoder)decoder).getValue());
setValue(builder.build());
}
break;
}
}
return getValue() != null;
}