X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fgrpc.cc;h=ae3dab25d6445249831d76291a0316c5aa1c7b3e;hb=f3d13bd9c187c75ec9b4dbf42f8d821fb303bc90;hp=a1dac35bb6db0b8bb49c6ad4d78c805051a8091d;hpb=23faf977688c7123d624b2911e69e2c9f4d0f78c;p=collectd.git

diff --git a/src/grpc.cc b/src/grpc.cc
index a1dac35b..ae3dab25 100644
--- a/src/grpc.cc
+++ b/src/grpc.cc
@@ -287,35 +287,44 @@ static grpc::Status Process(grpc::ServerContext *ctx,
 				grpc::string("failed to query values: cannot create iterator"));
 	}
 
+	status = grpc::Status::OK;
 	while (uc_iterator_next(iter, &name) == 0) {
 		value_list_t res;
-		if (parse_identifier_vl(name, &res) != 0)
-			return grpc::Status(grpc::StatusCode::INTERNAL,
+		if (parse_identifier_vl(name, &res) != 0) {
+			status = grpc::Status(grpc::StatusCode::INTERNAL,
 					grpc::string("failed to parse identifier"));
+			break;
+		}
 
 		if (!ident_matches(&res, &matcher))
 			continue;
 
-		if (uc_iterator_get_time(iter, &res.time) < 0)
-			return grpc::Status(grpc::StatusCode::INTERNAL,
+		if (uc_iterator_get_time(iter, &res.time) < 0) {
+			status = grpc::Status(grpc::StatusCode::INTERNAL,
 					grpc::string("failed to retrieve value timestamp"));
-		if (uc_iterator_get_interval(iter, &res.interval) < 0)
-			return grpc::Status(grpc::StatusCode::INTERNAL,
+			break;
+		}
+		if (uc_iterator_get_interval(iter, &res.interval) < 0) {
+			status = grpc::Status(grpc::StatusCode::INTERNAL,
 					grpc::string("failed to retrieve value interval"));
-		if (uc_iterator_get_values(iter, &res.values, &res.values_len) < 0)
-			return grpc::Status(grpc::StatusCode::INTERNAL,
+			break;
+		}
+		if (uc_iterator_get_values(iter, &res.values, &res.values_len) < 0) {
+			status = grpc::Status(grpc::StatusCode::INTERNAL,
 					grpc::string("failed to retrieve values"));
+			break;
+		}
 
 		auto vl = reply->add_values();
 		status = marshal_value_list(&res, vl);
 		free(res.values);
 		if (!status.ok())
-			return status;
+			break;
 	}
 
 	uc_iterator_destroy(iter);
 
-	return grpc::Status::OK;
+	return status;
 } /* Process(): QueryValues */
 
 class Call