parent
5f58307153
commit
7666d99694
|
@ -190,7 +190,6 @@ selfdrive/common/util.[c,h]
|
|||
selfdrive/common/efd.[c,h]
|
||||
selfdrive/common/cqueue.[c,h]
|
||||
selfdrive/common/clutil.[c,h]
|
||||
selfdrive/common/messaging.h
|
||||
selfdrive/common/params.h
|
||||
selfdrive/common/params.cc
|
||||
selfdrive/common/mutex.h
|
||||
|
|
|
@ -18,7 +18,6 @@
|
|||
#include "cereal/gen/cpp/car.capnp.h"
|
||||
|
||||
#include "common/util.h"
|
||||
#include "common/messaging.h"
|
||||
#include "common/params.h"
|
||||
#include "common/swaglog.h"
|
||||
#include "common/timing.h"
|
||||
|
|
|
@ -1,15 +0,0 @@
|
|||
// the c version of cereal/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;
|
||||
}
|
||||
|
|
@ -8,7 +8,6 @@
|
|||
#include "json11.hpp"
|
||||
|
||||
#include "common/swaglog.h"
|
||||
#include "common/messaging.h"
|
||||
#include "common/params.h"
|
||||
#include "common/timing.h"
|
||||
|
||||
|
|
Loading…
Reference in New Issue