gpt4 book ai didi

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

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

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

WorkerThread.getOutputBB介绍

[英]Return the encrypted ByteBuffer used to handle response.
[中]返回用于处理响应的加密ByteBuffer。

代码示例

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

public ByteBuffer getSecuredOutputByteBuffer() {
  return workerThread().getOutputBB();
}

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

public ByteBuffer getSecuredOutputByteBuffer() {
  return workerThread().getOutputBB();
}

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

/**
 * Encrypt the response and flush it using {@link OutputWriter}
 * @param channel  {@link SelectableChannel} to flush
 * @param bb  {@link ByteBuffer}
 * @return  number of bytes written
 * @throws java.io.IOException 
 */     
public static long flushChannel(SelectableChannel channel, ByteBuffer bb)
    throws IOException{
 
  WorkerThread workerThread = (WorkerThread)Thread.currentThread();
  SSLEngine sslEngine = workerThread.getSSLEngine();
  ByteBuffer outputBB = workerThread.getOutputBB();
  return flushChannel(channel,bb,outputBB,sslEngine);
}

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

/**
 * Encrypt the response and flush it using {@link OutputWriter}
 * @param channel  {@link SelectableChannel} to flush
 * @param bb  {@link ByteBuffer}
 * @return  number of bytes written
 * @throws java.io.IOException 
 */     
public static long flushChannel(SelectableChannel channel, ByteBuffer bb)
    throws IOException{
 
  WorkerThread workerThread = (WorkerThread)Thread.currentThread();
  SSLEngine sslEngine = workerThread.getSSLEngine();
  ByteBuffer outputBB = workerThread.getOutputBB();
  return flushChannel(channel,bb,outputBB,sslEngine);
}

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

/**
 * Encrypt the response and flush it using {@link OutputWriter}
 * @param channel  {@link SelectableChannel} to flush
 * @param bb  {@link ByteBuffer}
 * @return  number of bytes written
 * @throws java.io.IOException 
 */     
public static long flushChannel(SelectableChannel channel, ByteBuffer bb)
    throws IOException{
 
  WorkerThread workerThread = (WorkerThread)Thread.currentThread();
  SSLEngine sslEngine = workerThread.getSSLEngine();
  ByteBuffer outputBB = workerThread.getOutputBB();
  return flushChannel(channel,bb,outputBB,sslEngine);
}

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

(WorkerThread)Thread.currentThread();
ByteBuffer byteBuffer = workerThread.getByteBuffer();
ByteBuffer outputBB = workerThread.getOutputBB();
ByteBuffer inputBB = workerThread.getInputBB();

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

(WorkerThread)Thread.currentThread();
ByteBuffer byteBuffer = workerThread.getByteBuffer();
ByteBuffer outputBB = workerThread.getOutputBB();
ByteBuffer inputBB = workerThread.getInputBB();

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

(WorkerThread)Thread.currentThread();
ByteBuffer byteBuffer = workerThread.getByteBuffer();
ByteBuffer outputBB = workerThread.getOutputBB();
ByteBuffer inputBB = workerThread.getInputBB();

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

securedBB = ((WorkerThread) currentThread).getOutputBB();

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

private static void swapEncryptOutBuffer(final WorkerThread workerThread,
                     final SSLAsyncOutputBuffer outputBuffer,
                     final SSLEngine engine) {
  ByteBuffer tmp = allocate(engine);
  outputBuffer.setOutputBB(workerThread.getOutputBB());
  workerThread.setOutputBB(tmp);
  outputBuffer.setSSLEngine(engine);
}

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

(SSLWritePreProcessor) attributes.getAttribute(SSL_WRITE_PREPROCESSOR);
if (preProcessor == null) {
  preProcessor = new SSLWritePreProcessor(sslEngine, workerThread.getOutputBB());
  workerThread.setOutputBB(null);
  attributes.setAttribute(SSL_WRITE_PREPROCESSOR, preProcessor);

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

/**
 * Get the peer certificate list by initiating a new handshake.
 * @param key {@link SelectionKey}
 * @param needClientAuth 
 * @return Object[] An array of X509Certificate.
 * @throws java.io.IOException 
 */
public static Object[] doPeerCertificateChain(SelectionKey key,
    boolean needClientAuth) throws IOException {
  
  final WorkerThread workerThread = 
      (WorkerThread)Thread.currentThread();
  ByteBuffer byteBuffer = workerThread.getByteBuffer();
  ByteBuffer inputBB = workerThread.getInputBB();
  ByteBuffer outputBB = workerThread.getOutputBB();
  SSLEngine sslEngine = workerThread.getSSLEngine();
  
  return SSLUtils.doPeerCertificateChain((SocketChannel) key.channel(), 
      byteBuffer, inputBB, outputBB, sslEngine, needClientAuth, 
      InputReader.getDefaultReadTimeout());
}

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

(WorkerThread)Thread.currentThread();
ByteBuffer byteBuffer = workerThread.getByteBuffer();
ByteBuffer outputBB = workerThread.getOutputBB();
ByteBuffer inputBB = workerThread.getInputBB();
SSLEngine sslEngine = workerThread.getSSLEngine();

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

(WorkerThread) Thread.currentThread();
ByteBuffer byteBuffer = workerThread.getByteBuffer();
ByteBuffer outputBB = workerThread.getOutputBB();
ByteBuffer inputBB = workerThread.getInputBB();
SSLEngine sslEngine = workerThread.getSSLEngine();

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

sslEngine,
thread.getByteBuffer(),
thread.getOutputBB(),
redirectPort,
redirectToSecure);

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

private void saveSecuredBufferRemainders(SelectionKey selectionKey) {
  ThreadAttachment attachment = 
      (ThreadAttachment) selectionKey.attachment();
  
  WorkerThread workerThread = (WorkerThread) Thread.currentThread();   
  if (attachment == null || workerThread.getAttachment() != attachment) {
    Controller.logger().log(Level.FINE, 
        "SelectionKey ThreadAttachment is NULL or doesn't " +
        "correspond to the current thread, when saving buffers");
    return;
  }
  
  ByteBuffer inputBB = workerThread.getInputBB();
  if (inputBB != null && inputBB.hasRemaining()) {
    workerThread.updateAttachment(attachment.getMode() | Mode.INPUT_BB);
  } else {
    workerThread.updateAttachment(attachment.getMode() & 
        (Integer.MAX_VALUE ^ Mode.INPUT_BB));
  }
  ByteBuffer outputBB = workerThread.getOutputBB();
  if (outputBB != null && outputBB.hasRemaining()) {
    workerThread.updateAttachment(attachment.getMode() | Mode.OUTPUT_BB);
  } else {
    workerThread.updateAttachment(attachment.getMode() & 
        (Integer.MAX_VALUE ^ Mode.OUTPUT_BB));
  }
}

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

hasHandshake = true;
  ByteBuffer outputBB = workerThread.getOutputBB();
  outputBB.limit(outputBB.position());
} else {

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