diff options
Diffstat (limited to 'src/messenger/gnunet-service-messenger_list_messages.c')
-rw-r--r-- | src/messenger/gnunet-service-messenger_list_messages.c | 76 |
1 files changed, 75 insertions, 1 deletions
diff --git a/src/messenger/gnunet-service-messenger_list_messages.c b/src/messenger/gnunet-service-messenger_list_messages.c index c4f1f7043..bb6086e41 100644 --- a/src/messenger/gnunet-service-messenger_list_messages.c +++ b/src/messenger/gnunet-service-messenger_list_messages.c | |||
@@ -1,6 +1,6 @@ | |||
1 | /* | 1 | /* |
2 | This file is part of GNUnet. | 2 | This file is part of GNUnet. |
3 | Copyright (C) 2020 GNUnet e.V. | 3 | Copyright (C) 2020--2021 GNUnet e.V. |
4 | 4 | ||
5 | GNUnet is free software: you can redistribute it and/or modify it | 5 | GNUnet is free software: you can redistribute it and/or modify it |
6 | under the terms of the GNU Affero General Public License as published | 6 | under the terms of the GNU Affero General Public License as published |
@@ -54,6 +54,8 @@ clear_list_messages (struct GNUNET_MESSENGER_ListMessages *messages) | |||
54 | void | 54 | void |
55 | add_to_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const struct GNUNET_HashCode *hash) | 55 | add_to_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const struct GNUNET_HashCode *hash) |
56 | { | 56 | { |
57 | GNUNET_assert((messages) && (hash)); | ||
58 | |||
57 | struct GNUNET_MESSENGER_ListMessage *element = GNUNET_new(struct GNUNET_MESSENGER_ListMessage); | 59 | struct GNUNET_MESSENGER_ListMessage *element = GNUNET_new(struct GNUNET_MESSENGER_ListMessage); |
58 | 60 | ||
59 | GNUNET_memcpy(&(element->hash), hash, sizeof(struct GNUNET_HashCode)); | 61 | GNUNET_memcpy(&(element->hash), hash, sizeof(struct GNUNET_HashCode)); |
@@ -62,8 +64,21 @@ add_to_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const stru | |||
62 | } | 64 | } |
63 | 65 | ||
64 | void | 66 | void |
67 | copy_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const struct GNUNET_MESSENGER_ListMessages *origin) | ||
68 | { | ||
69 | GNUNET_assert((messages) && (origin)); | ||
70 | |||
71 | struct GNUNET_MESSENGER_ListMessage *element; | ||
72 | |||
73 | for (element = origin->head; element; element = element->next) | ||
74 | add_to_list_messages (messages, &(element->hash)); | ||
75 | } | ||
76 | |||
77 | void | ||
65 | remove_from_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const struct GNUNET_HashCode *hash) | 78 | remove_from_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const struct GNUNET_HashCode *hash) |
66 | { | 79 | { |
80 | GNUNET_assert((messages) && (hash)); | ||
81 | |||
67 | struct GNUNET_MESSENGER_ListMessage *element; | 82 | struct GNUNET_MESSENGER_ListMessage *element; |
68 | 83 | ||
69 | for (element = messages->head; element; element = element->next) | 84 | for (element = messages->head; element; element = element->next) |
@@ -74,3 +89,62 @@ remove_from_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const | |||
74 | break; | 89 | break; |
75 | } | 90 | } |
76 | } | 91 | } |
92 | |||
93 | void | ||
94 | load_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const char *path) | ||
95 | { | ||
96 | GNUNET_assert((messages) && (path)); | ||
97 | |||
98 | if (GNUNET_YES != GNUNET_DISK_file_test (path)) | ||
99 | return; | ||
100 | |||
101 | enum GNUNET_DISK_AccessPermissions permission = (GNUNET_DISK_PERM_USER_READ | GNUNET_DISK_PERM_USER_WRITE); | ||
102 | |||
103 | struct GNUNET_DISK_FileHandle *handle = GNUNET_DISK_file_open( | ||
104 | path, GNUNET_DISK_OPEN_READ, permission | ||
105 | ); | ||
106 | |||
107 | if (!handle) | ||
108 | return; | ||
109 | |||
110 | GNUNET_DISK_file_seek(handle, 0, GNUNET_DISK_SEEK_SET); | ||
111 | |||
112 | struct GNUNET_HashCode hash; | ||
113 | ssize_t len; | ||
114 | |||
115 | do { | ||
116 | len = GNUNET_DISK_file_read(handle, &hash, sizeof(hash)); | ||
117 | |||
118 | if (len != sizeof(hash)) | ||
119 | break; | ||
120 | |||
121 | add_to_list_messages(messages, &hash); | ||
122 | } while (len == sizeof(hash)); | ||
123 | |||
124 | GNUNET_DISK_file_close(handle); | ||
125 | } | ||
126 | |||
127 | void | ||
128 | save_list_messages (struct GNUNET_MESSENGER_ListMessages *messages, const char *path) | ||
129 | { | ||
130 | GNUNET_assert((messages) && (path)); | ||
131 | |||
132 | enum GNUNET_DISK_AccessPermissions permission = (GNUNET_DISK_PERM_USER_READ | GNUNET_DISK_PERM_USER_WRITE); | ||
133 | |||
134 | struct GNUNET_DISK_FileHandle *handle = GNUNET_DISK_file_open( | ||
135 | path, GNUNET_DISK_OPEN_CREATE | GNUNET_DISK_OPEN_WRITE, permission | ||
136 | ); | ||
137 | |||
138 | if (!handle) | ||
139 | return; | ||
140 | |||
141 | GNUNET_DISK_file_seek(handle, 0, GNUNET_DISK_SEEK_SET); | ||
142 | |||
143 | struct GNUNET_MESSENGER_ListMessage *element; | ||
144 | |||
145 | for (element = messages->head; element; element = element->next) | ||
146 | GNUNET_DISK_file_write(handle, &(element->hash), sizeof(element->hash)); | ||
147 | |||
148 | GNUNET_DISK_file_sync(handle); | ||
149 | GNUNET_DISK_file_close(handle); | ||
150 | } | ||