Loading src/main/message_stream.cc +22 −20 Original line number Diff line number Diff line Loading @@ -111,7 +111,8 @@ MessageStreamFactory::MessageStreamFactory(SSL_CTX *ssl_context, bool MessageStreamFactory::NewMessageStream(int fd, bool use_ssl, SSL *ssl, uint32_t max_message_size_bytes, MessageStreamInterface **message_stream) { if ( (ssl == NULL) && use_ssl) { if ( use_ssl) { if(ssl == NULL) { SSL *ssl = SSL_new(ssl_context_); // We want to automatically retry reads and writes when a renegotiation // takes place. This way the only errors we have to handle are real, Loading @@ -132,6 +133,7 @@ bool MessageStreamFactory::NewMessageStream(int fd, bool use_ssl, SSL *ssl, uint SSL_free(ssl); return false; } } LOG(INFO) << "Successfully performed SSL handshake"; *message_stream = new MessageStream(max_message_size_bytes, new SslByteStream(ssl)); } else { Loading Loading
src/main/message_stream.cc +22 −20 Original line number Diff line number Diff line Loading @@ -111,7 +111,8 @@ MessageStreamFactory::MessageStreamFactory(SSL_CTX *ssl_context, bool MessageStreamFactory::NewMessageStream(int fd, bool use_ssl, SSL *ssl, uint32_t max_message_size_bytes, MessageStreamInterface **message_stream) { if ( (ssl == NULL) && use_ssl) { if ( use_ssl) { if(ssl == NULL) { SSL *ssl = SSL_new(ssl_context_); // We want to automatically retry reads and writes when a renegotiation // takes place. This way the only errors we have to handle are real, Loading @@ -132,6 +133,7 @@ bool MessageStreamFactory::NewMessageStream(int fd, bool use_ssl, SSL *ssl, uint SSL_free(ssl); return false; } } LOG(INFO) << "Successfully performed SSL handshake"; *message_stream = new MessageStream(max_message_size_bytes, new SslByteStream(ssl)); } else { Loading