From 2a3eef08fb4a96f193ddc9a830ec3afa84c42fdb Mon Sep 17 00:00:00 2001
From: ismagom <gomezi@tcd.ie>
Date: Mon, 1 Feb 2016 11:06:03 +0100
Subject: [PATCH] Added timeout to blocking recv/send uhd functions to avoid

---
 srslte/lib/rf/src/rf_uhd_imp.c | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/srslte/lib/rf/src/rf_uhd_imp.c b/srslte/lib/rf/src/rf_uhd_imp.c
index 639190211..b66babcf0 100644
--- a/srslte/lib/rf/src/rf_uhd_imp.c
+++ b/srslte/lib/rf/src/rf_uhd_imp.c
@@ -431,6 +431,7 @@ int rf_uhd_recv_with_time(void *h,
   rf_uhd_handler_t *handler = (rf_uhd_handler_t*) h;
   size_t rxd_samples;
   uhd_rx_metadata_handle *md = &handler->rx_md_first; 
+  int trials = 0; 
   if (blocking) {
     int n = 0;
     cf_t *data_c = (cf_t*) data;
@@ -451,7 +452,7 @@ int rf_uhd_recv_with_time(void *h,
       }
       md = &handler->rx_md; 
       n += rxd_samples;
-    } while (n < nsamples);
+    } while (n < nsamples && trials < 100);
   } else {
     void **buffs_ptr = (void**) &data;
     return uhd_rx_streamer_recv(handler->rx_stream, buffs_ptr, 
@@ -479,6 +480,7 @@ int rf_uhd_send_timed(void *h,
   if (has_time_spec) {
     uhd_tx_metadata_set_time_spec(&handler->tx_md, secs, frac_secs);
   }
+  int trials = 0; 
   if (blocking) {
     int n = 0;
     cf_t *data_c = (cf_t*) data;
@@ -511,7 +513,7 @@ int rf_uhd_send_timed(void *h,
       // Increase time spec 
       uhd_tx_metadata_add_time_spec(&handler->tx_md, txd_samples/handler->tx_rate);
       n += txd_samples;
-    } while (n < nsamples);
+    } while (n < nsamples && trials < 100);
     return nsamples;
   } else {
     const void **buffs_ptr = (const void**) &data;