[PATCH cluster 08/12] pmxcfs: server: move message response sending to separate function

[Daniel Kral <d.kral@proxmox.com>]

Move the sending of IPC request responses to a separate function in
preparation of an upcoming patch, which allows sending large responses
as multiple chunks and therefore increases the complexity slightly.

Signed-off-by: Daniel Kral <d.kral@proxmox.com>
---
 src/pmxcfs/server.c | 40 ++++++++++++++++++++++------------------
 1 file changed, 22 insertions(+), 18 deletions(-)

diff --git a/src/pmxcfs/server.c b/src/pmxcfs/server.c
index c9fabb4..0af6745 100644
--- a/src/pmxcfs/server.c
+++ b/src/pmxcfs/server.c
@@ -438,24 +438,7 @@ static int32_t s1_msg_handle_request(
     return result;
 }
 
-static int32_t s1_msg_process_fn(qb_ipcs_connection_t *c, void *data, size_t size) {
-    struct qb_ipc_request_header *req_pt = (struct qb_ipc_request_header *)data;
-
-    struct s1_context *ctx = (struct s1_context *)qb_ipcs_context_get(c);
-
-    if (!ctx) {
-        cfs_critical("qb_ipcs_context_get failed");
-        qb_ipcs_disconnect(c);
-        return 0;
-    }
-
-    int32_t request_id = req_pt->id;
-    int32_t request_size = req_pt->size;
-    cfs_debug("process msg:%d, size:%d", request_id, request_size);
-
-    int32_t result = s1_msg_handle_request(ctx, data, request_id, request_size);
-    cfs_debug("process result %d", result);
-
+static void s1_msg_send_response(qb_ipcs_connection_t *c, int32_t request_id, int32_t result) {
     int iov_len = 2;
     struct iovec iov[iov_len];
     struct qb_ipc_response_header res_header;
@@ -487,6 +470,27 @@ static int32_t s1_msg_process_fn(qb_ipcs_connection_t *c, void *data, size_t siz
         cfs_critical("qb_ipcs_response_send: %s", strerror(errno));
         qb_ipcs_disconnect(c);
     }
+}
+
+static int32_t s1_msg_process_fn(qb_ipcs_connection_t *c, void *data, size_t size) {
+    struct qb_ipc_request_header *req_pt = (struct qb_ipc_request_header *)data;
+
+    struct s1_context *ctx = (struct s1_context *)qb_ipcs_context_get(c);
+
+    if (!ctx) {
+        cfs_critical("qb_ipcs_context_get failed");
+        qb_ipcs_disconnect(c);
+        return 0;
+    }
+
+    int32_t request_id = req_pt->id;
+    int32_t request_size = req_pt->size;
+    cfs_debug("process msg:%d, size:%d", request_id, request_size);
+
+    int32_t result = s1_msg_handle_request(ctx, data, request_id, request_size);
+    cfs_debug("process result %d", result);
+
+    s1_msg_send_response(c, request_id, result);
 
     return 0;
 }
-- 
2.47.3