refactor(rpc): refactor request meta & add support for backup request (…

…#255)
XiaoMi · Feb 7, 2020 · 2efa13d · 2efa13d
1 parent 0941e76
commit 2efa13d
Show file tree

Hide file tree

Showing 8 changed files with 1,047 additions and 149 deletions.
diff --git a/include/dsn/cpp/serialization_helper/dsn.layer2_types.h b/include/dsn/cpp/serialization_helper/dsn.layer2_types.h
diff --git a/include/dsn/tool-api/rpc_message.h b/include/dsn/tool-api/rpc_message.h
@@ -70,7 +70,8 @@ typedef union msg_context
         uint64_t unused : 4;               ///< not used yet
         uint64_t serialize_format : 4;     ///< dsn_msg_serialize_format
         uint64_t is_forward_supported : 1; ///< whether support forwarding a message to real leader
-        uint64_t reserved : 53;
+        uint64_t is_backup_request : 1;    ///< whether the RPC is a backup request
+        uint64_t reserved : 52;
     } u;
     uint64_t context; ///< msg_context is of sizeof(uint64_t)
 } msg_context_t;
@@ -208,6 +209,8 @@ class message_ex : public ref_counter,
     size_t body_size() { return (size_t)header->body_length; }
     DSN_API void *rw_ptr(size_t offset_begin);
 
+    bool is_backup_request() const { return header->context.u.is_backup_request; }
+
 private:
     DSN_API message_ex();
     DSN_API void prepare_buffer_header();
@@ -228,4 +231,4 @@ class message_ex : public ref_counter,
 };
 typedef dsn::ref_ptr<message_ex> message_ptr;
 
-} // end namespace
+} // namespace dsn
diff --git a/src/core/core/dsn.layer2_types.cpp b/src/core/core/dsn.layer2_types.cpp