summaryrefslogtreecommitdiffstats
path: root/host/lib/transport
diff options
context:
space:
mode:
authorJosh Blum <josh@joshknows.com>2012-01-16 22:31:03 -0800
committerJosh Blum <josh@joshknows.com>2012-01-23 13:03:09 -0800
commitb8e41cbbc9666a9758d0f9f3a57272530716935a (patch)
treefc8eb1546d5ac4ab3ec5ae742335b45144fa0bc2 /host/lib/transport
parent287958ba36072f699090aa61ad2b6bbee6846d66 (diff)
downloaduhd-b8e41cbbc9666a9758d0f9f3a57272530716935a.tar.gz
uhd-b8e41cbbc9666a9758d0f9f3a57272530716935a.tar.bz2
uhd-b8e41cbbc9666a9758d0f9f3a57272530716935a.zip
uhd: flush transport for new rx streamers
Diffstat (limited to 'host/lib/transport')
-rw-r--r--host/lib/transport/super_recv_packet_handler.hpp5
1 files changed, 4 insertions, 1 deletions
diff --git a/host/lib/transport/super_recv_packet_handler.hpp b/host/lib/transport/super_recv_packet_handler.hpp
index 05cad93ea..a5876c8bf 100644
--- a/host/lib/transport/super_recv_packet_handler.hpp
+++ b/host/lib/transport/super_recv_packet_handler.hpp
@@ -116,7 +116,10 @@ public:
* \param xport_chan which transport channel
* \param get_buff the getter function
*/
- void set_xport_chan_get_buff(const size_t xport_chan, const get_buff_type &get_buff){
+ void set_xport_chan_get_buff(const size_t xport_chan, const get_buff_type &get_buff, const bool flush = false){
+ if (flush){
+ while (get_buff(0.0));
+ }
_props.at(xport_chan).get_buff = get_buff;
}