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
|
/*
This file is part of GNUnet.
(C) 2011 Christian Grothoff (and other contributing authors)
GNUnet is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published
by the Free Software Foundation; either version 3, or (at your
option) any later version.
GNUnet is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
General Public License for more details.
You should have received a copy of the GNU General Public License
along with GNUnet; see the file COPYING. If not, write to the
Free Software Foundation, Inc., 59 Temple Place - Suite 330,
Boston, MA 02111-1307, USA.
*/
/**
* @file ats/gnunet-service-ats_performance.h
* @brief ats service, interaction with 'performance' API
* @author Matthias Wachs
* @author Christian Grothoff
*/
#ifndef GNUNET_SERVICE_ATS_PERFORMANCE_H
#define GNUNET_SERVICE_ATS_PERFORMANCE_H
#include "gnunet_util_lib.h"
#include "gnunet_ats_service.h"
#include "ats.h"
/**
* Register a new performance client.
*
* @param client handle of the new client
* @param flag flag specifying the type of the client
*/
void
GAS_performance_add_client (struct GNUNET_SERVER_Client *client,
enum StartFlag flag);
/**
* Unregister a client (which may have been a performance client,
* but this is not assured).
*
* @param client handle of the (now dead) client
*/
void
GAS_performance_remove_client (struct GNUNET_SERVER_Client *client);
void
GAS_handle_performance_update (struct GNUNET_PeerIdentity *peer,
const char *plugin_name,
const void *plugin_addr,
size_t plugin_addr_len,
const int active,
struct GNUNET_ATS_Information *ats,
uint32_t ats_count,
struct GNUNET_BANDWIDTH_Value32NBO
bandwidth_out,
struct GNUNET_BANDWIDTH_Value32NBO
bandwidth_in);
/**
* Transmit the given performance information to all performance
* clients.
*
* @param peer peer for which this is an address suggestion
* @param plugin_name 0-termintated string specifying the transport plugin
* @param plugin_addr binary address for the plugin to use
* @param plugin_addr_len number of bytes in plugin_addr
* @param active is this address active
* @param atsi performance data for the address
* @param atsi_count number of performance records in 'ats'
* @param bandwidth_out assigned outbound bandwidth
* @param bandwidth_in assigned inbound bandwidth
*/
void
GAS_performance_notify_all_clients (const struct GNUNET_PeerIdentity *peer,
const char *plugin_name,
const void *plugin_addr, size_t plugin_addr_len,
const int active,
const struct GNUNET_ATS_Information *atsi,
uint32_t atsi_count,
struct GNUNET_BANDWIDTH_Value32NBO
bandwidth_out,
struct GNUNET_BANDWIDTH_Value32NBO
bandwidth_in);
/**
* Handle 'address list request' messages from clients.
*
* @param cls unused, NULL
* @param client client that sent the request
* @param message the request message
*/
void
GAS_handle_request_address_list (void *cls,
struct GNUNET_SERVER_Client *client,
const struct GNUNET_MessageHeader *message);
/**
* Handle 'reservation request' messages from clients.
*
* @param cls unused, NULL
* @param client client that sent the request
* @param message the request message
*/
void
GAS_handle_reservation_request (void *cls,
struct GNUNET_SERVER_Client *client,
const struct GNUNET_MessageHeader *message);
/**
* Handle 'preference change' messages from clients.
*
* @param cls unused, NULL
* @param client client that sent the request
* @param message the request message
*/
void
GAS_handle_preference_change (void *cls,
struct GNUNET_SERVER_Client *client,
const struct GNUNET_MessageHeader *message);
void
GAS_handle_monitor (void *cls,
struct GNUNET_SERVER_Client *client,
const struct GNUNET_MessageHeader *message);
/**
* Initialize performance subsystem.
*
* @param server handle to our server
* @param addresses the address handle to use
*/
void
GAS_performance_init (struct GNUNET_SERVER_Handle *server,
struct GAS_Addresses_Handle *GSA_addresses);
/**
* Shutdown performance subsystem.
*/
void
GAS_performance_done (void);
/* FIXME: add API to broadcast performance updates! */
#endif
/* end of gnunet-service-ats_performance.h */
|
