Skip to content

Commit 6eae174

Browse files
committed
input, zmq: Restore systemevent sub
Subscribe to system events.
1 parent 22b8698 commit 6eae174

File tree

2 files changed

+14
-4
lines changed

2 files changed

+14
-4
lines changed

metadata_input_zeromq.c

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -337,7 +337,8 @@ static uint8_t md_input_zeromq_config(struct md_input_zeromq *miz)
337337

338338
if (((miz->md_zmq_mask & META_TYPE_INTERFACE) ||
339339
(miz->md_zmq_mask & META_TYPE_POS) ||
340-
(miz->md_zmq_mask & META_TYPE_RADIO)) &&
340+
(miz->md_zmq_mask & META_TYPE_RADIO) ||
341+
(miz->md_zmq_mask & META_TYPE_SYSTEM)) &&
341342
zmq_connect(miz->zmq_socket, "ipc:///tmp/nl_pub") == -1)
342343
{
343344
META_PRINT_SYSLOG(miz->parent, LOG_ERR, "Can't connect to NL ZMQ publisher\n");
@@ -351,14 +352,21 @@ static uint8_t md_input_zeromq_config(struct md_input_zeromq *miz)
351352
return RETVAL_FAILURE;
352353
}
353354

354-
if (miz->md_zmq_mask & META_TYPE_INTERFACE)
355+
if (miz->md_zmq_mask & META_TYPE_INTERFACE) {
355356
subscribe_for_topic(ZMQ_NL_INTERFACE_TOPIC, miz);
357+
}
356358

357-
if (miz->md_zmq_mask & META_TYPE_RADIO)
359+
if (miz->md_zmq_mask & META_TYPE_RADIO) {
358360
subscribe_for_topic(ZMQ_NL_RADIOEVENT_TOPIC, miz);
361+
}
359362

360-
if (miz->md_zmq_mask & META_TYPE_POS)
363+
if (miz->md_zmq_mask & META_TYPE_POS) {
361364
subscribe_for_topic(ZMQ_NL_GPS_TOPIC, miz);
365+
}
366+
367+
if (miz->md_zmq_mask & META_TYPE_SYSTEM) {
368+
subscribe_for_topic(ZMQ_NL_SYSTEMEVENT_TOPIC, miz);
369+
}
362370

363371
if (miz->md_zmq_mask & META_TYPE_CONNECTION) {
364372
subscribe_for_topic(ZMQ_DLB_METADATA_TOPIC, miz);

metadata_input_zeromq.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,8 @@
3333

3434
#define ZMQ_NL_GPS_TOPIC "CELERWAY.NL.GPS"
3535

36+
#define ZMQ_NL_SYSTEMEVENT_TOPIC "CELERWAY.NL.SYSTEMEVENT"
37+
3638
#define ZMQ_DLB_METADATA_TOPIC "CELERWAY.DLB.METADATA"
3739

3840
#define ZMQ_DLB_DATAUSAGE_TOPIC "CELERWAY.DLB.DATAUSAGE"

0 commit comments

Comments
 (0)