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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
|
// oscbndlsend.c - test program to send OSC bundles
//
// this test is designed to run with either oscbndlrecv.c or lo_bndlrecv.c
// We'll send 5 bundles:
// at NOW+2.9: [/xyz/msg1 1009 "an arbitrary string at 2.9"],
// [/abcdefg/msg2 2009 "another arbitrary string at 2.9"]
// at NOW+2.8: [/xyz/msg1 1008 "an arbitrary string at 2.8"],
// [/abcdefg/msg2 2008 "another arbitrary string at 2.8"]
// at NOW+2.7: [/xyz/msg1 1007 "an arbitrary string at 2.7"],
// [/abcdefg/msg2 2007 "another arbitrary string at 2.7"]
// at NOW+2.6: [/xyz/msg1 1006 "an arbitrary string at 2.6"],
// [/abcdefg/msg2 2006 "another arbitrary string at 2.6"]
// at NOW+2.5: [/xyz/msg1 1005 "an arbitrary string at 2.5"],
// [/abcdefg/msg2 2005 "another arbitrary string at 2.5"]
// Then we'll send a nested bundle:
// at NOW+3: [/first 1111 "an arbitrary string at 3.0"],
// [#bundle NOW+3.1
// [/xyz/msg1 1011 "an arbitrary string at 3.1"],
// [/abcdefg/msg2 2011 "another arbitrary string at 3.1"]]
#include "o2.h"
#include "stdio.h"
#include "string.h"
#include "assert.h"
#ifdef WIN32
#include "usleep.h" // special windows implementation of sleep/usleep
#else
#include <unistd.h>
#endif
o2_message_ptr make_message(o2_time time, char *address, int i, char *s)
{
o2_send_start();
o2_add_int32(i);
o2_add_string(s);
// add the message to the bundle
return o2_message_finish(time, address, FALSE);
}
o2_message_ptr bundle2(o2_time time, o2_message_ptr m1, o2_message_ptr m2)
{
o2_send_start();
o2_add_message(m1);
o2_message_free(m1);
o2_add_message(m2);
o2_message_free(m2);
return o2_service_message_finish(time, "oscsend", "", FALSE);
}
void send_nested(o2_time now, o2_time touter, o2_time tinner, int base)
{
char s[128];
// make first message
sprintf(s, "first string at %g", touter);
o2_message_ptr out1 = make_message(now + touter, "/oscsend/first",
base + 1, s);
// make first inner message
sprintf(s, "msg1 string at %g", tinner);
o2_message_ptr in1 = make_message(now + tinner, "/oscsend/xyz/msg1",
base + 2, s);
// make second inner message
// use timestamp of 0, should deliver at max(touter, tinner) because
// of containing bundle
sprintf(s, "msg2 string at %g", tinner);
o2_message_ptr in2 = make_message(0.0, "/oscsend/abcdefg/msg2",
base + 3, s);
// make inner bundle
o2_message_ptr inner = bundle2(now + tinner, in1, in2);
// make outer bundle
o2_message_ptr outer = bundle2(now + touter, out1, inner);
// send it
o2_message_send(outer);
}
int main(int argc, const char * argv[])
{
printf("Usage: oscbndlrecv flags (see o2.h for flags, "
"use a for all, also u for UDP, M for master)\n");
int tcpflag = TRUE;
int master = FALSE;
if (argc == 2) {
o2_debug_flags(argv[1]);
tcpflag = (strchr(argv[1], 'u') == NULL);
master = (strchr(argv[1], 'M') != NULL);
}
if (argc > 2) {
printf("WARNING: o2server ignoring extra command line argments\n");
}
printf("tcpflag %d master %d\n", tcpflag, master);
o2_initialize("test");
// you can make this run without an O2 server by passing "master"
if (master)
o2_clock_set(NULL, NULL);
if (master) sleep(2); // wait for liblo server to come up if we are master
char s[128];
printf("Waiting for clock sync\n");
while (!o2_clock_is_synchronized) {
usleep(2000);
o2_poll();
}
int err = o2_osc_delegate("oscsend", "localhost", 8100, tcpflag);
assert(err == O2_SUCCESS);
printf("connected to port 8100\n");
o2_time now = o2_time_get();
printf("Sending simple message\n");
o2_send("/oscsend/test", 0.0, NULL);
printf("Sending messages\n");
for (int i = 9; i >= 5; i--) {
// make the bundle
o2_send_start();
// make first message
sprintf(s, "an arbitrary string at 2.%d", i);
o2_message_ptr msg1 = make_message(0.0, "/oscsend/xyz/msg1",
1000 + i, s);
// make second message
sprintf(s, "another arbitrary string at 2.%d", i);
o2_message_ptr msg2 = make_message(0.0, "/oscsend/abcdefg/msg2",
2000 + i, s);
// add the messages to the bundle
o2_send_start();
o2_add_message(msg1);
o2_message_free(msg1);
o2_add_message(msg2);
o2_message_free(msg2);
o2_message_ptr msg = o2_service_message_finish(now + 2 + i * 0.1,
"oscsend", "", FALSE);
// send it
o2_message_send(msg);
}
// now send nested bundles
// this tests timestamps on inner bundles, trying both 0 and a time:
// [@3.0 /first [@0 /msg1 /msg2]] -- should deliver all at 3.0
// [@3.1 /first [@3.2 /msg1 /msg2]] -- should dliever msg1, msg2 at 3.2
send_nested(now, 3.0, 0.0, 3000);
send_nested(now, 3.1, 3.2, 4000);
printf("after sending\n");
sleep(1); // if you exit() after send(), data might be lost
printf("removing oscsend\n");
o2_service_free("oscsend");
printf("calling o2_finish()\n");
o2_finish();
printf("sleep(1)\n");
sleep(1); // clean up sockets
printf("OSCSEND DONE\n");
return 0;
}
|
