fix usrp thread priority

common/utils/T/T.h

@@ -188,6 +188,12 @@ extern T_cache_t *T_cache;
 
 #define T_HEADER(x) \
   do { \
+    if (!__builtin_types_compatible_p(typeof(x), struct T_header *)) { \
+      printf("%s:%d:%s: " \
+             "bad use of T, pass a message ID as first parameter\n", \
+             __FILE__, __LINE__, __FUNCTION__); \
+      abort(); \
+    } \
     struct timespec T_HEADER_time; \
     if (clock_gettime(CLOCK_REALTIME, &T_HEADER_time)) abort(); \
     memcpy(T_LOCAL_buf, &T_HEADER_time, sizeof(struct timespec)); \
@@ -199,6 +205,12 @@ extern T_cache_t *T_cache;
 
 #define T_HEADER(x) \
   do { \
+    if (!__builtin_types_compatible_p(typeof(x), struct T_header *)) { \
+      printf("%s:%d:%s: " \
+             "bad use of T, pass a message ID as first parameter\n", \
+             __FILE__, __LINE__, __FUNCTION__); \
+      abort(); \
+    } \
     T_PUT_int(1, (int)(uintptr_t)(x)); \
   } while (0)
 

targets/ARCH/USRP/USERSPACE/LIB/usrp_lib.cpp

@@ -469,7 +469,7 @@ extern "C" {
          * \param openair0_cfg RF frontend parameters set by application
          */
     int device_init(openair0_device* device, openair0_config_t *openair0_cfg) {
-        //uhd::set_thread_priority_safe(1.0);
+        uhd::set_thread_priority_safe(1.0);
         usrp_state_t *s = (usrp_state_t*)calloc(sizeof(usrp_state_t),1);
         // Initialize USRP device
         device->openair0_cfg = openair0_cfg;