本文整理了Java中org.littleshoot.mina.common.ByteBuffer.mark()
方法的一些代码示例,展示了ByteBuffer.mark()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ByteBuffer.mark()
方法的具体详情如下:
包路径:org.littleshoot.mina.common.ByteBuffer
类名称:ByteBuffer
方法名:mark
暂无
代码示例来源:origin: org.littleshoot/mina-port
@Override
public synchronized void mark(int readlimit) {
ByteBuffer.this.mark();
}
代码示例来源:origin: org.littleshoot/mina-port
public ByteBuffer mark() {
buf.mark();
return this;
}
代码示例来源:origin: org.littleshoot/tcp-framing
public DecodingState decode(final ByteBuffer in,
final ProtocolDecoderOutput out) throws Exception
{
in.mark();
final int firstByte = in.getUnsigned();
// Reset the buffer position.
in.reset();
final int masked = firstByte & 0xc0;
if (masked > 0)
{
return this.m_stateFactory.newState();
}
else
{
return null;
}
}
}
代码示例来源:origin: org.littleshoot/mina-port
@Override
protected void doWrite(IoSession session, WriteRequest writeRequest) {
SocketSessionImpl s = (SocketSessionImpl) session;
Queue<WriteRequest> writeRequestQueue = s.getWriteRequestQueue();
// SocketIoProcessor.doFlush() will reset it after write is finished
// because the buffer will be passed with messageSent event.
ByteBuffer buffer = (ByteBuffer) writeRequest.getMessage();
buffer.mark();
int remaining = buffer.remaining();
if (remaining == 0) {
s.increaseScheduledWriteRequests();
} else {
s.increaseScheduledWriteBytes(buffer.remaining());
}
writeRequestQueue.add(writeRequest);
if (session.getTrafficMask().isWritable()) {
s.getIoProcessor().flush(s);
}
}
代码示例来源:origin: org.littleshoot/mina-port
@Override
protected void doWrite(IoSession session, WriteRequest writeRequest) {
DatagramSessionImpl s = (DatagramSessionImpl) session;
Queue<WriteRequest> writeRequestQueue = s.getWriteRequestQueue();
// SocketIoProcessor.doFlush() will reset it after write is finished
// because the buffer will be passed with messageSent event.
ByteBuffer buffer = (ByteBuffer) writeRequest.getMessage();
buffer.mark();
int remaining = buffer.remaining();
if (remaining == 0) {
s.increaseScheduledWriteRequests();
} else {
s.increaseScheduledWriteBytes(buffer.remaining());
}
writeRequestQueue.add(writeRequest);
if (session.getTrafficMask().isWritable()) {
s.getManagerDelegate().flushSession(s);
}
}
代码示例来源:origin: org.littleshoot/mina-port
if (message instanceof ByteBuffer) {
ByteBuffer rb = (ByteBuffer) message;
rb.mark();
byteCount = rb.remaining();
ByteBuffer wb = ByteBuffer.allocate(rb.remaining());
内容来源于网络,如有侵权,请联系作者删除!