fix(thrift): add start_time_ns for structure mutation_update in thrif…

…t file (#387)
XiaoMi · Mar 29, 2020 · 4cb2cd2 · 4cb2cd2
1 parent c941d5a
commit 4cb2cd2
Show file tree

Hide file tree

Showing 4 changed files with 35 additions and 6 deletions.
diff --git a/include/dsn/dist/replication/replication_types.h b/include/dsn/dist/replication/replication_types.h
diff --git a/src/dist/replication/common/replication_types.cpp b/src/dist/replication/common/replication_types.cpp
diff --git a/src/dist/replication/lib/mutation.cpp b/src/dist/replication/lib/mutation.cpp
@@ -143,6 +143,7 @@ void mutation::add_client_request(task_code code, dsn::message_ex *request)
         update.code = code;
         update.serialization_type =
             (dsn_msg_serialize_format)request->header->context.u.serialize_format;
+        update.__set_start_time_ns(dsn_now_ns());
         request->add_ref(); // released on dctor
 
         void *ptr;

diff --git a/src/dist/replication/replication.thrift b/src/dist/replication/replication.thrift
@@ -20,6 +20,7 @@ struct mutation_update
     //the serialization type of data, this need to store in log and replicate to secondaries by primary
     2:i32            serialization_type;
     3:dsn.blob       data;
+    4:optional i64   start_time_ns;
 }
 
 struct mutation_data