javax.net.ssl.SSLEngine.getHandshakeStatus()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.3k)|赞(0)|评价(0)|浏览(206)

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

SSLEngine.getHandshakeStatus介绍

[英]Returns the status of the handshake of this engine instance.
[中]返回此引擎实例的握手状态。

代码示例

代码示例来源:origin: apache/kafka

  1. boolean complete() {
  2. return sslEngine.getHandshakeStatus() == SSLEngineResult.HandshakeStatus.FINISHED ||
  3. sslEngine.getHandshakeStatus() == SSLEngineResult.HandshakeStatus.NOT_HANDSHAKING;
  4. }

代码示例来源:origin: redisson/redisson

  1. @Override
  2. public HandshakeStatus getHandshakeStatus() {
  3. return engine.getHandshakeStatus();
  4. }

代码示例来源:origin: TooTallNate/Java-WebSocket

  1. private boolean isHandShakeComplete() {
  2. HandshakeStatus status = sslEngine.getHandshakeStatus();
  3. return status == SSLEngineResult.HandshakeStatus.FINISHED || status == SSLEngineResult.HandshakeStatus.NOT_HANDSHAKING;
  4. }

代码示例来源:origin: wildfly/wildfly

  1. @Override
  2. public SSLEngineResult.HandshakeStatus getHandshakeStatus() {
  3. return delegate.getHandshakeStatus();
  4. }

代码示例来源:origin: wildfly/wildfly

  1. @Override
  2. public SSLEngineResult.HandshakeStatus getHandshakeStatus() {
  3. return delegate.getHandshakeStatus();
  4. }

代码示例来源:origin: wildfly/wildfly

  1. @Override
  2. public HandshakeStatus getHandshakeStatus() {
  3. return engine.getHandshakeStatus();
  4. }

代码示例来源:origin: wildfly/wildfly

  1. public SSLEngineResult.HandshakeStatus getHandshakeStatus() {
  2. return delegate.getHandshakeStatus();
  3. }

代码示例来源:origin: org.mongodb/mongo-java-driver

  1. @Override
  2. public HandshakeStatus get() {
  3. return engine.getHandshakeStatus();
  4. }
  5. });

代码示例来源:origin: jersey/jersey

  1. /**
  2. * Returns a printed current state of the SslFilter that could be helpful for troubleshooting.
  3. */
  4. private String getDebugState() {
  5. return "SslFilter{"
  6. + "\napplicationInputBuffer=" + applicationInputBuffer
  7. + ",\nnetworkOutputBuffer=" + networkOutputBuffer
  8. + ",\nsslEngineStatus=" + sslEngine.getHandshakeStatus()
  9. + ",\nsslSession=" + sslEngine.getSession()
  10. + ",\nstate=" + state
  11. + ",\npendingApplicationWrite=" + pendingApplicationWrite
  12. + ",\npendingWritesSize=" + writeQueue
  13. + '}';
  14. }

代码示例来源:origin: wildfly/wildfly

  1. public SSLEngineResult.HandshakeStatus getHandshakeStatus() {
  2. return currentRef.get().getHandshakeStatus();
  3. }

代码示例来源:origin: wildfly/wildfly

  1. public SSLEngineResult.HandshakeStatus getHandshakeStatus() {
  2. return currentRef.get().getHandshakeStatus();
  3. }

代码示例来源:origin: wildfly/wildfly

  1. public SSLEngineResult.HandshakeStatus getHandshakeStatus() {
  2. return currentRef.get().getHandshakeStatus();
  3. }

代码示例来源:origin: igniterealtime/Openfire

  1. private SSLEngineResult.HandshakeStatus doTasks() {
  2. Runnable runnable;
  3. /*
  4. * We could run this in a separate thread, but do in the current for now.
  5. */
  6. while ((runnable = tlsEngine.getDelegatedTask()) != null) {
  7. runnable.run();
  8. }
  9. return tlsEngine.getHandshakeStatus();
  10. }

代码示例来源:origin: igniterealtime/Openfire

  1. private SSLEngineResult.HandshakeStatus doTasks() {
  2. Runnable runnable;
  3. /*
  4. * We could run this in a separate thread, but do in the current for now.
  5. */
  6. while ((runnable = tlsEngine.getDelegatedTask()) != null) {
  7. runnable.run();
  8. }
  9. return tlsEngine.getHandshakeStatus();
  10. }

代码示例来源:origin: apache/kafka

  1. /**
  2. * Executes the SSLEngine tasks needed.
  3. * @return HandshakeStatus
  4. */
  5. private HandshakeStatus runDelegatedTasks() {
  6. for (;;) {
  7. Runnable task = delegatedTask();
  8. if (task == null) {
  9. break;
  10. }
  11. task.run();
  12. }
  13. return sslEngine.getHandshakeStatus();
  14. }

