summaryrefslogtreecommitdiffstats
path: root/src/fuse/connection.c
diff options
context:
space:
mode:
authorSimon Rettberg2020-07-24 13:24:33 +0200
committerSimon Rettberg2020-07-24 13:24:33 +0200
commit2fe1dc1fb47aaaff6c9d7d9e3f6e4f1e304bbb66 (patch)
tree0834b9f6f1443672de7eeaae20c2675445bcea5f /src/fuse/connection.c
parent[FUSE] Detach old receive thread when creating anew one, update var (diff)
downloaddnbd3-2fe1dc1fb47aaaff6c9d7d9e3f6e4f1e304bbb66.tar.gz
dnbd3-2fe1dc1fb47aaaff6c9d7d9e3f6e4f1e304bbb66.tar.xz
dnbd3-2fe1dc1fb47aaaff6c9d7d9e3f6e4f1e304bbb66.zip
[FUSE] Cleanup
Diffstat (limited to 'src/fuse/connection.c')
-rw-r--r--src/fuse/connection.c14
1 files changed, 5 insertions, 9 deletions
diff --git a/src/fuse/connection.c b/src/fuse/connection.c
index f9e942b..2fa7c57 100644
--- a/src/fuse/connection.c
+++ b/src/fuse/connection.c
@@ -256,9 +256,7 @@ bool connection_read( dnbd3_async_t *request )
if ( !dnbd3_get_block( connection.sockFd, request->offset, request->length, (uint64_t)request, 0 ) ) {
shutdown( connection.sockFd, SHUT_RDWR );
connection.sockFd = -1;
- pthread_mutex_unlock( &connection.sendMutex );
signal_call( connection.panicSignal );
- return true;
}
}
pthread_mutex_unlock( &connection.sendMutex );
@@ -268,9 +266,7 @@ bool connection_read( dnbd3_async_t *request )
void connection_close()
{
static bool signalled = false;
- if ( true ) {
- logadd( LOG_INFO, "Tearing down dnbd3 connections and workers" );
- }
+ logadd( LOG_INFO, "Tearing down dnbd3 connections and workers" );
pthread_mutex_lock( &mutexInit );
keepRunning = false;
if ( threadInitDone && !signalled ) {
@@ -502,10 +498,10 @@ static void* connection_backgroundThread( void *something UNUSED )
if ( timing_reachedPrecise( &nextKeepalive, &now ) ) {
pthread_mutex_lock( &connection.sendMutex );
if ( connection.sockFd != -1 ) {
- dnbd3_request_t request;
- request.magic = dnbd3_packet_magic;
- request.cmd = CMD_KEEPALIVE;
- request.handle = request.offset = request.size = 0;
+ dnbd3_request_t request = {
+ .magic = dnbd3_packet_magic,
+ .cmd = CMD_KEEPALIVE,
+ };
fixup_request( request );
ssize_t ret = sock_sendAll( connection.sockFd, &request, sizeof request, 2 );
if ( (size_t)ret != sizeof request ) {