fix callback server interface

jianzfb · Oct 17, 2024 · 60e259b · 60e259b
1 parent 204bdae
commit 60e259b
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/antgo/pipeline/extent/op/templates/grpc_stream_server_code.hpp b/antgo/pipeline/extent/op/templates/grpc_stream_server_code.hpp
@@ -93,9 +93,15 @@ class ${servername}ServiceImpl final : public ${servername}::Service{
 
         while(1){
             std::string server_reply;
-            eagleeye::ServerStatus result = eagleeye::eagleeye_pipeline_server_call(server_key, "", server_reply, timeout);
+            eagleeye::ServerStatus result = eagleeye::eagleeye_pipeline_server_call(server_key, std::vector<eagleeye::RequestData>{}, server_reply, timeout);
 
             ${servername}MessageReply reply;
+            if(result == eagleeye::SERVER_NOT_EXIST){
+                reply.set_code(1);
+                writer->Write(reply);
+                return Status::OK;
+            }
+
             reply.set_code(0);
             reply.set_data(server_reply);
             writer->Write(reply);