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
|
/*
* Copyright 2005-2010, Hugo Santos <hugo@fivebits.net>
* Distributed under the terms of the MIT License.
*/
#ifndef _dbeacon_h_
#define _dbeacon_h_
#if __FreeBSD_version <= 500042
#include <inttypes.h>
#else
#include <stdint.h>
#endif
#include <string>
#include <map>
#include "address.h"
struct Stats {
Stats();
uint64_t timestamp, lastupdate;
float avgdelay, avgjitter, avgloss, avgdup, avgooo;
bool valid;
uint8_t rttl;
void check_validity(uint64_t);
};
struct beaconExternalStats {
beaconExternalStats();
uint64_t lastupdate;
uint32_t age;
Stats ASM, SSM;
bool identified;
std::string name, contact;
};
struct beaconMcastState {
beaconMcastState();
uint32_t lastseq;
uint32_t packetcount, packetcountreal;
uint32_t pointer;
int lastdelay, lastjitter, lastloss, lastdup, lastooo;
Stats s;
#define PACKETS_PERIOD 40
#define PACKETS_VERY_OLD 150
uint32_t cacheseqnum[PACKETS_PERIOD+1];
void refresh(uint32_t, uint64_t);
void update(uint8_t, uint32_t, uint64_t, uint64_t, uint64_t);
};
typedef std::map<int, std::string> WebSites;
struct beaconSource {
beaconSource();
address addr;
uint64_t creation;
int sttl;
uint64_t lastevent;
uint64_t lastlocalevent;
beaconMcastState ASM, SSM;
void setName(const std::string &);
void update(uint8_t, uint32_t, uint64_t, uint64_t, uint64_t, bool);
beaconExternalStats &getExternal(const address &, uint64_t now, uint64_t ts);
bool rxlocal(uint64_t now) const;
std::string name;
std::string adminContact;
std::string CC;
uint32_t Flags;
typedef std::map<address, beaconExternalStats> ExternalSources;
ExternalSources externalSources;
WebSites webSites;
bool identified;
};
typedef std::map<address, beaconSource> Sources;
beaconSource &getSource(const address &, const char *name, uint64_t now, uint64_t recvts, bool rxlocal);
void removeSource(const address &, bool);
uint64_t get_timestamp();
uint64_t get_time_of_day();
int SetupSSMPing();
extern const char * const defaultPort;
extern const int defaultTTL;
extern int forceFamily;
extern int mcastInterface;
struct beaconExternalStats;
extern uint32_t flags;
extern std::string beaconName, adminContact, twoLetterCC;
extern Sources sources;
extern WebSites webSites;
extern address beaconUnicastAddr;
extern int verbose;
void info(const char *format, ...);
void fatal(const char *format, ...);
address get_local_address_for(const address &);
void d_log(int level, const char *format, ...);
int dbeacon_daemonize(const char *pidfile);
struct Message {
address from, to;
uint64_t timestamp;
int ttl;
uint8_t *buffer;
size_t len;
};
typedef void (*SocketHandler)(int socket, const Message &);
void ListenTo(int sock, SocketHandler);
#endif
|
