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
|
/*
* Ivy perf mesure le temp de round trip
*
* Copyright (C) 1997-2004
* Centre d'Études de la Navigation Aérienne
*
* Main and only file
*
* Authors: François-Régis Colin <fcolin@cena.fr>
* Yannick Jestin <jestin@cena.fr>
*
* Please refer to file version.h for the
* copyright notice regarding this software
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#ifdef WIN32
#include <windows.h>
#ifdef __MINGW32__
#include <regex.h>
#include <getopt.h>
#endif
#else
#include <time.h>
#include <unistd.h>
#ifdef __INTERIX
extern char *optarg;
extern int optind;
#endif
#endif
#include "ivy.h"
#include "timer.h"
#include "ivyloop.h"
#define MILLISEC 1000.0
//const char* IVY_ADDR = "127.0.0.255";
const char* IVY_ADDR = "192.168.1.255";
//const char* IVY_ADDR = "10.33.39.255";
const char* IVY_PORT = "2023";
const char * me = "A";
const char * other = "B";
char ready_message[1000] = "A ready";
char ready_bind[1000] = "^B ready";
void Ready (IvyClientPtr app, void *user_data, int argc, char *argv[])
{
const char *name = IvyGetApplicationName( app );
int count = IvySendMsg ("are you there %s",name);
printf("Application %s received '%s' from %s sent question 'are you there %s'= %d\n", me, ready_bind, name, name, count);
}
void Question (IvyClientPtr app, void *user_data, int argc, char *argv[])
{
const char *name = IvyGetApplicationName( app );
int count = IvySendMsg ("yes i am %s",me);
printf("Application %s Reply to %s are you there = %d\n", me, name, count);
}
void Reply (IvyClientPtr app, void *user_data, int argc, char *argv[])
{
const char *name = IvyGetApplicationName( app );
printf("Application %s Reply to our question! %s\n", name, argv[0]);
}
void binCB( IvyClientPtr app, void *user_data, int id, const char* regexp, IvyBindEvent event )
{
const char *app_name = IvyGetApplicationName( app );
switch ( event )
{
case IvyAddBind:
printf("%s receive Application:%s bind '%s' ADDED\n", me, app_name, regexp );
//if ( *me == 'A' ) usleep( 200000 ); // slowdown sending of regexp
break;
case IvyRemoveBind:
printf("%s receive Application:%s bind '%s' REMOVED\n", me, app_name, regexp );
break;
case IvyChangeBind:
printf("%s receive Application:%s bind '%s' CHANGED\n", me, app_name, regexp );
break;
case IvyFilterBind:
printf("%s receive Application:%s bind '%s' FILTRED\n", me, app_name, regexp );
break;
}
}
int main(int argc, char *argv[])
{
/* Mainloop management */
if ( argc > 1 )
{
me = "B";
other = "A";
#ifdef WIN32
strcpy_s( ready_message, sizeof(ready_message), "B ready");
strcpy_s( ready_bind, sizeof(ready_bind), "^A ready");
#else
strcpy(ready_message, "B ready");
strcpy(ready_bind, "^A ready");
#endif
}
IvyInit (me, ready_message, NULL,NULL,NULL,NULL);
IvySetBindCallback( binCB, 0 );
#ifdef WIN32
IvyBindMsg(Ready, NULL, ready_bind);
#else
#if defined(__GNUC__) && __GNUC_PREREQ(4,7)
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wformat-security"
#endif
IvyBindMsg (Ready, NULL, ready_bind);
#if defined(__GNUC__) && __GNUC_PREREQ(4,7)
#pragma GCC diagnostic pop
#endif
#endif
IvyBindMsg (Question, NULL, "^are you there %s",me);
IvyBindMsg (Reply, NULL, "^(yes i am %s)",other);
//IvyStart (NULL);
char domain[30];
snprintf(domain, sizeof(domain), "%s:%s", IVY_ADDR, IVY_PORT);
IvyStart (domain);
IvyMainLoop ();
return 0;
}
|
