admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-30 23:45:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix error handle while using stream

Browse Source 
Former-commit-id: 2400cb8c1dea0a0c1b6de5a9a653c639122e2ecd
This commit is contained in:
kun yu 2019-07-29 20:17:10 +08:00
parent 593010fd91
commit dfb35391ba
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cpp/src/sdk/grpc/GrpcClient.cpp
View File

@ -115,7 +115,8 @@ GrpcClient::SearchVector(std::vector<::milvus::grpc::TopKQueryResult>& result_ar
::grpc::Status status = reader->Finish();
if (!status.ok()) {
std::cerr << "SearchVector rpc failed!\n";
std::cerr << "SearchVector rpc failed!" << std::endl;
std::cerr << status.error_message() << std::endl;
}
if (query_result.status().error_code() != grpc::SUCCESS) {
@ -131,7 +132,8 @@ GrpcClient::DescribeTable(::milvus::grpc::TableSchema& grpc_schema, const std::s
::grpc::Status status = stub_->DescribeTable(&context, grpc_tablename, &grpc_schema);
if (!status.ok()) {
std::cerr << "DescribeTable rpc failed!\n";
std::cerr << "DescribeTable rpc failed!" << std::endl;
std::cerr << status.error_message() << std::endl;
}
if (grpc_schema.table_name().status().error_code() != grpc::SUCCESS) {
@ -174,6 +176,7 @@ GrpcClient::ShowTables(std::vector<std::string> &table_array) {
if (!status.ok()) {
std::cerr << "ShowTables gRPC failed!" << std::endl;
std::cerr << status.error_message() << std::endl;
}
if (table_name.status().error_code() != grpc::SUCCESS) {