You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
16 lines
435 B
16 lines
435 B
7 years ago
|
// the c version of selfdrive/messaging.py
|
||
|
|
|
||
|
|
#include <zmq.h>
|
||
|
|
|
||
|
|
// TODO: refactor to take in service instead of endpoint?
|
||
|
|
void *sub_sock(void *ctx, const char *endpoint) {
|
||
|
|
void* sock = zmq_socket(ctx, ZMQ_SUB);
|
||
|
|
assert(sock);
|
||
|
|
zmq_setsockopt(sock, ZMQ_SUBSCRIBE, "", 0);
|
||
|
|
int reconnect_ivl = 500;
|
||
|
|
zmq_setsockopt(sock, ZMQ_RECONNECT_IVL_MAX, &reconnect_ivl, sizeof(reconnect_ivl));
|
||
|
|
zmq_connect(sock, endpoint);
|
||
|
|
return sock;
|
||
|
|
}
|
||
|
|
|