line |
true |
false |
branch |
90
|
0 |
18 |
if (-1 == self->sockfd) { |
96
|
0 |
18 |
if (len > INT_MAX) { |
106
|
0 |
18 |
if (0 >= res) { |
135
|
0 |
30 |
if (-1 == self->sockfd) { |
141
|
0 |
30 |
if (len > INT_MAX) { |
149
|
15 |
15 |
if (0 >= received) { |
178
|
0 |
1 |
if (-1 != self->sockfd) { |
184
|
0 |
1 |
if (!self->ssl) { |
191
|
0 |
1 |
if (AMQP_STATUS_OK != status) { |
196
|
0 |
1 |
if (0 > self->sockfd) { |
204
|
0 |
1 |
if (!bio) { |
213
|
0 |
1 |
if (!status) { |
221
|
2 |
1 |
if (status != 1) { |
233
|
2 |
0 |
if (AMQP_STATUS_OK == status) { |
241
|
1 |
0 |
if (self->verify_peer) { |
242
|
0 |
1 |
if (!cert) { |
249
|
0 |
1 |
if (X509_V_OK != result) { |
255
|
1 |
0 |
if (self->verify_hostname) { |
256
|
0 |
1 |
if (!cert) { |
262
|
0 |
1 |
if (AMQP_HVR_MATCH_FOUND != amqp_ssl_validate_hostname(host, cert)) { |
292
|
0 |
1 |
if (-1 == self->sockfd) { |
296
|
1 |
0 |
if (AMQP_SC_NONE == force) { |
304
|
0 |
1 |
if (amqp_os_socket_close(self->sockfd)) { |
320
|
1 |
0 |
if (self) { |
341
|
0 |
1 |
if (!self) { |
351
|
0 |
1 |
if (status) { |
356
|
0 |
1 |
if (!self->ctx) { |
376
|
0 |
0 |
if (base->klass != &amqp_ssl_socket_class) { |
385
|
0 |
1 |
if (base->klass != &amqp_ssl_socket_class) { |
390
|
0 |
1 |
if (1 != status) { |
400
|
0 |
0 |
if (base->klass != &amqp_ssl_socket_class) { |
405
|
0 |
0 |
if (1 != status) { |
409
|
0 |
0 |
if (1 != status) { |
426
|
0 |
0 |
if (base->klass != &amqp_ssl_socket_class) { |
429
|
0 |
0 |
if (n > INT_MAX) { |
434
|
0 |
0 |
if (1 != status) { |
438
|
0 |
0 |
if (!buf) { |
442
|
0 |
0 |
if (!rsa) { |
446
|
0 |
0 |
if (1 != status) { |
461
|
0 |
0 |
if (base->klass != &amqp_ssl_socket_class) { |
466
|
0 |
0 |
if (1 != status) { |
480
|
0 |
0 |
if (base->klass != &amqp_ssl_socket_class) { |
490
|
0 |
1 |
if (base->klass != &amqp_ssl_socket_class) { |
501
|
0 |
0 |
if (base->klass != &amqp_ssl_socket_class) { |
522
|
0 |
0 |
if (AMQP_TLSvLATEST == max) { |
525
|
0 |
0 |
if (AMQP_TLSvLATEST == min) { |
529
|
0 |
0 |
if (min > max) { |
533
|
0 |
0 |
if (max > max_supported || min > max_supported) { |
|
0 |
0 |
if (max > max_supported || min > max_supported) { |
537
|
0 |
0 |
if (min > AMQP_TLSv1) { |
541
|
0 |
0 |
if (min > AMQP_TLSv1_1 || max < AMQP_TLSv1_1) { |
|
0 |
0 |
if (min > AMQP_TLSv1_1 || max < AMQP_TLSv1_1) { |
546
|
0 |
0 |
if (max < AMQP_TLSv1_2) { |
558
|
0 |
1 |
CHECK_SUCCESS(pthread_mutex_lock(&openssl_init_mutex)); |
560
|
1 |
0 |
if (openssl_connections == 0 && !openssl_initialized) { |
|
1 |
0 |
if (openssl_connections == 0 && !openssl_initialized) { |
563
|
0 |
1 |
CHECK_SUCCESS(pthread_mutex_unlock(&openssl_init_mutex)); |
572
|
28569 |
28569 |
if (mode & CRYPTO_LOCK) { |
573
|
0 |
28569 |
CHECK_SUCCESS(pthread_mutex_lock(&amqp_openssl_lockarray[n])); |
575
|
0 |
28569 |
CHECK_SUCCESS(pthread_mutex_unlock(&amqp_openssl_lockarray[n])); |
584
|
0 |
1 |
if (!amqp_openssl_lockarray) { |
588
|
41 |
1 |
for (i = 0; i < CRYPTO_num_locks(); i++) { |
589
|
0 |
41 |
if (pthread_mutex_init(&amqp_openssl_lockarray[i], NULL)) { |
591
|
0 |
0 |
for (j = 0; j < i; j++) { |
620
|
0 |
0 |
CHECK_SUCCESS(pthread_mutex_lock(&openssl_init_mutex)); |
622
|
0 |
0 |
if (!openssl_initialized) { |
624
|
0 |
0 |
if (status) { |
632
|
0 |
0 |
CHECK_SUCCESS(pthread_mutex_unlock(&openssl_init_mutex)); |
638
|
0 |
1 |
CHECK_SUCCESS(pthread_mutex_lock(&openssl_init_mutex)); |
640
|
1 |
0 |
if (do_initialize_openssl && !openssl_initialized) { |
|
1 |
0 |
if (do_initialize_openssl && !openssl_initialized) { |
642
|
0 |
1 |
if (status) { |
648
|
1 |
0 |
if (!openssl_bio_initialized) { |
650
|
0 |
1 |
if (status) { |
659
|
0 |
1 |
CHECK_SUCCESS(pthread_mutex_unlock(&openssl_init_mutex)); |
664
|
0 |
1 |
CHECK_SUCCESS(pthread_mutex_lock(&openssl_init_mutex)); |
666
|
1 |
0 |
if (openssl_connections > 0) { |
670
|
0 |
1 |
CHECK_SUCCESS(pthread_mutex_unlock(&openssl_init_mutex)); |
676
|
0 |
0 |
CHECK_SUCCESS(pthread_mutex_lock(&openssl_init_mutex)); |
678
|
0 |
0 |
if (openssl_connections > 0) { |
698
|
0 |
0 |
for (i = 0; i < CRYPTO_num_locks(); i++) { |
717
|
0 |
0 |
CHECK_SUCCESS(pthread_mutex_unlock(&openssl_init_mutex)); |