[GNUnet-SVN] r13667 - gnunet/src/dht

[gnunet]

Author: nevans
Date: 2010-11-12 14:33:43 +0100 (Fri, 12 Nov 2010)
New Revision: 13667

Modified:
   gnunet/src/dht/gnunet-service-dht.c
   gnunet/src/dht/plugin_dhtlog_mysql_dump_load.c
Log:
testing if flushing files corrects a problem

Modified: gnunet/src/dht/gnunet-service-dht.c
===================================================================
--- gnunet/src/dht/gnunet-service-dht.c 2010-11-12 13:03:09 UTC (rev 13666)
+++ gnunet/src/dht/gnunet-service-dht.c 2010-11-12 13:33:43 UTC (rev 13667)
@@ -4425,9 +4425,9 @@
   if (server == NULL)
     {
 #if DEBUG_DHT
-  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-              "%s: Connection to core FAILED!\n", "dht",
-              GNUNET_i2s (identity));
+      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                  "%s: Connection to core FAILED!\n", "dht",
+                  GNUNET_i2s (identity));
 #endif
       GNUNET_SCHEDULER_cancel (cleanup_task);
       GNUNET_SCHEDULER_add_now (&shutdown_task, NULL);

Modified: gnunet/src/dht/plugin_dhtlog_mysql_dump_load.c
===================================================================
--- gnunet/src/dht/plugin_dhtlog_mysql_dump_load.c      2010-11-12 13:03:09 UTC 
(rev 13666)
+++ gnunet/src/dht/plugin_dhtlog_mysql_dump_load.c      2010-11-12 13:33:43 UTC 
(rev 13667)
@@ -326,7 +326,7 @@
     return GNUNET_SYSERR;
 
   ret = fprintf(node_outfile, "TRIALUID\t%s\n", 
GNUNET_h2s_full(&node->hashPubKey));
-
+  fflush(node_outfile);
   if (ret >= 0)
     return GNUNET_OK;
   return GNUNET_SYSERR;
@@ -348,7 +348,7 @@
     return GNUNET_SYSERR;
 
   ret = fprintf(outfile, "update trials set endtime=\"%s\", gets_succeeded=%u 
where trialuid = @temp_trial;\n", get_sql_time(), gets_succeeded);
-
+  fflush(node_outfile);
   if (ret >= 0)
     return GNUNET_OK;
   else
@@ -373,7 +373,7 @@
     return GNUNET_SYSERR;
 
   ret = fprintf(outfile, "update nodes set malicious_dropper = 1 where 
trialuid = @temp_trial and nodeid = \"%s\";\n", 
GNUNET_h2s_full(&peer->hashPubKey));
-
+  fflush(node_outfile);
   if (ret >= 0)
     return GNUNET_OK;
   else
@@ -397,7 +397,7 @@
     return GNUNET_SYSERR;
 
   ret = fprintf(outfile, "update trials set totalConnections = %u where 
trialuid = @temp_trial;\n", totalConnections);
-
+  fflush(node_outfile);
   if (ret >= 0)
     return GNUNET_OK;
   else