fix(node-gateway): include output message

Signed-off-by: Alexandra <alexandra.bach@eonerc.rwth-aachen.de>

Author: al3xa23

lib/api/request.cpp

@@ -25,7 +25,7 @@ std::string Request::toString() {
 
 Request *RequestFactory::create(Session *s, const std::string &uri,
                                 Session::Method meth, unsigned long ct) {
-  s->logger->info("Lookup request handler for: uri={}", uri);
+  s->logger->debug("Lookup request handler for: uri={}", uri);
 
   for (auto *rf : plugin::registry->lookup<RequestFactory>()) {
     std::smatch mr;

lib/api/requests/gateway/grpc.cpp

@@ -15,6 +15,7 @@
 #include <villas/api/response.hpp>
 #include <villas/nodes/gateway.hpp>
 #include <villas/timing.hpp>
+#include "villas/log.hpp"
 
 using namespace google::protobuf;
 
@@ -30,7 +31,7 @@ class ReflectionClient {
     request.set_file_containing_symbol(symbol);
     bool streamstatus = stream->Write(request);
     if (!streamstatus)
-      std::cout << "Server not allow reflection" << std::endl;
+      std::cout << "Server does not allow reflection" << std::endl;
 
     grpc::reflection::v1alpha::ServerReflectionResponse response;
     google::protobuf::FileDescriptorSet *file_descs =
@@ -167,7 +168,7 @@ class grpcRequest : public NodeRequest {
       db.Add(protos->file(i));
     }
     auto pool = std::make_unique<DescriptorPool>(&db);
-    const Descriptor *resp_desc;
+    const Descriptor *resp_desc = nullptr;
     // Check if server reflection complete
     if (protos->file_size() == 0) {
       server_reflection = false;
@@ -370,6 +371,7 @@ class grpcRequest : public NodeRequest {
       size_t dummy_wbytes;
       ret = gateway_node->formatter->sprint(dummy_buf, dummy_buflen,
                                             &dummy_wbytes, sample_dummy);
+      logger->debug("gRPC Request Sample length {}", sample_dummy->length);
       if (ret < 0) {
         logger->warn("Failed to format request payload");
       }
@@ -482,6 +484,7 @@ class grpcRequest : public NodeRequest {
     Sample *sample_dummy = sample_alloc_mem(64);
     int ret = gateway_node->formatter->sscan(
         recv_data.c_str(), resp_buf.Length(), &rbytes, sample_dummy);
+    logger->debug("gRPC Response Sample length {}", sample_dummy->length);
     if (ret < 0) {
       std::cerr << "Formatting Failed: " << ret << std::endl;
     }
@@ -493,10 +496,8 @@ class grpcRequest : public NodeRequest {
                              time_to_double(&sample_dummy->ts.origin), "value",
                              json_ch);
 
-    if (method == Session::PUT) {
-      sample_copy(gateway_node->read.sample, sample_dummy);
-      pthread_cond_signal(&gateway_node->read.cv);
-    }
+    sample_copy(gateway_node->read.sample, sample_dummy);
+    pthread_cond_signal(&gateway_node->read.cv);
 
     sample_free(sample_dummy);
     pthread_mutex_unlock(&gateway_node->read.mutex);

lib/nodes/gateway.cpp

@@ -53,13 +53,15 @@ int GatewayNode::_read(struct Sample *smps[], unsigned cnt) {
 
   pthread_cond_wait(&read.cv, &read.mutex);
   sample_copy(smps[0], read.sample);
+  logger->debug("Gateway read sample {}", smps[0]->length);
 
   return 1;
 }
 
 int GatewayNode::_write(struct Sample *smps[], unsigned cnt) {
   assert(cnt == 1);
   sample_copy(write.sample, smps[0]);
+  logger->debug("Gateway write sample {}", smps[0]->length);
 
   int ret =
       formatter->sprint(write.buf, write.buflen, &write.wbytes, smps, cnt);