2 This file is part of GNUnet.
3 Copyright (C) 2009-2016 GNUnet e.V.
5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published
7 by the Free Software Foundation, either version 3 of the License,
8 or (at your option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details.
15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>.
18 SPDX-License-Identifier: AGPL3.0-or-later
22 * @file dht/gnunet-service-dht.h
23 * @brief GNUnet DHT globals
24 * @author Christian Grothoff
26 #ifndef GNUNET_SERVICE_DHT_H
27 #define GNUNET_SERVICE_DHT_H
29 #include "gnunet_util_lib.h"
30 #include "gnunet_statistics_service.h"
31 #include "gnunet_transport_service.h"
32 #include "gnunet_block_lib.h"
34 #define DEBUG_DHT GNUNET_EXTRA_LOGGING
37 * Configuration we use.
39 extern const struct GNUNET_CONFIGURATION_Handle *GDS_cfg;
42 * Handle for the service.
44 extern struct GNUNET_SERVICE_Handle *GDS_service;
47 * Our handle to the BLOCK library.
49 extern struct GNUNET_BLOCK_Context *GDS_block_context;
52 * Handle for the statistics service.
54 extern struct GNUNET_STATISTICS_Handle *GDS_stats;
59 extern struct GNUNET_MessageHeader *GDS_my_hello;
63 * Handle a reply we've received from another peer. If the reply
64 * matches any of our pending queries, forward it to the respective
67 * @param expiration when will the reply expire
68 * @param key the query this reply is for
69 * @param get_path_length number of peers in @a get_path
70 * @param get_path path the reply took on get
71 * @param put_path_length number of peers in @a put_path
72 * @param put_path path the reply took on put
73 * @param type type of the reply
74 * @param data_size number of bytes in @a data
75 * @param data application payload data
78 GDS_CLIENTS_handle_reply (struct GNUNET_TIME_Absolute expiration,
79 const struct GNUNET_HashCode *key,
80 unsigned int get_path_length,
81 const struct GNUNET_PeerIdentity *get_path,
82 unsigned int put_path_length,
83 const struct GNUNET_PeerIdentity *put_path,
84 enum GNUNET_BLOCK_Type type,
90 * Check if some client is monitoring GET messages and notify
93 * @param options Options, for instance RecordRoute, DemultiplexEverywhere.
94 * @param type The type of data in the request.
95 * @param hop_count Hop count so far.
96 * @param path_length number of entries in path (or 0 if not recorded).
97 * @param path peers on the GET path (or NULL if not recorded).
98 * @param desired_replication_level Desired replication level.
99 * @param key Key of the requested data.
102 GDS_CLIENTS_process_get (uint32_t options,
103 enum GNUNET_BLOCK_Type type,
105 uint32_t desired_replication_level,
106 unsigned int path_length,
107 const struct GNUNET_PeerIdentity *path,
108 const struct GNUNET_HashCode *key);
112 * Check if some client is monitoring GET RESP messages and notify
115 * @param type The type of data in the result.
116 * @param get_path Peers on GET path (or NULL if not recorded).
117 * @param get_path_length number of entries in @a get_path.
118 * @param put_path peers on the PUT path (or NULL if not recorded).
119 * @param put_path_length number of entries in @a get_path.
120 * @param exp Expiration time of the data.
121 * @param key Key of the @a data.
122 * @param data Pointer to the result data.
123 * @param size Number of bytes in @a data.
126 GDS_CLIENTS_process_get_resp (enum GNUNET_BLOCK_Type type,
127 const struct GNUNET_PeerIdentity *get_path,
128 unsigned int get_path_length,
129 const struct GNUNET_PeerIdentity *put_path,
130 unsigned int put_path_length,
131 struct GNUNET_TIME_Absolute exp,
132 const struct GNUNET_HashCode *key,
138 * Check if some client is monitoring PUT messages and notify
141 * @param options Options, for instance RecordRoute, DemultiplexEverywhere.
142 * @param type The type of data in the request.
143 * @param hop_count Hop count so far.
144 * @param path_length number of entries in path (or 0 if not recorded).
145 * @param path peers on the PUT path (or NULL if not recorded).
146 * @param desired_replication_level Desired replication level.
147 * @param exp Expiration time of the data.
148 * @param key Key under which data is to be stored.
149 * @param data Pointer to the data carried.
150 * @param size Number of bytes in data.
153 GDS_CLIENTS_process_put (uint32_t options,
154 enum GNUNET_BLOCK_Type type,
156 uint32_t desired_replication_level,
157 unsigned int path_length,
158 const struct GNUNET_PeerIdentity *path,
159 struct GNUNET_TIME_Absolute exp,
160 const struct GNUNET_HashCode *key,