if (size_read < 0) {
LOG_PERROR(LOG_WARNING, "read_from_write_to(): read()");
return -1;
- }
/* EOF */
- if (size_read == 0) {
+ } else if (size_read == 0) {
return -1;
}
LOG(LOG_WARNING, "read_from_write_to_tls(): gnutls_record_recv(): %s",
gnutls_strerror((int)size_read));
return -1;
- }
/* EOF */
- if (size_read == 0) {
+ } else if (size_read == 0) {
return -1;
}
return EXIT_FAILURE;
}
for (i = 0; i < thread_count; i++) {
- int result;
- pthread_t thread;
-
- result = pthread_create(&thread, NULL,
+ errno = pthread_create(threads + i, NULL,
(void * (*)(void *))&worker_thread,
NULL);
- if (result != 0) {
- fprintf(stderr, "failed to create worker thread: %s\n",
- strerror(result));
+ if (errno != 0) {
+ perror("failed to create worker thread");
return EXIT_FAILURE;
}
-
- threads[i] = thread;
}
#ifdef USE_IPV4_ONLY
while ((option = getopt(argc, argv, "d:p:t:uh?")) != -1) {
switch (option) {
case 'd': {
- if (atoi(optarg) < 0) {
+ global_log_level = atoi(optarg);
+ if (global_log_level < 0) {
print_usage(argv[0]);
fprintf(stderr, "\n-d positive number required: '%s'\n",
optarg);
exit(EXIT_FAILURE);
}
- global_log_level = atoi(optarg);
break;
}
case 'p': {
static void initialize_gnutls(void) {
int result;
- gcry_error_t error = 0;
+ gcry_error_t error;
/* Thread safe setup. Must be called before gnutls_global_init(). */
error = gcry_control(GCRYCTL_SET_THREAD_CBS, &gcry_threads_pthread);
- if (error) {
+ if (error != 0) {
fprintf(stderr, "gcry_control(): %s/%s\n", gcry_strsource(error),
gcry_strerror(error));
exit(EXIT_FAILURE);
}
/* Prevent usage of blocking /dev/random. */
error = gcry_control(GCRYCTL_ENABLE_QUICK_RANDOM, 0);
- if (error) {
+ if (error != 0) {
fprintf(stderr, "gcry_control(): %s/%s\n", gcry_strsource(error),
gcry_strerror(error));
exit(EXIT_FAILURE);
return -2;
}
- while (fgets(buffer, MAX_REQUEST_LINE, client_fd) != NULL) {
+ while (fgets(buffer, sizeof(buffer), client_fd) != NULL) {
/* End of header. */
if (!strcmp(buffer, "\n") || !strcmp(buffer, "\r\n")) {
break;