fixes
authorChristian Grothoff <christian@grothoff.org>
Tue, 15 Mar 2011 10:28:54 +0000 (10:28 +0000)
committerChristian Grothoff <christian@grothoff.org>
Tue, 15 Mar 2011 10:28:54 +0000 (10:28 +0000)
src/fs/gnunet-service-fs_new.c
src/fs/gnunet-service-fs_pe.c
src/fs/gnunet-service-fs_pe.h

index 5e9fce754d67b9a2ae9d8338421f1200b17b1d8b..f68250a23360957b5585ba7a567d02f4b7106b54 100644 (file)
@@ -95,12 +95,6 @@ const struct GNUNET_CONFIGURATION_Handle *GSF_cfg;
  */
 struct GNUNET_STATISTICS_Handle *GSF_stats;
 
-/**
- * Pointer to handle to the core service (points to NULL until we've
- * connected to it).
- */
-struct GNUNET_CORE_Handle *GSF_core;
-
 /**
  * Handle for DHT operations.
  */
@@ -140,6 +134,12 @@ unsigned int GSF_cover_content_count;
  */
 struct GNUNET_BLOCK_Context *GSF_block_ctx;
 
+/**
+ * Pointer to handle to the core service (points to NULL until we've
+ * connected to it).
+ */
+struct GNUNET_CORE_Handle *GSF_core;
+
 
 /* ***************************** locals ******************************* */
 
@@ -153,12 +153,6 @@ static struct GNUNET_CONFIGURATION_Handle *block_cfg;
  */
 static GNUNET_SCHEDULER_TaskIdentifier cover_age_task;
 
-/**
- * Pointer to handle to the core service (points to NULL until we've
- * connected to it).
- */
-static struct GNUNET_CORE_Handle *core;
-
 /**
  * Datastore 'GET' load tracking.
  */
@@ -398,10 +392,10 @@ static void
 shutdown_task (void *cls,
               const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  if (NULL != core)
+  if (NULL != GSF_core)
     {
-      GNUNET_CORE_disconnect (core);
-      core = NULL;
+      GNUNET_CORE_disconnect (GSF_core);
+      GSF_core = NULL;
     }
   GSF_put_done_ ();
   GSF_push_done_ ();
@@ -531,17 +525,17 @@ main_init (struct GNUNET_SERVER_Handle *server,
     {NULL, NULL, 0, 0}
   };
 
-  core = GNUNET_CORE_connect (GSF_cfg,
-                             1, /* larger? */
-                             NULL,
-                             &peer_init_handler,
-                             &peer_connect_handler,
-                             &GSF_peer_disconnect_handler_,
-                             &GSF_peer_status_handler_,
-                             NULL, GNUNET_NO,
-                             NULL, GNUNET_NO,
-                             p2p_handlers);
-  if (NULL == core)
+  GSF_core = GNUNET_CORE_connect (GSF_cfg,
+                                 1, /* larger? */
+                                 NULL,
+                                 &peer_init_handler,
+                                 &peer_connect_handler,
+                                 &GSF_peer_disconnect_handler_,
+                                 &GSF_peer_status_handler_,
+                                 NULL, GNUNET_NO,
+                                 NULL, GNUNET_NO,
+                                 p2p_handlers);
+  if (NULL == GSF_core)
     {
       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  _("Failed to connect to `%s' service.\n"),
@@ -577,7 +571,7 @@ run (void *cls,
 {
   GSF_cfg = cfg;
   GSF_dsh = GNUNET_DATASTORE_connect (cfg);
-  if (GSF_dsh == NULL)
+  if (NULL == GSF_dsh)
     {
       GNUNET_SCHEDULER_shutdown ();
       return;
index 1c73c8dda6a757c9f3ee314e0213434f5be8aeb5..7b0f874fff5524018f472b3f6552f0797ad55327 100644 (file)
@@ -368,14 +368,14 @@ GSF_plan_notify_peer_disconnect_ (const struct GSF_ConnectedPeer *cp)
  * @param pr request that is done
  */
 void
-GSF_plan_notify_request_done_ (const struct GSF_PendingRequest *pr)
+GSF_plan_notify_request_done_ (struct GSF_PendingRequest *pr)
 {
   struct GSF_RequestPlan *rp;
   struct GSF_PendingRequestData *prd;
 
+  prd = GSF_pending_request_get_data_ (pr);
   while (NULL != (rp = prd->rp_head))
     {
-      prd = GSF_pending_request_get_data_ (rp->pr);
       GNUNET_CONTAINER_heap_remove_node (rp->hn);
       GNUNET_CONTAINER_DLL_remove (prd->rp_head,
                                   prd->rp_tail,
index 14e9dec2ef37c9c7d1b0dedfeec807d88ea4c1b5..2413b970f0137f3523d7754f71a5eae5d2d8b115 100644 (file)
@@ -59,7 +59,7 @@ GSF_plan_notify_peer_disconnect_ (const struct GSF_ConnectedPeer *cp);
  * @param pr request that is done
  */
 void
-GSF_plan_notify_request_done_ (const struct GSF_PendingRequest *pr);
+GSF_plan_notify_request_done_ (struct GSF_PendingRequest *pr);
 
 
 /**