summaryrefslogtreecommitdiff
path: root/gr-zeromq/lib/pub_sink_impl.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gr-zeromq/lib/pub_sink_impl.cc')
-rw-r--r--gr-zeromq/lib/pub_sink_impl.cc4
1 files changed, 3 insertions, 1 deletions
diff --git a/gr-zeromq/lib/pub_sink_impl.cc b/gr-zeromq/lib/pub_sink_impl.cc
index 9cd115da79..3a86819fb3 100644
--- a/gr-zeromq/lib/pub_sink_impl.cc
+++ b/gr-zeromq/lib/pub_sink_impl.cc
@@ -34,7 +34,7 @@ namespace gr {
pub_sink::make(size_t itemsize, size_t vlen, char *address, bool blocking)
{
return gnuradio::get_initial_sptr
- (new pub_sink_impl(itemsize, vlen, address, blocking));
+ (new pub_sink_impl(itemsize, vlen, address, blocking));
}
pub_sink_impl::pub_sink_impl(size_t itemsize, size_t vlen, char *address, bool blocking)
@@ -52,6 +52,8 @@ namespace gr {
pub_sink_impl::~pub_sink_impl()
{
+ d_socket->close();
+ d_context->close();
delete d_socket;
delete d_context;
}