1 files changed, 74 insertions, 77 deletions

diff --git a/src/fs/fs_publish_ksk.c b/src/fs/fs_publish_ksk.c
index e7f6408fd..151b8256c 100644
--- a/src/fs/fs_publish_ksk.c
+++ b/src/fs/fs_publish_ksk.c
@@ -11,12 +11,12 @@
      WITHOUT ANY WARRANTY; without even the implied warranty of
      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
      Affero General Public License for more details.
-    
+
      You should have received a copy of the GNU Affero General Public License
      along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
      SPDX-License-Identifier: AGPL3.0-or-later
-*/
+ */
 
 /**
  * @file fs/fs_publish_ksk.c
@@ -38,9 +38,7 @@
 /**
  * Context for the KSK publication.
  */
-struct GNUNET_FS_PublishKskContext
-{
-
+struct GNUNET_FS_PublishKskContext {
   /**
    * Keywords to use.
    */
@@ -100,7 +98,6 @@ struct GNUNET_FS_PublishKskContext
    * Keyword that we are currently processing.
    */
   unsigned int i;
-
 };
 
 
@@ -112,7 +109,7 @@ struct GNUNET_FS_PublishKskContext
  * @param cls closure of type `struct PublishKskContext *`
  */
 static void
-publish_ksk_cont (void *cls);
+publish_ksk_cont(void *cls);
 
 
 /**
@@ -123,21 +120,21 @@ publish_ksk_cont (void *cls);
  * @param msg error message (or NULL)
  */
 static void
-kb_put_cont (void *cls,
-             const char *msg)
+kb_put_cont(void *cls,
+            const char *msg)
 {
   struct GNUNET_FS_PublishKskContext *pkc = cls;
 
   pkc->uc = NULL;
   if (NULL != msg)
-  {
-    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-                "KBlock PUT operation failed: %s\n", msg);
-    pkc->cont (pkc->cont_cls, NULL, msg);
-    GNUNET_FS_publish_ksk_cancel (pkc);
-    return;
-  }
-  pkc->ksk_task = GNUNET_SCHEDULER_add_now (&publish_ksk_cont, pkc);
+    {
+      GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
+                 "KBlock PUT operation failed: %s\n", msg);
+      pkc->cont(pkc->cont_cls, NULL, msg);
+      GNUNET_FS_publish_ksk_cancel(pkc);
+      return;
+    }
+  pkc->ksk_task = GNUNET_SCHEDULER_add_now(&publish_ksk_cont, pkc);
 }
 
 
@@ -148,33 +145,33 @@ kb_put_cont (void *cls,
  * @param cls closure of type `struct GNUNET_FS_PublishKskContext *`
  */
 static void
-publish_ksk_cont (void *cls)
+publish_ksk_cont(void *cls)
 {
   struct GNUNET_FS_PublishKskContext *pkc = cls;
   const char *keyword;
 
   pkc->ksk_task = NULL;
-  if ( (pkc->i == pkc->ksk_uri->data.ksk.keywordCount) ||
-       (NULL == pkc->dsh) )
-  {
-    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-                "KSK PUT operation complete\n");
-    pkc->cont (pkc->cont_cls, pkc->ksk_uri,
-               NULL);
-    GNUNET_FS_publish_ksk_cancel (pkc);
-    return;
-  }
+  if ((pkc->i == pkc->ksk_uri->data.ksk.keywordCount) ||
+      (NULL == pkc->dsh))
+    {
+      GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
+                 "KSK PUT operation complete\n");
+      pkc->cont(pkc->cont_cls, pkc->ksk_uri,
+                NULL);
+      GNUNET_FS_publish_ksk_cancel(pkc);
+      return;
+    }
   keyword = pkc->ksk_uri->data.ksk.keywords[pkc->i++];
-  pkc->uc = GNUNET_FS_publish_ublock_ (pkc->h,
-                                       pkc->dsh,
-                                       keyword + 1 /* skip '+' */,
-                                       NULL,
-                                       GNUNET_CRYPTO_ecdsa_key_get_anonymous (),
-                                       pkc->meta,
-                                       pkc->uri,
-                                       &pkc->bo,
-                                       pkc->options,
-                                       &kb_put_cont, pkc);
+  pkc->uc = GNUNET_FS_publish_ublock_(pkc->h,
+                                      pkc->dsh,
+                                      keyword + 1 /* skip '+' */,
+                                      NULL,
+                                      GNUNET_CRYPTO_ecdsa_key_get_anonymous(),
+                                      pkc->meta,
+                                      pkc->uri,
+                                      &pkc->bo,
+                                      pkc->options,
+                                      &kb_put_cont, pkc);
 }
 
 
@@ -192,39 +189,39 @@ publish_ksk_cont (void *cls)
  * @return NULL on error ('cont' will still be called)
  */
 struct GNUNET_FS_PublishKskContext *
