|
82 | 82 | static const int rd_kafka_max_block_ms = 1000; |
83 | 83 |
|
84 | 84 | const char *rd_kafka_broker_state_names[] = { |
85 | | - "INIT", "DOWN", "TRY_CONNECT", "CONNECT", "SSL_HANDSHAKE", |
86 | | - "AUTH_LEGACY", "UP", "UPDATE", "APIVERSION_QUERY", "AUTH_HANDSHAKE", |
87 | | - "AUTH_REQ", "REAUTH"}; |
| 85 | + "INIT", "DOWN", "TRY_CONNECT", "CONNECT", |
| 86 | + "SSL_HANDSHAKE", "AUTH_LEGACY", "UP", "APIVERSION_QUERY", |
| 87 | + "AUTH_HANDSHAKE", "AUTH_REQ", "REAUTH"}; |
88 | 88 |
|
89 | 89 | const char *rd_kafka_secproto_names[] = { |
90 | 90 | [RD_KAFKA_PROTO_PLAINTEXT] = "plaintext", |
@@ -4711,10 +4711,11 @@ static int rd_kafka_broker_thread_main(void *arg) { |
4711 | 4711 | ; |
4712 | 4712 |
|
4713 | 4713 | #if WITH_SSL |
4714 | | - /* Remove OpenSSL per-thread error state to avoid memory leaks */ |
| 4714 | + /* Remove OpenSSL per-thread error state to avoid memory leaks |
| 4715 | + */ |
4715 | 4716 | #if OPENSSL_VERSION_NUMBER >= 0x10100000L && !defined(LIBRESSL_VERSION_NUMBER) |
4716 | | - /*(OpenSSL libraries handle thread init and deinit) |
4717 | | - * https://github.com/openssl/openssl/pull/1048 */ |
| 4717 | + /*(OpenSSL libraries handle thread init and deinit) |
| 4718 | + * https://github.com/openssl/openssl/pull/1048 */ |
4718 | 4719 | #elif OPENSSL_VERSION_NUMBER >= 0x10000000L |
4719 | 4720 | ERR_remove_thread_state(NULL); |
4720 | 4721 | #endif |
|
0 commit comments