org.glassfish.grizzly.memory.Buffers.appendBuffers()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(91)

本文整理了Java中org.glassfish.grizzly.memory.Buffers.appendBuffers()方法的一些代码示例,展示了Buffers.appendBuffers()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Buffers.appendBuffers()方法的具体详情如下:
包路径:org.glassfish.grizzly.memory.Buffers
类名称:Buffers
方法名:appendBuffers

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);
  }
}

相关文章