From 1b84453cc51b07eb9106bcd6731a321ff1924d74 Mon Sep 17 00:00:00 2001
From: Josh Blum
Date: Sun, 5 May 2013 16:57:57 -0700
Subject: 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
---
 lib/block_message.cpp | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)

(limited to 'lib')

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());
+}
-- 
cgit