From 559c160dd796779821ac036edeb09513b6259d73 Mon Sep 17 00:00:00 2001 From: neza2017 Date: Sat, 5 Sep 2020 17:47:28 +0800 Subject: [PATCH] Set sync type Signed-off-by: neza2017 --- .gitignore | 4 ++++ proxy/src/server/timesync/TimeSync.cpp | 3 +-- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/.gitignore b/.gitignore index 54d598a1f9..fa3661548b 100644 --- a/.gitignore +++ b/.gitignore @@ -27,6 +27,10 @@ proxy/cmake_build proxy/cmake-build-debug proxy/thirdparty/grpc-src proxy/thirdparty/grpc-build +proxy/milvus/ +proxy/milvus/* +proxy/suvlim/ +proxy/suvlim/* # Compiled source *.a diff --git a/proxy/src/server/timesync/TimeSync.cpp b/proxy/src/server/timesync/TimeSync.cpp index b60e06674c..0e4dd0a9a6 100644 --- a/proxy/src/server/timesync/TimeSync.cpp +++ b/proxy/src/server/timesync/TimeSync.cpp @@ -31,8 +31,7 @@ TimeSync::TimeSync(int64_t id, for (;;) { if (this->stop_) break; this->sync_msg_.set_timestamp(this->timestamp_()); - //TODO, set msg type - //this->sync_msg_.set_msgtype(); + this->sync_msg_.set_sync_type(milvus::grpc::READ); auto rst = producer.send(sync_msg_.SerializeAsString()); if (rst != pulsar::ResultOk) { //TODO, add log