This is an automated email from the ASF dual-hosted git repository.
yuchenhe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new d6841bc feat: add query app data_version (#663)
d6841bc is described below
commit d6841bc5b0d2a44a6ed1316935d5546e32b44156
Author: HeYuchen <[email protected]>
AuthorDate: Mon Dec 28 15:14:34 2020 +0800
feat: add query app data_version (#663)
---
rdsn | 2 +-
src/server/pegasus_server_impl.cpp | 2 ++
src/server/pegasus_server_impl.h | 2 ++
3 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/rdsn b/rdsn
index 29c6ccc..b92ba6d 160000
--- a/rdsn
+++ b/rdsn
@@ -1 +1 @@
-Subproject commit 29c6ccca84873f4735c690dc8a616b8ef93377eb
+Subproject commit b92ba6d5b3a9a15370b85f82814d94a746ace132
diff --git a/src/server/pegasus_server_impl.cpp
b/src/server/pegasus_server_impl.cpp
index 5c3d5c7..fb7b600 100644
--- a/src/server/pegasus_server_impl.cpp
+++ b/src/server/pegasus_server_impl.cpp
@@ -2860,5 +2860,7 @@ void pegasus_server_impl::on_detect_hotkey(const
dsn::replication::detect_hotkey
collector->handle_rpc(req, resp);
}
+uint32_t pegasus_server_impl::query_data_version() const { return
_pegasus_data_version; }
+
} // namespace server
} // namespace pegasus
diff --git a/src/server/pegasus_server_impl.h b/src/server/pegasus_server_impl.h
index 5a42a24..1703dd7 100644
--- a/src/server/pegasus_server_impl.h
+++ b/src/server/pegasus_server_impl.h
@@ -339,6 +339,8 @@ private:
void on_detect_hotkey(const dsn::replication::detect_hotkey_request &req,
dsn::replication::detect_hotkey_response &resp)
override;
+ uint32_t query_data_version() const override;
+
private:
static const std::chrono::seconds kServerStatUpdateTimeSec;
static const std::string COMPRESSION_HEADER;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
