gras: added post input buffer/message/tag api calls

This allows the user to post stuff to the input port
from an external entity aka outside of the scheduler.

resolves #86

1 files changed, 25 insertions, 0 deletions

diff --git a/lib/block_message.cpp b/lib/block_message.cpp
index 43dc7b4..eae0c68 100644
--- a/lib/block_message.cpp
+++ b/lib/block_message.cpp
@@ -47,3 +47,28 @@ void Block::propagate_tags(const size_t i, const TagIter &iter)
         }
     }
 }
+
+void Block::post_input_tag(const size_t which_input, const Tag &tag)
+{
+    InputTagMessage message(tag);
+    message.index = which_input;
+    Theron::Actor &actor = *((*this)->block);
+    actor.GetFramework().Send(message, Theron::Address::Null(), actor.GetAddress());
+}
+
+void Block::post_input_msg(const size_t which_input, const PMCC &msg)
+{
+    InputMsgMessage message(msg);
+    message.index = which_input;
+    Theron::Actor &actor = *((*this)->block);
+    actor.GetFramework().Send(message, Theron::Address::Null(), actor.GetAddress());
+}
+
+void Block::post_input_buffer(const size_t which_input, const SBuffer &buffer)
+{
+    InputBufferMessage message;
+    message.index = which_input;
+    message.buffer = buffer;
+    Theron::Actor &actor = *((*this)->block);
+    actor.GetFramework().Send(message, Theron::Address::Null(), actor.GetAddress());
+}