From 3a4a7069b94292a939885305fc31f4a7d1418cdd Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Wed, 10 Feb 2021 11:33:48 +0800
Subject: [PATCH] add type SFBinlogWriterStat

---
 src/idempotency/server/server_types.h | 3 ++-
 src/sf_types.h                        | 7 +++++++
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/idempotency/server/server_types.h b/src/idempotency/server/server_types.h
index d1844cc..9d6b3d3 100644
--- a/src/idempotency/server/server_types.h
+++ b/src/idempotency/server/server_types.h
@@ -39,10 +39,11 @@ typedef struct idempotency_request_result {
 typedef struct idempotency_request {
     uint64_t req_id;
     volatile int ref_count;
-    bool finished;
+    volatile bool finished;
     IdempotencyRequestResult output;
     struct fast_mblock_man *allocator;  //for free
     struct idempotency_request *next;
+    struct fast_task_info *task;  //for debug
 } IdempotencyRequest;
 
 typedef struct idempotency_request_htable {
diff --git a/src/sf_types.h b/src/sf_types.h
index 9d40c4a..16621b6 100644
--- a/src/sf_types.h
+++ b/src/sf_types.h
@@ -102,6 +102,13 @@ typedef struct sf_space_stat {
     int64_t used;
 } SFSpaceStat;
 
+typedef struct sf_binlog_writer_stat {
+    int64_t total_count;
+    int64_t next_version;
+    int waiting_count;
+    int max_waitings;
+} SFBinlogWriterStat;
+
 typedef struct sf_version_range {
     int64_t first; //including
     int64_t last;  //including