代码示例来源:origin: TooTallNate/Java-WebSocket

  1. /**
  2. * performs the unwrap operation by unwrapping from {@link #inCrypt} to {@link #inData}
  3. **/
  4. private synchronized ByteBuffer unwrap() throws SSLException {
  5. int rem;
  6. //There are some ssl test suites, which get around the selector.select() call, which cause an infinite unwrap and 100% cpu usage (see #459 and #458)
  7. if(readEngineResult.getStatus() == SSLEngineResult.Status.CLOSED && sslEngine.getHandshakeStatus() == HandshakeStatus.NOT_HANDSHAKING){
  8. try {
  9. close();
  10. } catch (IOException e) {
  11. //Not really interesting
  12. }
  13. }
  14. do {
  15. rem = inData.remaining();
  16. readEngineResult = sslEngine.unwrap( inCrypt, inData );
  17. } while ( readEngineResult.getStatus() == SSLEngineResult.Status.OK && ( rem != inData.remaining() || sslEngine.getHandshakeStatus() == HandshakeStatus.NEED_UNWRAP ) );
  18. inData.flip();
  19. return inData;
  20. }

代码示例来源:origin: apache/kafka

  1. protected void startHandshake() throws IOException {
  2. if (state != State.NOT_INITALIZED)
  3. throw new IllegalStateException("startHandshake() can only be called once, state " + state);
  4. this.netReadBuffer = ByteBuffer.allocate(netReadBufferSize());
  5. this.netWriteBuffer = ByteBuffer.allocate(netWriteBufferSize());
  6. this.appReadBuffer = ByteBuffer.allocate(applicationBufferSize());
  7. //clear & set netRead & netWrite buffers
  8. netWriteBuffer.position(0);
  9. netWriteBuffer.limit(0);
  10. netReadBuffer.position(0);
  11. netReadBuffer.limit(0);
  12. state = State.HANDSHAKE;
  13. //initiate handshake
  14. sslEngine.beginHandshake();
  15. handshakeStatus = sslEngine.getHandshakeStatus();
  16. }

代码示例来源:origin: rapidoid/rapidoid

  1. private SSLEngineResult.HandshakeStatus executeTasks() {
  2. Runnable runnable;
  3. while ((runnable = engine.getDelegatedTask()) != null) {
  4. runnable.run();
  5. }
  6. SSLEngineResult.HandshakeStatus hsStatus = engine.getHandshakeStatus();
  7. U.must(hsStatus != SSLEngineResult.HandshakeStatus.NEED_TASK, "handshake shouldn't need additional tasks!");
  8. debug("after tasks: " + hsStatus);
  9. return hsStatus;
  10. }

代码示例来源:origin: TooTallNate/Java-WebSocket

  1. public SSLSocketChannel2( SocketChannel channel , SSLEngine sslEngine , ExecutorService exec , SelectionKey key ) throws IOException {
  2. if( channel == null || sslEngine == null || exec == null )
  3. throw new IllegalArgumentException( "parameter must not be null" );
  4. this.socketChannel = channel;
  5. this.sslEngine = sslEngine;
  6. this.exec = exec;
  7. readEngineResult = writeEngineResult = new SSLEngineResult( Status.BUFFER_UNDERFLOW, sslEngine.getHandshakeStatus(), 0, 0 ); // init to prevent NPEs
  8. tasks = new ArrayList<Future<?>>( 3 );
  9. if( key != null ) {
  10. key.interestOps( key.interestOps() | SelectionKey.OP_WRITE );
  11. this.selectionKey = key;
  12. }
  13. createBuffers( sslEngine.getSession() );
  14. // kick off handshake
  15. socketChannel.write( wrap( emptybuffer ) );// initializes res
  16. processHandshake();
  17. }

代码示例来源:origin: apache/ignite

  1. /**
  2. * Runs all tasks needed to continue SSL work.
  3. *
  4. * @return Handshake status after running all tasks.
  5. */
  6. private HandshakeStatus runTasks() {
  7. Runnable runnable;
  8. while ((runnable = sslEngine.getDelegatedTask()) != null) {
  9. if (log.isDebugEnabled())
  10. log.debug("Running SSL engine task: " + runnable + '.');
  11. runnable.run();
  12. }
  13. if (log.isDebugEnabled())
  14. log.debug("Finished running SSL engine tasks. HandshakeStatus: " + sslEngine.getHandshakeStatus());
  15. return sslEngine.getHandshakeStatus();
  16. }

相关文章