Advertisement
Guest User

Untitled

a guest
Apr 1st, 2013
111
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.60 KB | None | 0 0
  1. diff --git a/host/lib/transport/super_recv_packet_handler.hpp b/host/lib/transport/super_recv_packet_handler.hpp
  2. index 7a19726..6c99cb9 100644
  3. --- a/host/lib/transport/super_recv_packet_handler.hpp
  4. +++ b/host/lib/transport/super_recv_packet_handler.hpp
  5. @@ -95,7 +95,7 @@ public:
  6. _task_barrier_exit.resize(size);
  7. _task_handlers.resize(size);
  8. for (size_t i = 1/*skip 0*/; i < size; i++){
  9. - _task_handlers[i] = task::make(boost::bind(&recv_packet_handler::converter_thread_task, this, i));
  10. + //_task_handlers[i] = task::make(boost::bind(&recv_packet_handler::converter_thread_task, this, i));
  11. };
  12. }
  13.  
  14. @@ -541,7 +541,7 @@ private:
  15. _convert_bytes_to_copy = bytes_to_copy;
  16.  
  17. //perform N channels of conversion
  18. - converter_thread_task(0);
  19. + for (size_t i = 0; i < _props.size(); i++) converter_thread_task(i);
  20.  
  21. //update the copy buffer's availability
  22. info.data_bytes_to_copy -= bytes_to_copy;
  23. @@ -561,7 +561,7 @@ private:
  24. ******************************************************************/
  25. UHD_INLINE void converter_thread_task(const size_t index)
  26. {
  27. - _task_barrier_entry.wait();
  28. + //_task_barrier_entry.wait();
  29.  
  30. //shortcut references to local data structures
  31. buffers_info_type &buff_info = get_curr_buffer_info();
  32. @@ -587,7 +587,7 @@ private:
  33. info.buff.reset(); //effectively a release
  34. }
  35.  
  36. - _task_barrier_exit.wait();
  37. + //_task_barrier_exit.wait();
  38. }
  39.  
  40. //! Shared variables for the worker threads
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement