gpt4 book ai didi

com.sun.grizzly.util.WorkerThread.setByteBuffer()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-26 22:57:05 26 4
gpt4 key购买 nike

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

WorkerThread.setByteBuffer介绍

[英]Set the ByteBuffer shared this thread
[中]设置字节缓冲共享此线程

代码示例

代码示例来源:origin: org.glassfish.external/grizzly-module

public void setByteBuffer(ByteBuffer byteBuffer) {
  workerThread().setByteBuffer(byteBuffer);
}

代码示例来源:origin: com.sun.grizzly/grizzly-portunif

public void setByteBuffer(ByteBuffer byteBuffer) {
  workerThread().setByteBuffer(byteBuffer);
}

代码示例来源:origin: org.shoal/shoal-gms-impl

((WorkerThread) Thread.currentThread()).setByteBuffer(null);
} else {
  if (workerBufferRemaining < lastBufferRemaining) {

代码示例来源:origin: com.sun.grizzly/grizzly-utils

workerThread.setByteBuffer(byteBuffer);

代码示例来源:origin: org.glassfish.external/grizzly-module

workerThread.setByteBuffer(byteBuffer);

代码示例来源:origin: com.sun.grizzly/grizzly-http

/**
 * Execute the request. When RCM is enabled, swicth the {@link ByteBuffer}
 * based on the decision made by a {@link ResourceAllocationFilter}
 * @param ctx
 * @throws java.lang.Exception
 */
@Override
public void execute(Context ctx) throws Exception {
  if (rcmSupport) {
    ByteBuffer byteBuffer =
        (ByteBuffer) ctx.getAttribute(ResourceAllocationFilter.BYTE_BUFFER);
    // Switch ByteBuffer
    if (byteBuffer != null) {
      ((WorkerThread) Thread.currentThread()).setByteBuffer(byteBuffer);
    }
    if (!protocolFilters.isEmpty()) {
      int currentPosition = super.executeProtocolFilter(ctx);
      super.postExecuteProtocolFilter(currentPosition, ctx);
    }
  } else {
    super.execute(ctx);
  }
}

代码示例来源:origin: com.sun.grizzly/grizzly-http-utils

workerThread.setByteBuffer(byteBuffer);

代码示例来源:origin: org.glassfish.external/grizzly-module

/**
 * Execute the request. When RCM is enabled, swicth the {@link ByteBuffer}
 * based on the decision made by a {@link ResourceAllocationFilter}
 * @param ctx
 * @throws java.lang.Exception
 */
@Override
public void execute(Context ctx) throws Exception {
  if (rcmSupport) {
    ByteBuffer byteBuffer =
        (ByteBuffer) ctx.getAttribute(ResourceAllocationFilter.BYTE_BUFFER);
    // Switch ByteBuffer
    if (byteBuffer != null) {
      ((WorkerThread) Thread.currentThread()).setByteBuffer(byteBuffer);
    }
    if (protocolFilters.size() != 0) {
      int currentPosition = super.executeProtocolFilter(ctx);
      super.postExecuteProtocolFilter(currentPosition, ctx);
    }
  } else {
    super.execute(ctx);
  }
}

代码示例来源:origin: com.sun.grizzly/grizzly-config

byteBuffer = SSLUtils.unwrapAll(byteBuffer, inputBB, sslEngine);
protocolRequest.setByteBuffer(byteBuffer);
workerThread.setByteBuffer(byteBuffer);
workerThread.setByteBuffer(byteBuffer);

代码示例来源:origin: org.glassfish.external/grizzly-module

workerThread.setInputBB(inputBB);
workerThread.setOutputBB(outputBB);
workerThread.setByteBuffer(byteBuffer);

代码示例来源:origin: org.glassfish.external/grizzly-module

workerThread.setByteBuffer(nBuf);
} else {
  workerThread.setByteBuffer(ByteBufferFactory.allocateView(false));

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com