Add receive_all() function to connections, replaces {,try_}receive()
* replace tbb::concurrent_queue by std::vector and mutex because the concurrent queue does not support thread-safe swap * allows fast acquisition of _all_ messages from the connection * in the typical use case of sending, waiting until halt and receiving this leads to less time spend with exclusive access to the connection and therefore more possible parallelism * remove single-message receive() and try_receive() interface Depends-On: 11113 Change-Id: Ifd6cebfcea3b9bc56699aaf9db741579ca074a81
Showing
- example/hxcomm_loopback_throughput.cpp 1 addition, 3 deletionsexample/hxcomm_loopback_throughput.cpp
- example/reset_and_id_readout.h 1 addition, 2 deletionsexample/reset_and_id_readout.h
- include/hxcomm/common/arqconnection.h 7 additions, 14 deletionsinclude/hxcomm/common/arqconnection.h
- include/hxcomm/common/arqconnection.tcc 14 additions, 14 deletionsinclude/hxcomm/common/arqconnection.tcc
- include/hxcomm/common/decoder.tcc 21 additions, 1 deletioninclude/hxcomm/common/decoder.tcc
- include/hxcomm/common/execute_messages.h 2 additions, 7 deletionsinclude/hxcomm/common/execute_messages.h
- include/hxcomm/common/loopbackconnection.h 7 additions, 13 deletionsinclude/hxcomm/common/loopbackconnection.h
- include/hxcomm/common/loopbackconnection.tcc 12 additions, 14 deletionsinclude/hxcomm/common/loopbackconnection.tcc
- include/hxcomm/common/simconnection.h 7 additions, 13 deletionsinclude/hxcomm/common/simconnection.h
- include/hxcomm/common/simconnection.tcc 10 additions, 13 deletionsinclude/hxcomm/common/simconnection.tcc
- include/hxcomm/common/stream.h 12 additions, 7 deletionsinclude/hxcomm/common/stream.h
- tests/hw/hxcomm/test-connection.cpp 4 additions, 31 deletionstests/hw/hxcomm/test-connection.cpp
- tests/hw/hxcomm/test-halt.cpp 3 additions, 1 deletiontests/hw/hxcomm/test-halt.cpp
- tests/hw/hxcomm/test-jtag_loopback.cpp 1 addition, 5 deletionstests/hw/hxcomm/test-jtag_loopback.cpp
- tests/hw/hxcomm/test-readout_jtag_id.cpp 1 addition, 7 deletionstests/hw/hxcomm/test-readout_jtag_id.cpp
- tests/hw/hxcomm/test-tick.cpp 4 additions, 2 deletionstests/hw/hxcomm/test-tick.cpp
- tests/sw/hxcomm/test-encode_decode_throughput.cpp 2 additions, 0 deletionstests/sw/hxcomm/test-encode_decode_throughput.cpp
- tests/sw/hxcomm/test-loopbackconnection.cpp 17 additions, 7 deletionstests/sw/hxcomm/test-loopbackconnection.cpp
- wscript 1 addition, 2 deletionswscript
Please register or sign in to comment