-
Notifications
You must be signed in to change notification settings - Fork 24
/
zmqserv.c
54 lines (43 loc) · 1.19 KB
/
zmqserv.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
#include <lo/lo.h>
#include <zmq.h>
#include <assert.h>
#include <stdlib.h>
#define MAXSZ 1024
lo_server s;
void *publisher;
void error(int num, const char *msg, const char *path) {
printf("liblo server error %d in path %s: %s\n", num, path, msg);
}
/**/
int generic_handler(const char *path, const char *types, lo_arg **argv,
int argc, lo_message msg, void *user_data) {
int i;
int sz = lo_message_length(msg, path);
void *m = lo_message_serialise(msg, path, NULL, NULL);
printf("message\n");
zmq_send(publisher, m, sz, 0);
free(m);
return 1;
}
void osc_init() {
s = lo_server_new("7777", error);
lo_server_add_method(s, NULL, NULL, generic_handler, NULL);
}
int main (void) {
// Prepare our context and publisher
void *context = zmq_ctx_new ();
publisher = zmq_socket (context, ZMQ_PUB);
int rc = zmq_bind (publisher, "tcp://*:5556");
void *osc[MAXSZ];
assert (rc == 0);
rc = zmq_bind(publisher, "ipc://dirt.ipc");
assert (rc == 0);
osc_init();
while (1) {
int sz = lo_server_recv(s);
//printf("processed message of size %d\n", sz);
}
zmq_close (publisher);
zmq_ctx_destroy (context);
return 0;
}