aboutsummaryrefslogtreecommitdiff
path: root/src/service/messenger/gnunet-service-messenger_message_store.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/service/messenger/gnunet-service-messenger_message_store.c')
-rw-r--r--src/service/messenger/gnunet-service-messenger_message_store.c9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/service/messenger/gnunet-service-messenger_message_store.c b/src/service/messenger/gnunet-service-messenger_message_store.c
index d39e3f7bb..1eb275f9b 100644
--- a/src/service/messenger/gnunet-service-messenger_message_store.c
+++ b/src/service/messenger/gnunet-service-messenger_message_store.c
@@ -217,6 +217,7 @@ load_message_store_links (struct GNUNET_MESSENGER_MessageStore *store,
217 (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put (store->links, 217 (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put (store->links,
218 &(storage.hash), link, 218 &(storage.hash), link,
219 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))) 219 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)))
220
220 break; 221 break;
221 } 222 }
222 while (link); 223 while (link);
@@ -235,7 +236,8 @@ load_message_store (struct GNUNET_MESSENGER_MessageStore *store,
235 GNUNET_assert ((store) && (directory)); 236 GNUNET_assert ((store) && (directory));
236 237
237 enum GNUNET_DISK_AccessPermissions permission = (GNUNET_DISK_PERM_USER_READ 238 enum GNUNET_DISK_AccessPermissions permission = (GNUNET_DISK_PERM_USER_READ
238 | GNUNET_DISK_PERM_USER_WRITE); 239 | GNUNET_DISK_PERM_USER_WRITE
240 );
239 241
240 if (store->storage_messages) 242 if (store->storage_messages)
241 GNUNET_DISK_file_close (store->storage_messages); 243 GNUNET_DISK_file_close (store->storage_messages);
@@ -369,7 +371,8 @@ save_message_store (struct GNUNET_MESSENGER_MessageStore *store,
369 struct GNUNET_MESSENGER_ClosureMessageSave save; 371 struct GNUNET_MESSENGER_ClosureMessageSave save;
370 372
371 enum GNUNET_DISK_AccessPermissions permission = (GNUNET_DISK_PERM_USER_READ 373 enum GNUNET_DISK_AccessPermissions permission = (GNUNET_DISK_PERM_USER_READ
372 | GNUNET_DISK_PERM_USER_WRITE); 374 | GNUNET_DISK_PERM_USER_WRITE
375 );
373 376
374 char *filename; 377 char *filename;
375 378
@@ -526,6 +529,7 @@ get_store_message (struct GNUNET_MESSENGER_MessageStore *store,
526 if (GNUNET_OK == GNUNET_CONTAINER_multihashmap_put (store->messages, hash, 529 if (GNUNET_OK == GNUNET_CONTAINER_multihashmap_put (store->messages, hash,
527 message, 530 message,
528 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)) 531 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
532
529 goto free_buffer; 533 goto free_buffer;
530 534
531 free_message : destroy_message (message); 535 free_message : destroy_message (message);
@@ -609,6 +613,7 @@ add_link (struct GNUNET_MESSENGER_MessageStore *store,
609 613
610 if (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put (store->links, hash, link, 614 if (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put (store->links, hash, link,
611 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)) 615 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
616
612 GNUNET_free (link); 617 GNUNET_free (link);
613 else 618 else
614 store->write_links = GNUNET_YES; 619 store->write_links = GNUNET_YES;