本文整理了Java中org.glassfish.grizzly.memory.Buffers.appendBuffers()
方法的一些代码示例,展示了Buffers.appendBuffers()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Buffers.appendBuffers()
方法的具体详情如下:
包路径:org.glassfish.grizzly.memory.Buffers
类名称:Buffers
方法名:appendBuffers
[英]Append two Buffers. If one of the Buffers is null - then another Buffer will be returned as result. If the first Buffer is CompositeBuffer then the second Buffer will be appended to it via CompositeBuffer#append(Buffer), else if the second Buffer is CompositeBuffer then the first Bufferwill be prepended to it via CompositeBuffer#prepend(org.glassfish.grizzly.Buffer). If none of the Buffer parameters is null nor CompositeBuffers - then new CompositeBuffer will be created and both Buffers will be added there. The resulting CompositeBuffer will be disallowed for disposal.
[中]附加两个缓冲区。如果其中一个缓冲区为空,则会返回另一个缓冲区作为结果。如果第一个缓冲区是CompositeBuffer,则第二个缓冲区将通过CompositeBuffer#append(Buffer)附加到它,否则如果第二个缓冲区是CompositeBuffer,则第一个缓冲区将通过CompositeBuffer#prepend(org.glassfish.grizzly.Buffer)预先添加到它。如果缓冲区参数均不为null或CompositeBuffer,则将创建新的CompositeBuffer,并在其中添加两个缓冲区。由此产生的复合缓冲液将不允许处置。
代码示例来源:origin: com.ning/async-http-client
public GrizzlyResponse(final HttpResponsePacket httpResponsePacket,
final HttpResponseStatus status,
final HttpResponseHeaders headers,
final List<HttpResponseBodyPart> bodyParts) {
super(status, headers, bodyParts);
this.httpResponsePacket = httpResponsePacket;
if (isNonEmpty(bodyParts)) {
if (bodyParts.size() == 1) {
responseBody = ((GrizzlyResponseBodyPart) bodyParts.get(0)).getBodyBuffer();
} else {
final Buffer firstBuffer = ((GrizzlyResponseBodyPart) bodyParts.get(0)).getBodyBuffer();
final MemoryManager mm = httpResponsePacket.getRequest().getConnection().getMemoryManager();
Buffer constructedBodyBuffer = firstBuffer;
for (int i = 1, len = bodyParts.size(); i < len; i++) {
constructedBodyBuffer =
Buffers.appendBuffers(mm,
constructedBodyBuffer,
((GrizzlyResponseBodyPart) bodyParts.get(i)).getBodyBuffer());
}
responseBody = constructedBodyBuffer;
}
} else {
responseBody = Buffers.EMPTY_BUFFER;
}
}
代码示例来源:origin: javaee/grizzly
Buffer appendToRemainder(final MemoryManager mm,
final Buffer buffer) {
final Buffer remainderBuffer = parsingResult.remainder;
parsingResult.remainder = null;
return Buffers.appendBuffers(mm, remainderBuffer, buffer, true);
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server-core
@Override
public Buffer append(final Buffer element1, final Buffer element2) {
return Buffers.appendBuffers(null, element1, element2,
isCompositeBufferDisposable);
}
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server
@Override
public Buffer append(final Buffer element1, final Buffer element2) {
return Buffers.appendBuffers(null, element1, element2,
isCompositeBufferDisposable);
}
}
代码示例来源:origin: javaee/grizzly
@Override
public Buffer append(final Buffer element1, final Buffer element2) {
return Buffers.appendBuffers(null, element1, element2,
isCompositeBufferDisposable);
}
}
代码示例来源:origin: javaee/grizzly
@Override
public Buffer append(final Buffer element1, final Buffer element2) {
return Buffers.appendBuffers(null, element1, element2,
isCompositeBufferDisposable);
}
}
代码示例来源:origin: javaee/grizzly
Buffer appendToRemainder(final MemoryManager mm,
final Buffer buffer) {
final Buffer remainderBuffer = parsingResult.remainder;
parsingResult.remainder = null;
return Buffers.appendBuffers(mm, remainderBuffer, buffer, true);
}
代码示例来源:origin: javaee/grizzly
Buffer appendToRemainder(final MemoryManager mm,
final Buffer buffer) {
final Buffer remainderBuffer = parsingResult.remainder;
parsingResult.remainder = null;
return Buffers.appendBuffers(mm, remainderBuffer, buffer, true);
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-core
@Override
public Buffer append(final Buffer element1, final Buffer element2) {
return Buffers.appendBuffers(null, element1, element2,
isCompositeBufferDisposable);
}
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server-core
Buffer appendToRemainder(final MemoryManager mm,
final Buffer buffer) {
final Buffer remainderBuffer = parsingResult.remainder;
parsingResult.remainder = null;
return Buffers.appendBuffers(mm, remainderBuffer, buffer, true);
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-http2
Buffer appendToRemainder(final MemoryManager mm,
final Buffer buffer) {
final Buffer remainderBuffer = parsingResult.remainder;
parsingResult.remainder = null;
return Buffers.appendBuffers(mm, remainderBuffer, buffer, true);
}
代码示例来源:origin: javaee/grizzly
void offerInputData(final Buffer data, final boolean isLast) {
final boolean isFirstBufferCached = (cachedInputBuffer == null);
cachedIsLast |= isLast;
cachedInputBuffer = Buffers.appendBuffers(
http2Session.getMemoryManager(),
cachedInputBuffer, data);
if (isFirstBufferCached) {
http2Session.streamsToFlushInput.add(this);
}
}
代码示例来源:origin: javaee/grizzly
void offerInputData(final Buffer data, final boolean isLast) {
final boolean isFirstBufferCached = (cachedInputBuffer == null);
cachedIsLast |= isLast;
cachedInputBuffer = Buffers.appendBuffers(
http2Session.getMemoryManager(),
cachedInputBuffer, data);
if (isFirstBufferCached) {
http2Session.streamsToFlushInput.add(this);
}
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server
public boolean append(final Buffer buffer) {
currentHeaderSize += buffer.remaining();
if (currentHeaderSize <= maxHeaderSize) {
inBuffer = Buffers.appendBuffers(memoryManager, inBuffer, buffer, true);
return true;
}
return false;
}
代码示例来源:origin: javaee/grizzly
public boolean append(final Buffer buffer) {
currentHeaderSize += buffer.remaining();
if (currentHeaderSize <= maxHeaderSize) {
inBuffer = Buffers.appendBuffers(memoryManager, inBuffer, buffer, true);
return true;
}
return false;
}
代码示例来源:origin: javaee/grizzly
void offerInputData(final Buffer data, final boolean isLast) {
final boolean isFirstBufferCached = (cachedInputBuffer == null);
cachedIsLast |= isLast;
cachedInputBuffer = Buffers.appendBuffers(
http2Session.getMemoryManager(),
cachedInputBuffer, data);
if (isFirstBufferCached) {
http2Session.streamsToFlushInput.add(this);
}
}
代码示例来源:origin: javaee/grizzly
void offerInputData(final Buffer data, final boolean isLast) {
final boolean isFirstBufferCached = (cachedInputBuffer == null);
cachedIsLast |= isLast;
cachedInputBuffer = Buffers.appendBuffers(
http2Session.getMemoryManager(),
cachedInputBuffer, data);
if (isFirstBufferCached) {
http2Session.streamsToFlushInput.add(this);
}
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server-core
public boolean append(final Buffer buffer) {
currentHeaderSize += buffer.remaining();
if (currentHeaderSize <= maxHeaderSize) {
inBuffer = Buffers.appendBuffers(memoryManager, inBuffer, buffer, true);
return true;
}
return false;
}
代码示例来源:origin: javaee/grizzly
void offerInputData(final Buffer data, final boolean isLast) {
final boolean isFirstBufferCached = (cachedInputBuffer == null);
cachedIsLast |= isLast;
cachedInputBuffer = Buffers.appendBuffers(
http2Session.getMemoryManager(),
cachedInputBuffer, data);
if (isFirstBufferCached) {
http2Session.streamsToFlushInput.add(this);
}
}
代码示例来源:origin: javaee/grizzly
void offerInputData(final Buffer data, final boolean isLast) {
final boolean isFirstBufferCached = (cachedInputBuffer == null);
cachedIsLast |= isLast;
cachedInputBuffer = Buffers.appendBuffers(
http2Session.getMemoryManager(),
cachedInputBuffer, data);
if (isFirstBufferCached) {
http2Session.streamsToFlushInput.add(this);
}
}
内容来源于网络,如有侵权,请联系作者删除!