本文整理了Java中com.couchbase.client.deps.io.netty.buffer.ByteBuf.readInt()
方法的一些代码示例,展示了ByteBuf.readInt()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ByteBuf.readInt()
方法的具体详情如下:
包路径:com.couchbase.client.deps.io.netty.buffer.ByteBuf
类名称:ByteBuf
方法名:readInt
[英]Gets a 32-bit integer at the current readerIndexand increases the readerIndex by 4 in this buffer.
[中]获取当前readerIndex处的32位整数,并在此缓冲区中将readerIndex增加4。
代码示例来源:origin: com.couchbase.client/core-io
@Override
public int readInt() {
return buf.readInt();
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public int readInt() {
return buf.readInt();
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public int readInt() {
checkReadableBytes(4);
return buffer.readInt();
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public int readInt() throws IOException {
checkAvailable(4);
return buffer.readInt();
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public int readInt() {
return ByteBufUtil.swapInt(buf.readInt());
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public int readInt() {
checkReadableBytes(4);
return buffer.readInt();
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public int readInt() throws IOException {
checkAvailable(4);
return buffer.readInt();
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public int readInt() {
return ByteBufUtil.swapInt(buf.readInt());
}
代码示例来源:origin: com.couchbase.client/core-io
int valueLength = body.readInt();
ByteBuf value = ctx.alloc().buffer(valueLength, valueLength);
value.writeBytes(body, valueLength);
代码示例来源:origin: com.couchbase.client/core-io
@Override
protected BinaryMemcacheRequest decodeHeader(ByteBuf in) {
BinaryMemcacheRequest header = new DefaultBinaryMemcacheRequest();
header.setMagic(in.readByte());
header.setOpcode(in.readByte());
header.setKeyLength(in.readShort());
header.setExtrasLength(in.readByte());
header.setDataType(in.readByte());
header.setReserved(in.readShort());
header.setTotalBodyLength(in.readInt());
header.setOpaque(in.readInt());
header.setCAS(in.readLong());
return header;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
protected BinaryMemcacheRequest decodeHeader(ByteBuf in) {
BinaryMemcacheRequest header = new DefaultBinaryMemcacheRequest();
header.setMagic(in.readByte());
header.setOpcode(in.readByte());
header.setKeyLength(in.readShort());
header.setExtrasLength(in.readByte());
header.setDataType(in.readByte());
header.setReserved(in.readShort());
header.setTotalBodyLength(in.readInt());
header.setOpaque(in.readInt());
header.setCAS(in.readLong());
return header;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
int valueLength = body.readInt();
ByteBuf value = ctx.alloc().buffer(valueLength, valueLength);
value.writeBytes(body, valueLength);
代码示例来源:origin: com.couchbase.client/core-io
final ByteBuf byteBuf = header.readSlice(length);
final byte client = byteBuf.readByte();
final int verify = byteBuf.readInt();
代码示例来源:origin: couchbase/couchbase-jvm-core
final ByteBuf byteBuf = header.readSlice(length);
final byte client = byteBuf.readByte();
final int verify = byteBuf.readInt();
代码示例来源:origin: com.couchbase.client/core-io
@Override
protected BinaryMemcacheResponse decodeHeader(ByteBuf in) {
BinaryMemcacheResponse header = new DefaultBinaryMemcacheResponse();
header.setMagic(in.readByte());
header.setOpcode(in.readByte());
if (header.getMagic() == FRAMING_MAGIC) {
header.setFramingExtrasLength(in.readByte());
header.setKeyLength(in.readByte());
} else {
header.setKeyLength(in.readShort());
}
header.setExtrasLength(in.readByte());
header.setDataType(in.readByte());
header.setStatus(in.readShort());
header.setTotalBodyLength(in.readInt());
header.setOpaque(in.readInt());
header.setCAS(in.readLong());
return header;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
protected BinaryMemcacheResponse decodeHeader(ByteBuf in) {
BinaryMemcacheResponse header = new DefaultBinaryMemcacheResponse();
header.setMagic(in.readByte());
header.setOpcode(in.readByte());
if (header.getMagic() == FRAMING_MAGIC) {
header.setFramingExtrasLength(in.readByte());
header.setKeyLength(in.readByte());
} else {
header.setKeyLength(in.readShort());
}
header.setExtrasLength(in.readByte());
header.setDataType(in.readByte());
header.setStatus(in.readShort());
header.setTotalBodyLength(in.readInt());
header.setOpaque(in.readInt());
header.setCAS(in.readLong());
return header;
}
代码示例来源:origin: com.couchbase.client/core-io
int offset = ByteBufUtil.swapInt(in.readInt());
代码示例来源:origin: couchbase/couchbase-jvm-core
int offset = ByteBufUtil.swapInt(in.readInt());
代码示例来源:origin: couchbase/java-dcp-client
int offset = ByteBufUtil.swapInt(in.readInt());
代码示例来源:origin: com.couchbase.client/core-io
return NOT_ENOUGH_INPUT;
length = ByteBufUtil.swapInt(in.readInt());
break;
default:
内容来源于网络,如有侵权,请联系作者删除!