summaryrefslogtreecommitdiff
path: root/gr-zeromq/lib/pull_msg_source_impl.cc
Commit message (Collapse)AuthorAgeFilesLines
* zeromq: replace ::bind with lambdaMarcus Müller2021-03-201-2/+1
| | | | Signed-off-by: Marcus Müller <mmueller@gnuradio.org>
* fixup! zeromq: Fix warnings with recv()Martin Braun2021-02-151-2/+2
| | | | Signed-off-by: Martin Braun <martin@gnuradio.org>
* zeromq: Fix warnings with recv()Martin Braun2021-02-151-4/+12
| | | | | | | | The recv() call on a ZMQ socket produces a warning if the return value is not stored. We follow the advice and check the return value, just in case. Signed-off-by: Martin Braun <martin.braun@ettus.com>
* C++14: Use std::make_unique instead of boost::make_uniqueMarcus Müller2021-01-041-2/+2
| | | | | | Also, clean up includes Signed-off-by: Marcus Müller <mmueller@gnuradio.org>
* zeromq: Remove manual memory managementThomas Habets2020-09-221-16/+12
| | | | | I believe this fixes a memory leak, as the thread objects were never deleted.
* Replace all calls to `get_initial_sptr` with `make_block_sptr`Thomas Habets2020-07-301-1/+1
| | | | | | | | | | | | | | First batch of changes: ``` find […] -print0 | xargs -0 sed -i -r '/get_initial_sptr/{:nxt N;/;/!b nxt;s/get_initial_sptr\(\s*new ([^(]+)(.*)\)\)/make_block_sptr<\1>\2)/}' ``` Then: * Back out `sptr_magic.h` edits * Change some `friend` clauses * clang-format the whole thing * Update checksums in the pybind11 bindings files
* zeromq: Add bind argument for message based zeromq blocks.Jacob Gilbert2020-04-101-4/+9
| | | | | | This is needed to support N:1 patterns. To avoid confusion, since this is probably a feature only needed by those who Know What They Are Doing, the option is added to the Advanced block property tab.
* zmq: Handle the PMT exceptionsVasil Velichkov2020-03-101-2/+6
| | | | | | | | | | | Handle the PMT exceptions when deserializing the received ZMQ messages, log an error message and continue the execution. Previously the unhandled exceptions were aborting the process: terminate called after throwing an instance of 'pmt::exception' what(): pmt::deserialize: malformed input stream, tag value = : 50 Aborted (core dumped)
* Update license header to SPDX formatdevnulling2020-01-271-13/+1
|
* clang-format: Ordering all the includesMarcus Müller2019-08-091-3/+3
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | clang-format: ordering includes in gnuradio-runtime clang-format: ordering includes in gr-filter clang-format: ordering includes in gr-fft clang-format: ordering includes in gr-audio clang-format: ordering includes in gr-analog clang-format: ordering includes in gr-fec clang-format: ordering includes in gr-wavelet clang-format: ordering includes in gr-zeromq clang-format: ordering includes in gr-vocoder clang-format: ordering includes in gr-video-sdl clang-format: ordering includes in gr-trellis clang-format: ordering includes in gr-blocks clang-format: ordering includes in gr-digital clang-format: ordering includes in gr-uhd clang-format: ordering includes in gr-dtv clang-format: ordering includes in gr-channels clang-format: ordering includes in gr-qtgui clang_format.py: re-enable include reordering
* Tree: clang-format without the include sortingMarcus Müller2019-08-091-58/+56
|
* zeromq: fixes to allow building using CPPZMQ 4.3.1 as well as priorMichael Dickens2019-06-151-1/+5
| | | | CPPZMQ deprecated some prototypes of "recv" and "send" in some version prior to 4.3.1. The "recv" one will be removed in 4.3.1 and thus will generate an error since no valid prototype exists in the way "recv" is currently being call. This fix updates our usage of both calls to work with the "new" and "old" ways, depending on the CPPZMQ version. Move the CPPZMQ header inclusion and a macro determine which version to use into a common local header.
* zeromq: remove unnecessary call to pmt::intern at runtimeMarcus Müller2018-02-231-3/+4
| | | | | | | | | | | | | | typical usage: message_port_pub(pmt::mp("out_port"), …) which is bad, as it implies hashing of a string, allocation of memory, deallocation, finding the hashed string in the table of interned strings and returning a unique pointer (which for reasons of PMT awesomeness isn't even unique) to the interned port name. Replacing all these port name ad hoc ::mp() calls by reusing one, private, port name member.
* gr-zmq: Fix build with gcc6.Philip Balister2016-06-281-1/+1
| | | | Signed-off-by: Philip Balister <philip@balister.org>
* MSVC-specific fixes for compatibilitygnieboer2016-05-301-1/+3
| | | | | | | | | | | | | | | | | | | * Changed dtv_viterbi_decoder to use __GR_ATTR_ALIGNED macro for cross-compiler compatibility * Replace usleep() with boost equivalent for cross-compiler compatibility * Includes windows-specific headers for portaudio * Added macro to handle use of VLAs on non-C99 compilers (MSVC) using alloca to declare variable length arrays * Remove setting SO_LINGER option for the UDP source. SO_LINGER is not an applicable option for a UDP socket. Windows will throw an exception if set. Linux allows it to be set but does not use it. * VS 2013+ supports round()
* zeromq: cleanup and made pull_msg_source derive from gr::blockJohnathan Corgan2015-01-121-33/+26
|
* zmq: pull_msg_source should be workingTim O'Shea2014-12-301-43/+41
|
* zmq: building working versions of additional zmq message blocks in place ↵Tim O'Shea2014-12-301-0/+120
(push/pull + rep/req)
generated by cgit v1.2.3 (git 2.39.1) at 2025-03-21 09:15:50 +0000