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
|
// statusclient.c - O2 status/discovery test, client side
//
// see statusserver.c for details
#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
int running = TRUE;
void stop_handler(o2_msg_data_ptr data, const char *types,
o2_arg_ptr *argv, int argc, void *user_data)
{
printf("client received stop message. Bye.\n");
running = FALSE;
}
int main(int argc, const char * argv[])
{
const char *ip = NULL;
int port = 0;
printf("Usage: statusclient [debugflags] [ip port] "
"(see o2.h for flags, use a for all)\n"
" last args, if set, specify a hub to use; if only ip is given,\n"
" o2_hub(NULL, 0) is called to turn off broadcasting\n"
" If port is 0, you will be prompted (allowing you to start first)\n");
if (argc >= 2) {
o2_debug_flags(argv[1]);
printf("debug flags are: %s\n", argv[1]);
}
o2_initialize("test");
if (argc == 3) {
port = 1;
} else if (argc == 4) {
ip = argv[2];
port = atoi(argv[3]);
while (port == 0) {
char input[100];
printf("Port specified as 0, enter new value: ");
port = atoi((const char *) fgets(input, 100, stdin));
}
printf("Using %s:%d as hub.\n", ip, port);
} else if (argc > 4) {
printf("WARNING: statusclient ignoring extra command line argments\n");
}
o2_service_new("client");
o2_method_new("/client/stop", "", &stop_handler, NULL, FALSE, TRUE);
if (port > 0)
o2_hub(ip, port);
const char *address;
int tcp_port;
o2_get_address(&address, &tcp_port);
printf("My address is %s:%d\n", address, tcp_port);
while (running) {
o2_poll();
usleep(2000); // 2ms
}
// exit without calling o2_finish() -- this is a test for behavior when
// the client crashes. Will the server still remove the service?
// o2_finish();
printf("CLIENT DONE\n");
return 0;
}
|
