diff --git a/src/run/monica-capnp-fbp-component-main.cpp b/src/run/monica-capnp-fbp-component-main.cpp index 2b23985..d4c2b84 100644 --- a/src/run/monica-capnp-fbp-component-main.cpp +++ b/src/run/monica-capnp-fbp-component-main.cpp @@ -96,8 +96,9 @@ class FBPMain { } try { while (true) { + KJ_LOG(INFO, "trying to read from IN port"); auto msg = inp.readRequest().send().wait(ioContext.waitScope); - KJ_LOG(INFO, "received msg"); + KJ_LOG(INFO, "received msg from IN port"); // check for end of data from in port if (msg.isDone()) { KJ_LOG(INFO, "received done -> exiting main loop"); @@ -123,21 +124,18 @@ class FBPMain { auto toAttrBuilder = mas::infrastructure::common::copyAndSetIPAttrs(inIp, outIp, toAttr);//, capnp::toAny(resJsonStr)); KJ_IF_MAYBE(builder, toAttrBuilder) builder->setAs(resJsonStr); - KJ_LOG(INFO, "sending result on out port"); + KJ_LOG(INFO, "trying to send result on OUT port"); wreq.send().wait(ioContext.waitScope); - KJ_LOG(INFO, "sent result on out port"); + KJ_LOG(INFO, "sent result on OUT port"); } } - } - KJ_LOG(INFO, "closing out port"); + KJ_LOG(INFO, "closing OUT port"); outp.closeRequest().send().wait(ioContext.waitScope); - //cout << "monica-capnp-fbp-component-main: closed result out port" << endl; } catch (const kj::Exception &e) { KJ_LOG(INFO, "Exception: ", e.getDescription()); std::cerr << "Exception: " << e.getDescription().cStr() << endl; - //std::cout << "Exception: " << e.getDescription().cStr() << endl; } return true;