fixup! rfnoc: Fix thread unsafe accesses in ctrlport

1 files changed, 5 insertions, 7 deletions

diff --git a/host/lib/rfnoc/ctrlport_endpoint.cpp b/host/lib/rfnoc/ctrlport_endpoint.cpp
index de5fa00b7..68a2dddf4 100644
--- a/host/lib/rfnoc/ctrlport_endpoint.cpp
+++ b/host/lib/rfnoc/ctrlport_endpoint.cpp
@@ -389,14 +389,13 @@ private:
             // If we can fit the current request in the queue then we can proceed
             return (_buff_occupied + pyld_size)
                    <= (_buff_capacity
-                       - (ASYNC_MESSAGE_SIZE * _max_outstanding_async_msgs));
+                          - (ASYNC_MESSAGE_SIZE * _max_outstanding_async_msgs));
         };
         if (!buff_not_full()) {
             // If there is a timed command in the queue, use the
             // MASSIVE_TIMEOUT instead
-            auto timeout_time = start_timeout(check_timed_in_queue() ?
-                                                MASSIVE_TIMEOUT :
-                                                _policy.timeout);
+            auto timeout_time =
+                start_timeout(check_timed_in_queue() ? MASSIVE_TIMEOUT : _policy.timeout);
 
             if (not _buff_free_cond.wait_until(lock, timeout_time, buff_not_full)) {
                 throw uhd::op_timeout(
@@ -423,9 +422,8 @@ private:
             if (!resp_ready()) {
                 // If we're waiting for a timed command or if we have a
                 // command in the queue, use the MASSIVE_TIMEOUT instead
-                auto timeout_time = start_timeout(check_timed_in_queue() ?
-                                                  MASSIVE_TIMEOUT :
-                                                   _policy.timeout);
+                auto timeout_time = start_timeout(
+                    check_timed_in_queue() ? MASSIVE_TIMEOUT : _policy.timeout);
 
                 if (not _resp_ready_cond.wait_until(lock, timeout_time, resp_ready)) {
                     throw uhd::op_timeout("Control operation timed out waiting for ACK");