git-svn-id: http://gnuradio.org/svn/gnuradio/trunk@11601
221aa14e-8319-0410-a670-
987f0aec2ac5
Signed-off-by: Johnathan Corgan <jcorgan@corganenterprises.com>
void
gr_block_detail::produce_each (int how_many_items)
{
- if (how_many_items > 0)
+ if (how_many_items > 0){
for (int i = 0; i < noutputs (); i++)
d_output[i]->update_write_pointer (how_many_items);
+ d_produce_or |= how_many_items;
+ }
}
+
+
+ void
+ gr_block_detail::_post(pmt::pmt_t msg)
+ {
+ d_tpb.insert_tail(msg);
+ }
*/
void produce_each (int how_many_items);
--
+ /*!
+ * Accept msg, place in queue, arrange for thread to be awakened if it's not already.
+ */
+ void _post(pmt::pmt_t msg);
-
gr_tpb_detail d_tpb; // used by thread-per-block scheduler
+ int d_produce_or;
// ----------------------------------------------------------------------------