From b3c973703505c3603c530fb7b50c9de204b23c77 Mon Sep 17 00:00:00 2001 From: Test_User Date: Thu, 20 Jun 2024 08:01:44 -0400 Subject: Reduced locking buffered openssl writing now ready --- networks/plaintext_buffered.c | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) (limited to 'networks/plaintext_buffered.c') diff --git a/networks/plaintext_buffered.c b/networks/plaintext_buffered.c index 437c8fa..6ff5718 100644 --- a/networks/plaintext_buffered.c +++ b/networks/plaintext_buffered.c @@ -82,7 +82,7 @@ void * plaintext_buffered_send_thread(void *handle) { size_t len; #ifdef USE_FUTEX - len = __sync_sub_and_fetch(&(info->buffer_len), res); + len = __sync_sub_and_fetch(&(info->buffer_len), (size_t)res); #else info->buffer_len -= (size_t)res; len = info->buffer_len; @@ -103,10 +103,7 @@ void * plaintext_buffered_send_thread(void *handle) { #else if (!info->valid) goto plaintext_buffered_send_thread_error_unlock; -#endif -#ifdef USE_FUTEX -#else mutex_unlock(&(info->mutex)); #endif @@ -204,9 +201,8 @@ int plaintext_buffered_send(void *handle, struct string msg) { len = PLAINTEXT_BUFFERED_LEN - plaintext_handle->write_buffer_index; #ifdef USE_FUTEX - if (!__sync_fetch_and_or(&(plaintext_handle->valid), 0)) { + if (!__sync_fetch_and_or(&(plaintext_handle->valid), 0)) return 1; - } #else if (!plaintext_handle->valid) { mutex_unlock(&(plaintext_handle->mutex)); -- cgit v1.2.3