-GNUNET_FS_publish_ksk (struct GNUNET_FS_Handle *h,
-                       const struct GNUNET_FS_Uri *ksk_uri,
-                       const struct GNUNET_CONTAINER_MetaData *meta,
-                       const struct GNUNET_FS_Uri *uri,
-                       const struct GNUNET_FS_BlockOptions *bo,
-                       enum GNUNET_FS_PublishOptions options,
-                       GNUNET_FS_PublishContinuation cont, void *cont_cls)
+GNUNET_FS_publish_ksk(struct GNUNET_FS_Handle *h,
+                      const struct GNUNET_FS_Uri *ksk_uri,
+                      const struct GNUNET_CONTAINER_MetaData *meta,
+                      const struct GNUNET_FS_Uri *uri,
+                      const struct GNUNET_FS_BlockOptions *bo,
+                      enum GNUNET_FS_PublishOptions options,
+                      GNUNET_FS_PublishContinuation cont, void *cont_cls)
 {
   struct GNUNET_FS_PublishKskContext *pkc;
 
-  GNUNET_assert (NULL != uri);
-  pkc = GNUNET_new (struct GNUNET_FS_PublishKskContext);
+  GNUNET_assert(NULL != uri);
+  pkc = GNUNET_new(struct GNUNET_FS_PublishKskContext);
   pkc->h = h;
   pkc->bo = *bo;
   pkc->options = options;
   pkc->cont = cont;
   pkc->cont_cls = cont_cls;
-  pkc->meta = GNUNET_CONTAINER_meta_data_duplicate (meta);
+  pkc->meta = GNUNET_CONTAINER_meta_data_duplicate(meta);
   if (0 == (options & GNUNET_FS_PUBLISH_OPTION_SIMULATE_ONLY))
-  {
-    pkc->dsh = GNUNET_DATASTORE_connect (h->cfg);
-    if (NULL == pkc->dsh)
     {
-      cont (cont_cls,
-            NULL,
-            _("Could not connect to datastore."));
-      GNUNET_free (pkc);
-      return NULL;
+      pkc->dsh = GNUNET_DATASTORE_connect(h->cfg);
+      if (NULL == pkc->dsh)
+        {
+          cont(cont_cls,
+               NULL,
+               _("Could not connect to datastore."));
+          GNUNET_free(pkc);
+          return NULL;
+        }
     }
-  }
-  pkc->uri = GNUNET_FS_uri_dup (uri);
-  pkc->ksk_uri = GNUNET_FS_uri_dup (ksk_uri);
-  pkc->ksk_task = GNUNET_SCHEDULER_add_now (&publish_ksk_cont, pkc);
+  pkc->uri = GNUNET_FS_uri_dup(uri);
+  pkc->ksk_uri = GNUNET_FS_uri_dup(ksk_uri);
+  pkc->ksk_task = GNUNET_SCHEDULER_add_now(&publish_ksk_cont, pkc);
   return pkc;
 }
 
@@ -235,27 +232,27 @@ GNUNET_FS_publish_ksk (struct GNUNET_FS_Handle *h,
  * @param pkc context of the operation to abort.
  */
 void
-GNUNET_FS_publish_ksk_cancel (struct GNUNET_FS_PublishKskContext *pkc)
+GNUNET_FS_publish_ksk_cancel(struct GNUNET_FS_PublishKskContext *pkc)
 {
   if (NULL != pkc->ksk_task)
-  {
-    GNUNET_SCHEDULER_cancel (pkc->ksk_task);
-    pkc->ksk_task = NULL;
-  }
+    {
+      GNUNET_SCHEDULER_cancel(pkc->ksk_task);
+      pkc->ksk_task = NULL;
+    }
   if (NULL != pkc->uc)
-  {
-    GNUNET_FS_publish_ublock_cancel_ (pkc->uc);
-    pkc->uc = NULL;
-  }
+    {
+      GNUNET_FS_publish_ublock_cancel_(pkc->uc);
+      pkc->uc = NULL;
+    }
   if (NULL != pkc->dsh)
-  {
-    GNUNET_DATASTORE_disconnect (pkc->dsh, GNUNET_NO);
-    pkc->dsh = NULL;
-  }
-  GNUNET_CONTAINER_meta_data_destroy (pkc->meta);
-  GNUNET_FS_uri_destroy (pkc->ksk_uri);
-  GNUNET_FS_uri_destroy (pkc->uri);
-  GNUNET_free (pkc);
+    {
+      GNUNET_DATASTORE_disconnect(pkc->dsh, GNUNET_NO);
+      pkc->dsh = NULL;
+    }
+  GNUNET_CONTAINER_meta_data_destroy(pkc->meta);
+  GNUNET_FS_uri_destroy(pkc->ksk_uri);
+  GNUNET_FS_uri_destroy(pkc->uri);
+  GNUNET_free(pkc);
 }