[sanlock] 02/06: sanlock: fix connection processing error path

This is an automated email from the git hooks/post-receive script.

teigland pushed a commit to branch master
in repository sanlock.

commit fd5ec4c01b4796abe9153aa45b2c26fbacc1ab2a
Author: David Teigland <teigland(a)redhat.com&gt;
AuthorDate: Mon Mar 9 12:34:54 2020 -0500

    sanlock: fix connection processing error path
    
    Don't close the connection fd in process_cmd_thread_unregistered
    error path, avoiding possible problems like that fixed in
    62ba5d194100f71cbed32214e0aeb76f690f4093.
    Handle it like process_cmd_thread_registered by receiving any
    data, sending an error back to the client, and resume the client.
    
    Call client_free() in the following cases to close
    the client connection instead of doing nothing and
    waiting for a poll error on the connection to clean
    it up later:
    - when recv() returns zero
    - when client_suspend() finds an error
    - when receiving an unknown cmd
    
    These error paths are not exercised by normal usage.
---
 src/main.c | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git a/src/main.c b/src/main.c
index 5d2a9b6..d2e8c9a 100644
--- a/src/main.c
+++ b/src/main.c
@@ -944,6 +944,7 @@ static int thread_pool_add_work(struct cmd_args *ca)
 		rv = pthread_create(&th, NULL, thread_pool_worker,
 				    (void *)(long)pool.num_workers);
 		if (rv < 0) {
+			log_error("thread_pool_add_work ci %d error %d", ca->ci_in, rv);
 			list_del(&ca->list);
 			pthread_mutex_unlock(&pool.mutex);
 			return rv;
@@ -1023,8 +1024,11 @@ static void process_cmd_thread_unregistered(int ci_in, struct
sm_header *h_recv)
  fail_free:
 	free(ca);
  fail:
+	log_error("cmd %d %d:%d process_unreg error %d",
+		  h_recv->cmd, ci_in, client[ci_in].fd, rv);
+	client_recv_all(ci_in, h_recv, 0);
 	send_result(client[ci_in].fd, h_recv, rv);
-	close(client[ci_in].fd);
+	client_resume(ci_in);
 }
 
 /*
@@ -1183,7 +1187,8 @@ static void process_connection(int ci)
 
 	rv = recv(client[ci].fd, &h, sizeof(h), MSG_WAITALL);
 	if (!rv)
-		return;
+		goto dead;
+
 	if (rv < 0) {
 		log_error("ci %d fd %d pid %d recv errno %d",
 			  ci, client[ci].fd, client[ci].pid, errno);
@@ -1253,7 +1258,7 @@ static void process_connection(int ci)
 	case SM_CMD_DELETE_RESOURCE:
 		rv = client_suspend(ci);
 		if (rv < 0)
-			return;
+			goto dead;
 		process_cmd_thread_unregistered(ci, &h);
 		break;
 	case SM_CMD_ACQUIRE:
@@ -1265,11 +1270,12 @@ static void process_connection(int ci)
 		   while the thread is working on it */
 		rv = client_suspend(ci);
 		if (rv < 0)
-			return;
+			goto dead;
 		process_cmd_thread_registered(ci, &h);
 		break;
 	default:
-		log_error("ci %d cmd %d unknown", ci, h.cmd);
+		log_error("process_connection ci %d fd %d cmd %d unknown", ci, client[ci].fd,
h.cmd);
+		goto dead;
 	};
 
 	return;

-- 
To stop receiving notification emails like this one, please contact
the administrator of this repository.