aboutsummaryrefslogtreecommitdiff
path: root/src/datacache/plugin_datacache_postgres.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/datacache/plugin_datacache_postgres.c')
-rw-r--r--src/datacache/plugin_datacache_postgres.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/datacache/plugin_datacache_postgres.c b/src/datacache/plugin_datacache_postgres.c
index 070619137..6a44c44a5 100644
--- a/src/datacache/plugin_datacache_postgres.c
+++ b/src/datacache/plugin_datacache_postgres.c
@@ -156,7 +156,7 @@ postgres_plugin_put (void *cls,
156 enum GNUNET_BLOCK_Type type, 156 enum GNUNET_BLOCK_Type type,
157 struct GNUNET_TIME_Absolute discard_time, 157 struct GNUNET_TIME_Absolute discard_time,
158 unsigned int path_info_len, 158 unsigned int path_info_len,
159 const struct GNUNET_PeerIdentity *path_info) 159 const struct GNUNET_DHT_PathElement *path_info)
160{ 160{
161 struct Plugin *plugin = cls; 161 struct Plugin *plugin = cls;
162 uint32_t type32 = (uint32_t) type; 162 uint32_t type32 = (uint32_t) type;
@@ -168,7 +168,7 @@ postgres_plugin_put (void *cls,
168 GNUNET_PQ_query_param_fixed_size (data, data_size), 168 GNUNET_PQ_query_param_fixed_size (data, data_size),
169 GNUNET_PQ_query_param_fixed_size (path_info, 169 GNUNET_PQ_query_param_fixed_size (path_info,
170 path_info_len * sizeof(struct 170 path_info_len * sizeof(struct
171 GNUNET_PeerIdentity)), 171 GNUNET_DHT_PathElement)),
172 GNUNET_PQ_query_param_end 172 GNUNET_PQ_query_param_end
173 }; 173 };
174 enum GNUNET_DB_QueryStatus ret; 174 enum GNUNET_DB_QueryStatus ret;
@@ -227,7 +227,7 @@ handle_results (void *cls,
227 uint32_t type; 227 uint32_t type;
228 void *data; 228 void *data;
229 size_t data_size; 229 size_t data_size;
230 struct GNUNET_PeerIdentity *path; 230 struct GNUNET_DHT_PathElement *path;
231 size_t path_len; 231 size_t path_len;
232 struct GNUNET_PQ_ResultSpec rs[] = { 232 struct GNUNET_PQ_ResultSpec rs[] = {
233 GNUNET_PQ_result_spec_absolute_time ("discard_time", 233 GNUNET_PQ_result_spec_absolute_time ("discard_time",
@@ -251,12 +251,12 @@ handle_results (void *cls,
251 GNUNET_break (0); 251 GNUNET_break (0);
252 return; 252 return;
253 } 253 }
254 if (0 != (path_len % sizeof(struct GNUNET_PeerIdentity))) 254 if (0 != (path_len % sizeof(struct GNUNET_DHT_PathElement)))
255 { 255 {
256 GNUNET_break (0); 256 GNUNET_break (0);
257 path_len = 0; 257 path_len = 0;
258 } 258 }
259 path_len %= sizeof(struct GNUNET_PeerIdentity); 259 path_len %= sizeof(struct GNUNET_DHT_PathElement);
260 LOG (GNUNET_ERROR_TYPE_DEBUG, 260 LOG (GNUNET_ERROR_TYPE_DEBUG,
261 "Found result of size %u bytes and type %u in database\n", 261 "Found result of size %u bytes and type %u in database\n",
262 (unsigned int) data_size, 262 (unsigned int) data_size,
@@ -446,7 +446,7 @@ extract_result_cb (void *cls,
446 uint32_t type; 446 uint32_t type;
447 void *data; 447 void *data;
448 size_t data_size; 448 size_t data_size;
449 struct GNUNET_PeerIdentity *path; 449 struct GNUNET_DHT_PathElement *path;
450 size_t path_len; 450 size_t path_len;
451 struct GNUNET_HashCode key; 451 struct GNUNET_HashCode key;
452 struct GNUNET_PQ_ResultSpec rs[] = { 452 struct GNUNET_PQ_ResultSpec rs[] = {
@@ -473,12 +473,12 @@ extract_result_cb (void *cls,
473 GNUNET_break (0); 473 GNUNET_break (0);
474 return; 474 return;
475 } 475 }
476 if (0 != (path_len % sizeof(struct GNUNET_PeerIdentity))) 476 if (0 != (path_len % sizeof(struct GNUNET_DHT_PathElement)))
477 { 477 {
478 GNUNET_break (0); 478 GNUNET_break (0);
479 path_len = 0; 479 path_len = 0;
480 } 480 }
481 path_len %= sizeof(struct GNUNET_PeerIdentity); 481 path_len %= sizeof(struct GNUNET_DHT_PathElement);
482 LOG (GNUNET_ERROR_TYPE_DEBUG, 482 LOG (GNUNET_ERROR_TYPE_DEBUG,
483 "Found result of size %u bytes and type %u in database\n", 483 "Found result of size %u bytes and type %u in database\n",
484 (unsigned int) data_size, 484 (unsigned int) data_size,