diff options
| author | Josh Blum | 2012-09-29 10:30:52 -0700 |
|---|---|---|
| committer | Josh Blum | 2012-09-29 10:30:52 -0700 |
| commit | f3194e33de2a6496ce9ea838681e62b64fa689f4 (patch) | |
| tree | 37b80081a4978826b6bf56603ed0bd35520e4af4 /lib/tag_handlers.hpp | |
| parent | 17e39ddbb0940d9d5e687713531e9a18d18e29f1 (diff) | |
| download | sandhi-f3194e33de2a6496ce9ea838681e62b64fa689f4.tar.gz sandhi-f3194e33de2a6496ce9ea838681e62b64fa689f4.tar.bz2 sandhi-f3194e33de2a6496ce9ea838681e62b64fa689f4.zip | |
ported block task and tag handlers to apology
Diffstat (limited to 'lib/tag_handlers.hpp')
| -rw-r--r-- | lib/tag_handlers.hpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/lib/tag_handlers.hpp b/lib/tag_handlers.hpp index b49be96..0a89ef1 100644 --- a/lib/tag_handlers.hpp +++ b/lib/tag_handlers.hpp @@ -17,13 +17,13 @@ #ifndef INCLUDED_LIBGRAS_TAG_HANDLERS_HPP #define INCLUDED_LIBGRAS_TAG_HANDLERS_HPP -#include "element_impl.hpp" +#include <gras_impl/block_actor.hpp> #include <algorithm> namespace gnuradio { -GRAS_FORCE_INLINE void ElementImpl::sort_tags(const size_t i) +GRAS_FORCE_INLINE void BlockActor::sort_tags(const size_t i) { if (not this->input_tags_changed[i]) return; std::vector<Tag> &tags_i = this->input_tags[i]; @@ -31,9 +31,9 @@ GRAS_FORCE_INLINE void ElementImpl::sort_tags(const size_t i) this->input_tags_changed[i] = false; } -GRAS_FORCE_INLINE void ElementImpl::trim_tags(const tsbe::TaskInterface &task_iface, const size_t i) +GRAS_FORCE_INLINE void BlockActor::trim_tags(const size_t i) { - const size_t num_outputs = task_iface.get_num_outputs(); + const size_t num_outputs = this->get_num_outputs(); //------------------------------------------------------------------ //-- trim the input tags that are past the consumption zone @@ -59,7 +59,7 @@ GRAS_FORCE_INLINE void ElementImpl::trim_tags(const tsbe::TaskInterface &task_if { Tag t = tags_i[tag_i]; t.offset = myullround(t.offset * this->relative_rate); - task_iface.post_downstream(out_i, t); + this->post_downstream(out_i, InputTagMessage(t)); } } break; @@ -70,7 +70,7 @@ GRAS_FORCE_INLINE void ElementImpl::trim_tags(const tsbe::TaskInterface &task_if { Tag t = tags_i[tag_i]; t.offset = myullround(t.offset * this->relative_rate); - task_iface.post_downstream(i, t); + this->post_downstream(i, InputTagMessage(t)); } } break; |