burst tagger: remove annoying debug statements
This commit is contained in:
@@ -44,8 +44,6 @@ burst_tagger_impl::~burst_tagger_impl() {
|
||||
|
||||
void
|
||||
burst_tagger_impl::add_sob(uint64_t item) {
|
||||
GR_LOG_DEBUG(d_debug_logger, boost::format("insert tx_sob at item %1%") % item);
|
||||
|
||||
static const pmt::pmt_t sob_key = pmt::string_to_symbol("tx_sob");
|
||||
static const pmt::pmt_t value = pmt::PMT_T;
|
||||
static const pmt::pmt_t srcid = pmt::string_to_symbol(alias());
|
||||
@@ -55,8 +53,6 @@ burst_tagger_impl::add_sob(uint64_t item) {
|
||||
|
||||
void
|
||||
burst_tagger_impl::add_eob(uint64_t item) {
|
||||
GR_LOG_DEBUG(d_debug_logger, boost::format("insert tx_eob at item %1%") % item);
|
||||
|
||||
static const pmt::pmt_t eob_key = pmt::string_to_symbol("tx_eob");
|
||||
static const pmt::pmt_t value = pmt::PMT_T;
|
||||
static const pmt::pmt_t srcid = pmt::string_to_symbol(alias());
|
||||
@@ -74,7 +70,6 @@ burst_tagger_impl::work(int noutput_items,
|
||||
|
||||
|
||||
if(!d_copy) {
|
||||
GR_LOG_DEBUG(d_debug_logger, "nothing to copy -- searching for tags");
|
||||
std::vector<gr::tag_t> tags;
|
||||
const uint64_t nread = nitems_read(0);
|
||||
|
||||
@@ -84,15 +79,12 @@ burst_tagger_impl::work(int noutput_items,
|
||||
|
||||
// copy until the first tag
|
||||
if(tags.size()) {
|
||||
GR_LOG_DEBUG(d_debug_logger, "tags found");
|
||||
tag_t tag = tags.front();
|
||||
if(tag.offset == nitems_read(0)) {
|
||||
d_copy = pmt::to_uint64(tag.value) * d_mult;
|
||||
GR_LOG_DEBUG(d_debug_logger, boost::format("tag is at current offset, packet len %1%") % d_copy);
|
||||
add_sob(nitems_written(0));
|
||||
} else {
|
||||
uint64_t cpy = std::min((uint64_t)noutput_items, tag.offset - nitems_written(0));
|
||||
GR_LOG_DEBUG(d_debug_logger, boost::format("tag is not at current offset, copying %1%") % cpy);
|
||||
std::memcpy(out, in, cpy * sizeof(gr_complex));
|
||||
return cpy;
|
||||
}
|
||||
@@ -101,7 +93,6 @@ burst_tagger_impl::work(int noutput_items,
|
||||
|
||||
if(d_copy) {
|
||||
int cpy = std::min(d_copy, noutput_items);
|
||||
GR_LOG_DEBUG(d_debug_logger, boost::format("copying %1% samples from packet") % cpy);
|
||||
std::memcpy(out, in, cpy * sizeof(gr_complex));
|
||||
d_copy -= cpy;
|
||||
if(d_copy == 0) {
|
||||
@@ -109,7 +100,6 @@ burst_tagger_impl::work(int noutput_items,
|
||||
}
|
||||
return cpy;
|
||||
} else {
|
||||
GR_LOG_DEBUG(d_debug_logger, boost::format("copy non-packet samples"));
|
||||
std::memcpy(out, in, noutput_items * sizeof(gr_complex));
|
||||
return noutput_items;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user