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

WorkerThread.getInputBB介绍

[英]Return the encrypted ByteBuffer used to handle request.
[中]返回用于处理请求的加密ByteBuffer。

代码示例

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

@Override
  public ByteBuffer getByteBuffer() {
    return ((WorkerThread) Thread.currentThread()).getInputBB();
  }
}

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

@Override
  public ByteBuffer getByteBuffer() {
    return ((WorkerThread) Thread.currentThread()).getInputBB();
  }
}

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

public ByteBuffer getByteBuffer() {
    final WorkerThread workerThread = (WorkerThread) Thread.currentThread();
    if (workerThread.getSSLEngine() != null) {
      return workerThread.getInputBB();
    }
    return null;
  }
});

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

public ByteBuffer getSecuredInputByteBuffer() {
  return workerThread().getInputBB();
}

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

public ByteBuffer getSecuredInputByteBuffer() {
  return workerThread().getInputBB();
}

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

/**
 * Read and decrypt bytes from the underlying SSL connections. All
 * the SSLEngine operations are delegated to class {@link SSLUtils}.
 * @return  number of bytes read
 * @throws java.io.IOException 
 */    
protected  int doSecureRead() throws IOException{ 
  final WorkerThread workerThread = 
      (WorkerThread)Thread.currentThread();
  int bytesRead = SSLUtils.doSecureRead((SocketChannel) key.channel(), 
      workerThread.getSSLEngine(), byteBuffer, 
      workerThread.getInputBB());
  byteBuffer.flip();
  
  return bytesRead;
}

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

/**
 * Read and decrypt bytes from the underlying SSL connections. All
 * the SSLEngine operations are delegated to class {@link SSLUtils}.
 * @return  number of bytes read
 * @throws java.io.IOException 
 */    
protected  int doSecureRead() throws IOException{ 
  final WorkerThread workerThread = 
      (WorkerThread)Thread.currentThread();
  int bytesRead = SSLUtils.doSecureRead((SocketChannel) key.channel(), 
      workerThread.getSSLEngine(), byteBuffer, 
      workerThread.getInputBB());
  byteBuffer.flip();
  
  return bytesRead;
}

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

/**
   * Returns <code>ByteBuffer</code>, where PUReadFilter will read data
   *
   * @return <code>ByteBuffer</code>
   */
  @Override
  public ByteBuffer getByteBuffer() {
    final WorkerThread workerThread = (WorkerThread) Thread.currentThread();
    final SSLEngine sslEngine = workerThread.getSSLEngine();
    if (sslEngine != null) {
      ByteBuffer secureInputBuffer = workerThread.getInputBB();
      if (secureInputBuffer == null) {
        final int securedBBSize = sslEngine.getSession().getPacketBufferSize();
        secureInputBuffer = ByteBuffer.allocate(securedBBSize * 2);
        workerThread.setInputBB(secureInputBuffer);
      }
      
      return secureInputBuffer;
    }
    return null;
  }
}

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

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

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

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

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

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

代码示例来源：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: com.sun.grizzly/grizzly-config

final ByteBuffer securedBuffer = thread.getInputBB();
if (securedBuffer.position() > 0) {
  final int initialPosition = byteBuffer.position();

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

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

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

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

代码示例来源：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));
  }
}