From a0fe47419895c4d749c5f785cc76e4c6263c2c97 Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Tue, 26 Sep 2023 15:51:26 +0800
Subject: [PATCH] add functions: sf_xxxx_task_send/recv_buffer

---
 src/sf_proto.h | 98 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 98 insertions(+)

diff --git a/src/sf_proto.h b/src/sf_proto.h
index a38a06d..dd63dce 100644
--- a/src/sf_proto.h
+++ b/src/sf_proto.h
@@ -327,6 +327,104 @@ static inline void sf_proto_init_task_context(struct fast_task_info *task,
     }
 }
 
+/* task send and recv buffer operations */
+static inline int sf_set_task_send_buffer_size(
+        struct fast_task_info *task, const int expect_size)
+{
+    int result;
+    if ((result=free_queue_set_buffer_size(task, task->send.ptr,
+                    expect_size)) == 0)
+    {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->send.ptr->data)->magic);
+    }
+    return result;
+}
+
+static inline int sf_set_task_recv_buffer_size(
+        struct fast_task_info *task, const int expect_size)
+{
+    int result;
+    if ((result=free_queue_set_buffer_size(task, task->recv.ptr,
+                    expect_size)) == 0)
+    {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->recv.ptr->data)->magic);
+    }
+    return result;
+}
+
+static inline int sf_set_task_send_max_buffer_size(
+        struct fast_task_info *task)
+{
+    int result;
+    if ((result=free_queue_set_max_buffer_size(task, task->send.ptr)) == 0) {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->send.ptr->data)->magic);
+    }
+    return result;
+}
+
+static inline int sf_set_task_recv_max_buffer_size(
+        struct fast_task_info *task)
+{
+    int result;
+    if ((result=free_queue_set_max_buffer_size(task, task->recv.ptr)) == 0) {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->recv.ptr->data)->magic);
+    }
+    return result;
+}
+
+static inline int sf_realloc_task_send_buffer(
+        struct fast_task_info *task, const int expect_size)
+{
+    int result;
+    if ((result=free_queue_realloc_buffer(task, task->send.ptr,
+                    expect_size)) == 0)
+    {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->send.ptr->data)->magic);
+    }
+    return result;
+}
+
+static inline int sf_realloc_task_recv_buffer(
+        struct fast_task_info *task, const int expect_size)
+{
+    int result;
+    if ((result=free_queue_realloc_buffer(task, task->recv.ptr,
+                    expect_size)) == 0)
+    {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->recv.ptr->data)->magic);
+    }
+    return result;
+}
+
+static inline int sf_realloc_task_send_max_buffer(
+        struct fast_task_info *task)
+{
+    int result;
+    if ((result=free_queue_realloc_max_buffer(task, task->send.ptr)) == 0) {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->send.ptr->data)->magic);
+    }
+    return result;
+}
+
+static inline int sf_realloc_task_recv_max_buffer(
+        struct fast_task_info *task)
+{
+    int result;
+    if ((result=free_queue_realloc_max_buffer(task, task->recv.ptr)) == 0) {
+        SF_PROTO_SET_MAGIC(((SFCommonProtoHeader *)
+                    task->recv.ptr->data)->magic);
+    }
+    return result;
+}
+
+
 static inline void sf_log_network_error_ex1(SFResponseInfo *response,
         const ConnectionInfo *conn, const char *service_name,
         const int result, const int log_level,