commit-gnuradio
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[Commit-gnuradio] [gnuradio] 06/11: uhd: modified tag preemption/gap han


From: git
Subject: [Commit-gnuradio] [gnuradio] 06/11: uhd: modified tag preemption/gap handling
Date: Sat, 26 Apr 2014 22:34:12 +0000 (UTC)

This is an automated email from the git hooks/post-receive script.

jcorgan pushed a commit to branch master
in repository gnuradio.

commit fdafa6a6ed03d5bfea5e2c11584902d64032c761
Author: Sean Nowlan <address@hidden>
Date:   Thu Apr 3 23:28:00 2014 -0400

    uhd: modified tag preemption/gap handling
---
 gr-uhd/lib/usrp_sink_impl.cc | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/gr-uhd/lib/usrp_sink_impl.cc b/gr-uhd/lib/usrp_sink_impl.cc
index 316c39a..413952a 100644
--- a/gr-uhd/lib/usrp_sink_impl.cc
+++ b/gr-uhd/lib/usrp_sink_impl.cc
@@ -496,6 +496,8 @@ namespace gr {
           //the last sample of the previous burst. Drop samples until the next
           //length_tag is found. Notify the user of the tag gap.
           std::cerr << "tG" << std::flush;
+          //increment the timespec by the number of samples dropped
+          _metadata.time_spec += ::uhd::time_spec_t(0, ninput_items, 
_sample_rate);
           return ninput_items;
         }
       }
@@ -572,15 +574,10 @@ namespace gr {
         //length_tag found; set the start of burst flag in the metadata
         else if(not pmt::is_null(_length_tag_key) and pmt::equal(key, 
_length_tag_key)) {
           //If there are still items left to send, the current burst has been 
preempted.
-          //Truncate the current burst by setting the end of burst flag in a 
mini end of
-          //burst packet. The next call to work will start at the new burst. 
Notify the
-          //user of the tag preemption.
+          //Set the items remaining counter to the new burst length. Notify 
the user of
+          //the tag preemption.
           if(_nitems_to_send > 0) {
-              ninput_items = 0;
-              _nitems_to_send = 0;
-              _metadata.end_of_burst = true;
               std::cerr << "tP" << std::flush;
-              return;
           }
           _nitems_to_send = pmt::to_long(value);
           _metadata.start_of_burst = true;



reply via email to

[Prev in Thread] Current Thread [Next in Thread]