]> git.ipfire.org Git - thirdparty/samba.git/commitdiff
async_sock: split out read_packet_do() from read_packet_handler()
authorStefan Metzmacher <metze@samba.org>
Mon, 28 Apr 2025 15:54:31 +0000 (17:54 +0200)
committerStefan Metzmacher <metze@samba.org>
Mon, 12 May 2025 10:31:30 +0000 (10:31 +0000)
We'll call read_packet_do() in other places too in future.

Signed-off-by: Stefan Metzmacher <metze@samba.org>
Reviewed-by: Volker Lendecke <vl@samba.org>
lib/async_req/async_sock.c

index 6cfcafd957881cac848bb70eb9f7fab8a2c1c812..2c33380cd83f4f4d2f446a32ba80bded3d70bac7 100644 (file)
@@ -459,6 +459,7 @@ struct read_packet_state {
 
 static void read_packet_cleanup(struct tevent_req *req,
                                 enum tevent_req_state req_state);
+static void read_packet_do(struct tevent_req *req);
 static void read_packet_handler(struct tevent_context *ev,
                                struct tevent_fd *fde,
                                uint16_t flags, void *private_data);
@@ -509,12 +510,8 @@ static void read_packet_cleanup(struct tevent_req *req,
        TALLOC_FREE(state->fde);
 }
 
-static void read_packet_handler(struct tevent_context *ev,
-                               struct tevent_fd *fde,
-                               uint16_t flags, void *private_data)
+static void read_packet_do(struct tevent_req *req)
 {
-       struct tevent_req *req = talloc_get_type_abort(
-               private_data, struct tevent_req);
        struct read_packet_state *state =
                tevent_req_data(req, struct read_packet_state);
        size_t total = talloc_get_size(state->buf);
@@ -590,6 +587,17 @@ static void read_packet_handler(struct tevent_context *ev,
                return;
        }
        state->buf = tmp;
+
+}
+
+static void read_packet_handler(struct tevent_context *ev,
+                               struct tevent_fd *fde,
+                               uint16_t flags, void *private_data)
+{
+       struct tevent_req *req = talloc_get_type_abort(
+               private_data, struct tevent_req);
+
+       read_packet_do(req);
 }
 
 ssize_t read_packet_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx,