diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/dht/gnunet-service-dht.c | 6 | ||||
-rw-r--r-- | src/dht/plugin_dhtlog_mysql_dump_load.c | 8 |
2 files changed, 7 insertions, 7 deletions
diff --git a/src/dht/gnunet-service-dht.c b/src/dht/gnunet-service-dht.c index b07c25b29..9e56e99b2 100644 --- a/src/dht/gnunet-service-dht.c +++ b/src/dht/gnunet-service-dht.c | |||
@@ -4425,9 +4425,9 @@ core_init (void *cls, | |||
4425 | if (server == NULL) | 4425 | if (server == NULL) |
4426 | { | 4426 | { |
4427 | #if DEBUG_DHT | 4427 | #if DEBUG_DHT |
4428 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 4428 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
4429 | "%s: Connection to core FAILED!\n", "dht", | 4429 | "%s: Connection to core FAILED!\n", "dht", |
4430 | GNUNET_i2s (identity)); | 4430 | GNUNET_i2s (identity)); |
4431 | #endif | 4431 | #endif |
4432 | GNUNET_SCHEDULER_cancel (cleanup_task); | 4432 | GNUNET_SCHEDULER_cancel (cleanup_task); |
4433 | GNUNET_SCHEDULER_add_now (&shutdown_task, NULL); | 4433 | GNUNET_SCHEDULER_add_now (&shutdown_task, NULL); |
diff --git a/src/dht/plugin_dhtlog_mysql_dump_load.c b/src/dht/plugin_dhtlog_mysql_dump_load.c index 45e0e1afb..97c4f3e79 100644 --- a/src/dht/plugin_dhtlog_mysql_dump_load.c +++ b/src/dht/plugin_dhtlog_mysql_dump_load.c | |||
@@ -326,7 +326,7 @@ add_node (unsigned long long *nodeuid, struct GNUNET_PeerIdentity * node) | |||
326 | return GNUNET_SYSERR; | 326 | return GNUNET_SYSERR; |
327 | 327 | ||
328 | ret = fprintf(node_outfile, "TRIALUID\t%s\n", GNUNET_h2s_full(&node->hashPubKey)); | 328 | ret = fprintf(node_outfile, "TRIALUID\t%s\n", GNUNET_h2s_full(&node->hashPubKey)); |
329 | 329 | fflush(node_outfile); | |
330 | if (ret >= 0) | 330 | if (ret >= 0) |
331 | return GNUNET_OK; | 331 | return GNUNET_OK; |
332 | return GNUNET_SYSERR; | 332 | return GNUNET_SYSERR; |
@@ -348,7 +348,7 @@ update_trials (unsigned int gets_succeeded) | |||
348 | return GNUNET_SYSERR; | 348 | return GNUNET_SYSERR; |
349 | 349 | ||
350 | ret = fprintf(outfile, "update trials set endtime=\"%s\", gets_succeeded=%u where trialuid = @temp_trial;\n", get_sql_time(), gets_succeeded); | 350 | ret = fprintf(outfile, "update trials set endtime=\"%s\", gets_succeeded=%u where trialuid = @temp_trial;\n", get_sql_time(), gets_succeeded); |
351 | 351 | fflush(node_outfile); | |
352 | if (ret >= 0) | 352 | if (ret >= 0) |
353 | return GNUNET_OK; | 353 | return GNUNET_OK; |
354 | else | 354 | else |
@@ -373,7 +373,7 @@ set_malicious (struct GNUNET_PeerIdentity *peer) | |||
373 | return GNUNET_SYSERR; | 373 | return GNUNET_SYSERR; |
374 | 374 | ||
375 | ret = fprintf(outfile, "update nodes set malicious_dropper = 1 where trialuid = @temp_trial and nodeid = \"%s\";\n", GNUNET_h2s_full(&peer->hashPubKey)); | 375 | ret = fprintf(outfile, "update nodes set malicious_dropper = 1 where trialuid = @temp_trial and nodeid = \"%s\";\n", GNUNET_h2s_full(&peer->hashPubKey)); |
376 | 376 | fflush(node_outfile); | |
377 | if (ret >= 0) | 377 | if (ret >= 0) |
378 | return GNUNET_OK; | 378 | return GNUNET_OK; |
379 | else | 379 | else |
@@ -397,7 +397,7 @@ add_connections (unsigned int totalConnections) | |||
397 | return GNUNET_SYSERR; | 397 | return GNUNET_SYSERR; |
398 | 398 | ||
399 | ret = fprintf(outfile, "update trials set totalConnections = %u where trialuid = @temp_trial;\n", totalConnections); | 399 | ret = fprintf(outfile, "update trials set totalConnections = %u where trialuid = @temp_trial;\n", totalConnections); |
400 | 400 | fflush(node_outfile); | |
401 | if (ret >= 0) | 401 | if (ret >= 0) |
402 | return GNUNET_OK; | 402 | return GNUNET_OK; |
403 | else | 403 | else |