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
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
|
/*
This file is part of GNUnet.
(C) 2006 - 2009 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 2, 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 src/dht/plugin_dhtlog_dummy.c
* @brief Dummy logging plugin to test logging calls
* @author Nathan Evans
*
* Database: NONE
*/
#include "platform.h"
#include "gnunet_util_lib.h"
#include "dhtlog.h"
#define DEBUG_DHTLOG GNUNET_NO
/*
* Inserts the specified trial into the dhttests.trials table
*
* @param trialuid return the trialuid of the newly inserted trial
* @param num_nodes how many nodes are in the trial
* @param topology integer representing topology for this trial
* @param blacklist_topology integer representing blacklist topology for this trial
* @param connect_topology integer representing connect topology for this trial
* @param connect_topology_option integer representing connect topology option
* @param connect_topology_option_modifier float to modify connect option
* @param topology_percentage percentage modifier for certain topologies
* @param topology_probability probability modifier for certain topologies
* @param puts number of puts to perform
* @param gets number of gets to perform
* @param concurrent number of concurrent requests
* @param settle_time time to wait between creating topology and starting testing
* @param num_rounds number of times to repeat the trial
* @param malicious_getters number of malicious GET peers in the trial
* @param malicious_putters number of malicious PUT peers in the trial
* @param malicious_droppers number of malicious DROP peers in the trial
* @param message string to put into DB for this trial
*
* @return GNUNET_OK on success, GNUNET_SYSERR on failure
*/
int
add_trial (unsigned long long *trialuid, int num_nodes, int topology,
int blacklist_topology, int connect_topology,
int connect_topology_option, float connect_topology_option_modifier,
float topology_percentage, float topology_probability,
int puts, int gets, int concurrent, int settle_time,
int num_rounds, int malicious_getters, int malicious_putters,
int malicious_droppers, char *message)
{
*trialuid = 42;
return GNUNET_OK;
}
/*
* Inserts the specified dhtkey into the dhttests.dhtkeys table,
* stores return value of dhttests.dhtkeys.dhtkeyuid into dhtkeyuid
*
* @param dhtkeyuid return value
* @param dhtkey hashcode of key to insert
*
* @return GNUNET_OK on success, GNUNET_SYSERR on failure
*/
int
add_dhtkey (unsigned long long *dhtkeyuid, const GNUNET_HashCode * dhtkey)
{
*dhtkeyuid = 1171;
return GNUNET_OK;
}
/*
* Inserts the specified node into the dhttests.nodes table
*
* @param nodeuid the inserted node uid
* @param node the node to insert
*
* @return GNUNET_OK on success, GNUNET_SYSERR on failure
*/
int
add_node (unsigned long long *nodeuid, struct GNUNET_PeerIdentity * node)
{
*nodeuid = 1337;
return GNUNET_OK;
}
/*
* Update dhttests.trials table with current server time as end time
*
* @param trialuid trial to update
* @param totalMessagesDropped stats value for messages dropped
* @param totalBytesDropped stats value for total bytes dropped
* @param unknownPeers stats value for unknown peers
*
* @return GNUNET_OK on success, GNUNET_SYSERR on failure.
*/
int
update_trials (unsigned long long trialuid,
unsigned long long totalMessagesDropped,
unsigned long long totalBytesDropped,
unsigned long long unknownPeers)
{
return GNUNET_OK;
}
/*
* Update dhttests.trials table with total connections information
*
* @param trialuid the trialuid to update
* @param totalConnections the number of connections
*
* @return GNUNET_OK on success, GNUNET_SYSERR on failure.
*/
int
add_connections (unsigned long long trialuid, unsigned int totalConnections)
{
return GNUNET_OK;
}
/*
* Inserts the specified query into the dhttests.queries table
*
* @param sqlqueruid inserted query uid
* @param queryid dht query id
* @param type type of the query
* @param hops number of hops query traveled
* @param succeeded whether or not query was successful
* @param node the node the query hit
* @param key the key of the query
*
* @return GNUNET_OK on success, GNUNET_SYSERR on failure.
*/
int
add_query (unsigned long long *sqlqueryuid, unsigned long long queryid,
unsigned int type, unsigned int hops, int succeeded,
const struct GNUNET_PeerIdentity * node, const GNUNET_HashCode * key)
{
*sqlqueryuid = 17;
return GNUNET_OK;
}
/*
* Inserts the specified route information into the dhttests.routes table
*
* @param sqlqueruid inserted query uid
* @param queryid dht query id
* @param type type of the query
* @param hops number of hops query traveled
* @param succeeded whether or not query was successful
* @param node the node the query hit
* @param key the key of the query
* @param from_node the node that sent the message to node
* @param to_node next node to forward message to
*
* @return GNUNET_OK on success, GNUNET_SYSERR on failure.
*/
int
add_route (unsigned long long *sqlqueryuid, unsigned long long queryid,
unsigned int type, unsigned int hops,
int succeeded, const struct GNUNET_PeerIdentity * node,
const GNUNET_HashCode * key, const struct GNUNET_PeerIdentity * from_node,
const struct GNUNET_PeerIdentity * to_node)
{
*sqlqueryuid = 18;
return GNUNET_OK;
}
/*
* Provides the dhtlog api
*
* @param c the configuration to use to connect to a server
*
* @return the handle to the server, or NULL on error
*/
void *
libgnunet_plugin_dhtlog_dummy_init (void * cls)
{
struct GNUNET_DHTLOG_Plugin *plugin = cls;
#if DEBUG_DHTLOG
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "DUMMY DHT Logger: initializing.\n");
#endif
GNUNET_assert(plugin->dhtlog_api == NULL);
plugin->dhtlog_api = GNUNET_malloc(sizeof(struct GNUNET_DHTLOG_Handle));
plugin->dhtlog_api->insert_trial = &add_trial;
plugin->dhtlog_api->insert_query = &add_query;
plugin->dhtlog_api->update_trial = &update_trials;
plugin->dhtlog_api->insert_route = &add_route;
plugin->dhtlog_api->insert_node = &add_node;
plugin->dhtlog_api->insert_dhtkey = &add_dhtkey;
plugin->dhtlog_api->update_connections = &add_connections;
return NULL;
}
/**
* Shutdown the plugin.
*/
void *
libgnunet_plugin_dhtlog_dummy_done (void * cls)
{
#if DEBUG_DHTLOG
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"DUMMY DHT Logger: shutdown\n");
#endif
return NULL;
}
/* end of plugin_dhtlog_dummy.c */
|
