summaryrefslogtreecommitdiff
path: root/lib/gras_impl/vector_of_queues.hpp
diff options
context:
space:
mode:
authorJosh Blum2012-09-12 21:37:49 -0700
committerJosh Blum2012-09-12 21:37:49 -0700
commitc7720bd1b740094636b0b66e6286f4c14961d31f (patch)
tree64887e53b7987af2ba4813d99b13487fffbb9679 /lib/gras_impl/vector_of_queues.hpp
parent081b95b570e06c3130aaf979b0feaae159901c9b (diff)
downloadsandhi-c7720bd1b740094636b0b66e6286f4c14961d31f.tar.gz
sandhi-c7720bd1b740094636b0b66e6286f4c14961d31f.tar.bz2
sandhi-c7720bd1b740094636b0b66e6286f4c14961d31f.zip
added hooks for input buffer inlining
Diffstat (limited to 'lib/gras_impl/vector_of_queues.hpp')
-rw-r--r--lib/gras_impl/vector_of_queues.hpp92
1 files changed, 0 insertions, 92 deletions
diff --git a/lib/gras_impl/vector_of_queues.hpp b/lib/gras_impl/vector_of_queues.hpp
deleted file mode 100644
index 32e0b7f..0000000
--- a/lib/gras_impl/vector_of_queues.hpp
+++ /dev/null
@@ -1,92 +0,0 @@
-//
-// Copyright 2012 Josh Blum
-//
-// This program is free software: you can redistribute it and/or modify
-// it under the terms of the GNU Lesser General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-//
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU Lesser General Public License for more details.
-//
-// You should have received a copy of the GNU Lesser General Public License
-// along with io_sig program. If not, see <http://www.gnu.org/licenses/>.
-
-#ifndef INCLUDED_LIBGRAS_IMPL_VECTOR_OF_QUEUES_HPP
-#define INCLUDED_LIBGRAS_IMPL_VECTOR_OF_QUEUES_HPP
-
-#include <boost/dynamic_bitset.hpp>
-#include <vector>
-#include <queue>
-
-namespace gnuradio
-{
-
-template <typename T>
-struct VectorOfQueues
-{
- boost::dynamic_bitset<> _bitset;
- std::vector<std::queue<T> > _queues;
-
- inline void resize(const size_t size)
- {
- _bitset.resize(size);
- _queues.resize(size);
- }
-
- inline void push(const size_t i, const T &value)
- {
- _queues[i].push(value);
- _bitset.set(i);
- }
-
- inline const T &front(const size_t i) const
- {
- return _queues[i].front();
- }
-
- inline T &front(const size_t i)
- {
- return _queues[i].front();
- }
-
- inline void pop(const size_t i)
- {
- _queues[i].pop();
- _bitset.set(i, not _queues[i].empty());
- }
-
- inline void flush(const size_t i)
- {
- _queues[i] = std::queue<T>();
- _bitset.reset(i);
- }
-
- inline void flush_all(void)
- {
- _queues.clear();
- _queues.resize(_bitset.size());
- _bitset.reset();
- }
-
- inline bool ready(const size_t i) const
- {
- return not _queues[i].empty();
- }
-
- inline bool empty(const size_t i) const
- {
- return _queues[i].empty();
- }
-
- inline bool all_ready(void) const
- {
- return (~_bitset).none();
- }
-};
-
-} //namespace gnuradio
-
-#endif /*INCLUDED_LIBGRAS_IMPL_VECTOR_OF_QUEUES_HPP*/