From 6640e3beca224341f82216442c8e2d417199836f Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sat, 4 Mar 2017 19:07:05 +0100 Subject: misc indentation changes --- src/include/gnunet_configuration_lib.h | 7 ++----- src/util/disk.c | 21 ++++++++++++--------- 2 files changed, 14 insertions(+), 14 deletions(-) (limited to 'src') diff --git a/src/include/gnunet_configuration_lib.h b/src/include/gnunet_configuration_lib.h index 746dea61f..c1537e4f8 100644 --- a/src/include/gnunet_configuration_lib.h +++ b/src/include/gnunet_configuration_lib.h @@ -281,8 +281,8 @@ GNUNET_CONFIGURATION_get_value_number (const struct GNUNET_CONFIGURATION_Handle * @return #GNUNET_OK on success, #GNUNET_SYSERR on error */ int -GNUNET_CONFIGURATION_get_value_float (const struct GNUNET_CONFIGURATION_Handle - *cfg, const char *section, +GNUNET_CONFIGURATION_get_value_float (const struct GNUNET_CONFIGURATION_Handle *cfg, + const char *section, const char *option, float *number); @@ -454,9 +454,6 @@ GNUNET_CONFIGURATION_get_data (const struct GNUNET_CONFIGURATION_Handle *cfg, size_t buf_size); - - - /** * Expand an expression of the form "$FOO/BAR" to "DIRECTORY/BAR" * where either in the "PATHS" section or the environtment "FOO" is diff --git a/src/util/disk.c b/src/util/disk.c index d3d5d87dc..d536ec897 100644 --- a/src/util/disk.c +++ b/src/util/disk.c @@ -329,8 +329,10 @@ GNUNET_DISK_file_get_identifiers (const char *filename, uint64_t * dev, BY_HANDLE_FILE_INFORMATION info; int succ; - fh = GNUNET_DISK_file_open (filename, GNUNET_DISK_OPEN_READ, 0); - if (fh == NULL) + fh = GNUNET_DISK_file_open (filename, + GNUNET_DISK_OPEN_READ, + GNUNET_DISK_PERM_NONE); + if (NULL == fh) return GNUNET_SYSERR; succ = GetFileInformationByHandle (fh->h, &info); GNUNET_DISK_file_close (fh); @@ -1191,7 +1193,7 @@ GNUNET_DISK_fn_write (const char *fn, fh = GNUNET_DISK_file_open (fn, GNUNET_DISK_OPEN_WRITE | GNUNET_DISK_OPEN_TRUNCATE | GNUNET_DISK_OPEN_CREATE, mode); - if (!fh) + if (! fh) return GNUNET_SYSERR; ret = GNUNET_DISK_file_write (fh, buffer, n); GNUNET_assert (GNUNET_OK == GNUNET_DISK_file_close (fh)); @@ -1756,9 +1758,10 @@ GNUNET_DISK_file_open (const char *fn, /** - * Close an open file + * Close an open file. + * * @param h file handle - * @return GNUNET_OK on success, GNUNET_SYSERR otherwise + * @return #GNUNET_OK on success, #GNUNET_SYSERR otherwise */ int GNUNET_DISK_file_close (struct GNUNET_DISK_FileHandle *h) @@ -1773,7 +1776,7 @@ GNUNET_DISK_file_close (struct GNUNET_DISK_FileHandle *h) ret = GNUNET_OK; #if MINGW - if (!CloseHandle (h->h)) + if (! CloseHandle (h->h)) { SetErrnoFromWinError (GetLastError ()); LOG_STRERROR (GNUNET_ERROR_TYPE_WARNING, "close"); @@ -1781,7 +1784,7 @@ GNUNET_DISK_file_close (struct GNUNET_DISK_FileHandle *h) } if (h->oOverlapRead) { - if (!CloseHandle (h->oOverlapRead->hEvent)) + if (! CloseHandle (h->oOverlapRead->hEvent)) { SetErrnoFromWinError (GetLastError ()); LOG_STRERROR (GNUNET_ERROR_TYPE_WARNING, "close"); @@ -1822,7 +1825,6 @@ struct GNUNET_DISK_FileHandle * GNUNET_DISK_get_handle_from_w32_handle (HANDLE osfh) { struct GNUNET_DISK_FileHandle *fh; - DWORD dwret; enum GNUNET_FILE_Type ftype; @@ -1836,7 +1838,8 @@ GNUNET_DISK_get_handle_from_w32_handle (HANDLE osfh) ftype = GNUNET_DISK_HANLDE_TYPE_PIPE; break; case FILE_TYPE_UNKNOWN: - if (GetLastError () == NO_ERROR || GetLastError () == ERROR_INVALID_HANDLE) + if ( (GetLastError () == NO_ERROR) || + (GetLastError () == ERROR_INVALID_HANDLE) ) { if (0 != ResetEvent (osfh)) ftype = GNUNET_DISK_HANLDE_TYPE_EVENT; -- cgit v1.2.3 From 29be1a71b26bed8f6b0317cc4ad12195edd6569f Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sun, 5 Mar 2017 15:54:47 +0100 Subject: indentation, comment and style fixes, no semantic changes --- src/fs/fs_directory.c | 78 +++++++++++++++++++++++++----------- src/fs/fs_download.c | 108 ++++++++++++++++++++++++++++++++++---------------- src/fs/fs_search.c | 7 ++-- src/fs/fs_tree.c | 6 +-- src/fs/fs_uri.c | 22 ++++++---- 5 files changed, 149 insertions(+), 72 deletions(-) (limited to 'src') diff --git a/src/fs/fs_directory.c b/src/fs/fs_directory.c index a18a903be..514eb64b3 100644 --- a/src/fs/fs_directory.c +++ b/src/fs/fs_directory.c @@ -170,13 +170,14 @@ find_full_data (void *cls, const char *plugin_name, * @param data pointer to the beginning of the directory * @param offset offset of data in the directory * @param dep function to call on each entry - * @param dep_cls closure for dep - * @return GNUNET_OK if this could be a block in a directory, - * GNUNET_NO if this could be part of a directory (but not 100% OK) - * GNUNET_SYSERR if 'data' does not represent a directory + * @param dep_cls closure for @a dep + * @return #GNUNET_OK if this could be a block in a directory, + * #GNUNET_NO if this could be part of a directory (but not 100% OK) + * #GNUNET_SYSERR if @a data does not represent a directory */ int -GNUNET_FS_directory_list_contents (size_t size, const void *data, +GNUNET_FS_directory_list_contents (size_t size, + const void *data, uint64_t offset, GNUNET_FS_DirectoryEntryProcessor dep, void *dep_cls) @@ -194,12 +195,16 @@ GNUNET_FS_directory_list_contents (size_t size, const void *data, if ((offset == 0) && ((size < 8 + sizeof (uint32_t)) || - (0 != memcmp (cdata, GNUNET_FS_DIRECTORY_MAGIC, 8)))) + (0 != memcmp (cdata, + GNUNET_FS_DIRECTORY_MAGIC, + 8)))) return GNUNET_SYSERR; pos = offset; if (offset == 0) { - GNUNET_memcpy (&mdSize, &cdata[8], sizeof (uint32_t)); + GNUNET_memcpy (&mdSize, + &cdata[8], + sizeof (uint32_t)); mdSize = ntohl (mdSize); if (mdSize > size - 8 - sizeof (uint32_t)) { @@ -215,7 +220,12 @@ GNUNET_FS_directory_list_contents (size_t size, const void *data, GNUNET_break (0); return GNUNET_SYSERR; /* malformed ! */ } - dep (dep_cls, NULL, NULL, md, 0, NULL); + dep (dep_cls, + NULL, + NULL, + md, + 0, + NULL); GNUNET_CONTAINER_meta_data_destroy (md); pos = 8 + sizeof (uint32_t) + mdSize; } @@ -247,7 +257,7 @@ GNUNET_FS_directory_list_contents (size_t size, const void *data, uri = GNUNET_FS_uri_parse (&cdata[pos], &emsg); pos = epos + 1; - if (uri == NULL) + if (NULL == uri) { GNUNET_free (emsg); pos--; /* go back to '\0' to force going to next alignment */ @@ -260,7 +270,9 @@ GNUNET_FS_directory_list_contents (size_t size, const void *data, return GNUNET_NO; /* illegal in directory! */ } - GNUNET_memcpy (&mdSize, &cdata[pos], sizeof (uint32_t)); + GNUNET_memcpy (&mdSize, + &cdata[pos], + sizeof (uint32_t)); mdSize = ntohl (mdSize); pos += sizeof (uint32_t); if (pos + mdSize > size) @@ -269,8 +281,9 @@ GNUNET_FS_directory_list_contents (size_t size, const void *data, return GNUNET_NO; /* malformed - or partial download */ } - md = GNUNET_CONTAINER_meta_data_deserialize (&cdata[pos], mdSize); - if (md == NULL) + md = GNUNET_CONTAINER_meta_data_deserialize (&cdata[pos], + mdSize); + if (NULL == md) { GNUNET_FS_uri_destroy (uri); GNUNET_break (0); @@ -282,10 +295,17 @@ GNUNET_FS_directory_list_contents (size_t size, const void *data, EXTRACTOR_METATYPE_GNUNET_ORIGINAL_FILENAME); full_data.size = 0; full_data.data = NULL; - GNUNET_CONTAINER_meta_data_iterate (md, &find_full_data, &full_data); - if (dep != NULL) + GNUNET_CONTAINER_meta_data_iterate (md, + &find_full_data, + &full_data); + if (NULL != dep) { - dep (dep_cls, filename, uri, md, full_data.size, full_data.data); + dep (dep_cls, + filename, + uri, + md, + full_data.size, + full_data.data); } GNUNET_free_non_null (full_data.data); GNUNET_free_non_null (filename); @@ -548,11 +568,12 @@ block_align (size_t start, unsigned int count, const size_t * sizes, * @param bld directory to finish * @param rsize set to the number of bytes needed * @param rdata set to the encoded directory - * @return GNUNET_OK on success + * @return #GNUNET_OK on success */ int GNUNET_FS_directory_builder_finish (struct GNUNET_FS_DirectoryBuilder *bld, - size_t * rsize, void **rdata) + size_t * rsize, + void **rdata) { char *data; char *sptr; @@ -575,9 +596,12 @@ GNUNET_FS_directory_builder_finish (struct GNUNET_FS_DirectoryBuilder *bld, bes = NULL; if (0 < bld->count) { - sizes = GNUNET_malloc (bld->count * sizeof (size_t)); - perm = GNUNET_malloc (bld->count * sizeof (unsigned int)); - bes = GNUNET_malloc (bld->count * sizeof (struct BuilderEntry *)); + sizes = GNUNET_new_array (bld->count, + size_t); + perm = GNUNET_new_array (bld->count, + unsigned int); + bes = GNUNET_new_array (bld->count, + struct BuilderEntry *); pos = bld->head; for (i = 0; i < bld->count; i++) { @@ -599,7 +623,8 @@ GNUNET_FS_directory_builder_finish (struct GNUNET_FS_DirectoryBuilder *bld, data = GNUNET_malloc_large (size); if (data == NULL) { - GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "malloc"); + GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, + "malloc"); *rsize = 0; *rdata = NULL; GNUNET_free_non_null (sizes); @@ -608,17 +633,22 @@ GNUNET_FS_directory_builder_finish (struct GNUNET_FS_DirectoryBuilder *bld, return GNUNET_SYSERR; } *rdata = data; - GNUNET_memcpy (data, GNUNET_DIRECTORY_MAGIC, strlen (GNUNET_DIRECTORY_MAGIC)); + GNUNET_memcpy (data, + GNUNET_DIRECTORY_MAGIC, + strlen (GNUNET_DIRECTORY_MAGIC)); off = strlen (GNUNET_DIRECTORY_MAGIC); sptr = &data[off + sizeof (uint32_t)]; ret = - GNUNET_CONTAINER_meta_data_serialize (bld->meta, &sptr, + GNUNET_CONTAINER_meta_data_serialize (bld->meta, + &sptr, size - off - sizeof (uint32_t), GNUNET_CONTAINER_META_DATA_SERIALIZE_FULL); GNUNET_assert (ret != -1); big = htonl (ret); - GNUNET_memcpy (&data[off], &big, sizeof (uint32_t)); + GNUNET_memcpy (&data[off], + &big, + sizeof (uint32_t)); off += sizeof (uint32_t) + ret; for (j = 0; j < bld->count; j++) { diff --git a/src/fs/fs_download.c b/src/fs/fs_download.c index 0789162bf..ed24a164a 100644 --- a/src/fs/fs_download.c +++ b/src/fs/fs_download.c @@ -37,14 +37,14 @@ static int is_recursive_download (struct GNUNET_FS_DownloadContext *dc) { return (0 != (dc->options & GNUNET_FS_DOWNLOAD_OPTION_RECURSIVE)) && - ((GNUNET_YES == GNUNET_FS_meta_data_test_for_directory (dc->meta)) || - ((NULL == dc->meta) && - ((NULL == dc->filename) || - ((strlen (dc->filename) >= strlen (GNUNET_FS_DIRECTORY_EXT)) && - (NULL != - strstr (dc->filename + strlen (dc->filename) - - strlen (GNUNET_FS_DIRECTORY_EXT), - GNUNET_FS_DIRECTORY_EXT)))))); + ( (GNUNET_YES == GNUNET_FS_meta_data_test_for_directory (dc->meta)) || + ( (NULL == dc->meta) && + ( (NULL == dc->filename) || + ( (strlen (dc->filename) >= strlen (GNUNET_FS_DIRECTORY_EXT)) && + (NULL != + strstr (dc->filename + strlen (dc->filename) - + strlen (GNUNET_FS_DIRECTORY_EXT), + GNUNET_FS_DIRECTORY_EXT)) ) ) ) ); } @@ -278,10 +278,12 @@ try_reconnect (struct GNUNET_FS_DownloadContext *dc); * @param data contents of the file (or NULL if they were not inlined) */ static void -trigger_recursive_download (void *cls, const char *filename, +trigger_recursive_download (void *cls, + const char *filename, const struct GNUNET_FS_Uri *uri, const struct GNUNET_CONTAINER_MetaData *meta, - size_t length, const void *data); + size_t length, + const void *data); /** @@ -304,24 +306,28 @@ full_recursive_download (struct GNUNET_FS_DownloadContext *dc) if (size64 != (uint64_t) size) { GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - _ - ("Recursive downloads of directories larger than 4 GB are not supported on 32-bit systems\n")); + _("Recursive downloads of directories larger than 4 GB are not supported on 32-bit systems\n")); return; } if (NULL != dc->filename) { - h = GNUNET_DISK_file_open (dc->filename, GNUNET_DISK_OPEN_READ, + h = GNUNET_DISK_file_open (dc->filename, + GNUNET_DISK_OPEN_READ, GNUNET_DISK_PERM_NONE); } else { GNUNET_assert (NULL != dc->temp_filename); - h = GNUNET_DISK_file_open (dc->temp_filename, GNUNET_DISK_OPEN_READ, + h = GNUNET_DISK_file_open (dc->temp_filename, + GNUNET_DISK_OPEN_READ, GNUNET_DISK_PERM_NONE); } if (NULL == h) return; /* oops */ - data = GNUNET_DISK_file_map (h, &m, GNUNET_DISK_MAP_TYPE_READ, size); + data = GNUNET_DISK_file_map (h, + &m, + GNUNET_DISK_MAP_TYPE_READ, + size); if (NULL == data) { GNUNET_log (GNUNET_ERROR_TYPE_ERROR, @@ -329,15 +335,25 @@ full_recursive_download (struct GNUNET_FS_DownloadContext *dc) } else { - GNUNET_FS_directory_list_contents (size, data, 0, - &trigger_recursive_download, dc); + if (GNUNET_OK != + GNUNET_FS_directory_list_contents (size, + data, + 0, + &trigger_recursive_download, + dc)) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + _("Failed to access full directroy contents of `%s' for recursive download\n"), + dc->filename); + } GNUNET_DISK_file_unmap (m); } GNUNET_DISK_file_close (h); if (NULL == dc->filename) { if (0 != UNLINK (dc->temp_filename)) - GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", + GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, + "unlink", dc->temp_filename); GNUNET_free (dc->temp_filename); dc->temp_filename = NULL; @@ -362,14 +378,17 @@ check_completed (struct GNUNET_FS_DownloadContext *dc) struct GNUNET_FS_DownloadContext *pos; /* first, check if we need to download children */ - if ((NULL == dc->child_head) && (is_recursive_download (dc))) + if ( (NULL == dc->child_head) && + (is_recursive_download (dc)) ) full_recursive_download (dc); /* then, check if children are done already */ for (pos = dc->child_head; NULL != pos; pos = pos->next) { - if ((pos->emsg == NULL) && (pos->completed < pos->length)) + if ( (NULL == pos->emsg) && + (pos->completed < pos->length) ) return; /* not done yet */ - if ((pos->child_head != NULL) && (pos->has_finished != GNUNET_YES)) + if ( (NULL != pos->child_head) && + (pos->has_finished != GNUNET_YES) ) return; /* not transitively done yet */ } /* All of our children are done, so mark this download done */ @@ -471,7 +490,11 @@ try_match_block (struct GNUNET_FS_DownloadContext *dc, } GNUNET_CRYPTO_hash (&data[dr->offset], dlen, &in_chk.key); GNUNET_CRYPTO_hash_to_aes_key (&in_chk.key, &sk, &iv); - if (-1 == GNUNET_CRYPTO_symmetric_encrypt (&data[dr->offset], dlen, &sk, &iv, enc)) + if (-1 == GNUNET_CRYPTO_symmetric_encrypt (&data[dr->offset], + dlen, + &sk, + &iv, + enc)) { GNUNET_break (0); return; @@ -484,7 +507,9 @@ try_match_block (struct GNUNET_FS_DownloadContext *dc, dr->state = BRS_RECONSTRUCT_META_UP; break; case BRS_CHK_SET: - if (0 != memcmp (&in_chk, &dr->chk, sizeof (struct ContentHashKey))) + if (0 != memcmp (&in_chk, + &dr->chk, + sizeof (struct ContentHashKey))) { /* other peer provided bogus meta data */ GNUNET_break_op (0); @@ -591,7 +616,10 @@ match_full_data (void *cls, const char *plugin_name, GNUNET_break_op (0); return 1; /* bogus meta data */ } - try_match_block (dc, dc->top_request, data, data_len); + try_match_block (dc, + dc->top_request, + data, + data_len); return 1; } @@ -820,10 +848,12 @@ schedule_block_download (struct GNUNET_FS_DownloadContext *dc, * @param data contents of the file (or NULL if they were not inlined) */ static void -trigger_recursive_download (void *cls, const char *filename, +trigger_recursive_download (void *cls, + const char *filename, const struct GNUNET_FS_Uri *uri, const struct GNUNET_CONTAINER_MetaData *meta, - size_t length, const void *data) + size_t length, + const void *data) { struct GNUNET_FS_DownloadContext *dc = cls; struct GNUNET_FS_DownloadContext *cpos; @@ -936,9 +966,17 @@ trigger_recursive_download (void *cls, const char *filename, (unsigned long long) GNUNET_FS_uri_chk_get_file_size (uri), (unsigned int) GNUNET_CONTAINER_meta_data_get_serialized_size (meta)); - GNUNET_FS_download_start (dc->h, uri, meta, full_name, temp_name, 0, + GNUNET_FS_download_start (dc->h, + uri, + meta, + full_name, + temp_name, + 0, GNUNET_FS_uri_chk_get_file_size (uri), - dc->anonymity, dc->options, NULL, dc); + dc->anonymity, + dc->options, + NULL, + dc); GNUNET_free_non_null (full_name); GNUNET_free_non_null (temp_name); GNUNET_free_non_null (fn); @@ -953,11 +991,9 @@ trigger_recursive_download (void *cls, const char *filename, void GNUNET_FS_free_download_request_ (struct DownloadRequest *dr) { - unsigned int i; - if (NULL == dr) return; - for (i = 0; i < dr->num_children; i++) + for (unsigned int i = 0; i < dr->num_children; i++) GNUNET_FS_free_download_request_ (dr->children[i]); GNUNET_free_non_null (dr->children); GNUNET_free (dr); @@ -1509,13 +1545,17 @@ create_download_request (struct DownloadRequest *parent, GNUNET_assert (dr->num_children > 0); dr->children = - GNUNET_malloc (dr->num_children * sizeof (struct DownloadRequest *)); + GNUNET_new_array (dr->num_children, + struct DownloadRequest *); for (i = 0; i < dr->num_children; i++) { dr->children[i] = - create_download_request (dr, i + head_skip, depth - 1, + create_download_request (dr, + i + head_skip, + depth - 1, dr_offset + (i + head_skip) * child_block_size, - file_start_offset, desired_length); + file_start_offset, + desired_length); } return dr; } diff --git a/src/fs/fs_search.c b/src/fs/fs_search.c index 3cbf2afef..e31115f39 100644 --- a/src/fs/fs_search.c +++ b/src/fs/fs_search.c @@ -1383,9 +1383,10 @@ GNUNET_FS_search_start_searching_ (struct GNUNET_FS_SearchContext *sc) GNUNET_assert (0 != sc->uri->data.ksk.keywordCount); anon = GNUNET_CRYPTO_ecdsa_key_get_anonymous (); GNUNET_CRYPTO_ecdsa_key_get_public (anon, &anon_pub); - sc->requests = - GNUNET_malloc (sizeof (struct SearchRequestEntry) * - sc->uri->data.ksk.keywordCount); + sc->requests + = GNUNET_new_array (sc->uri->data.ksk.keywordCount, + struct SearchRequestEntry); + for (i = 0; i < sc->uri->data.ksk.keywordCount; i++) { keyword = &sc->uri->data.ksk.keywords[i][1]; diff --git a/src/fs/fs_tree.c b/src/fs/fs_tree.c index b3c632203..e57e4e494 100644 --- a/src/fs/fs_tree.c +++ b/src/fs/fs_tree.c @@ -285,9 +285,9 @@ GNUNET_FS_tree_encoder_create (struct GNUNET_FS_Handle *h, uint64_t size, te->progress = progress; te->cont = cont; te->chk_tree_depth = GNUNET_FS_compute_depth (size); - te->chk_tree = - GNUNET_malloc (te->chk_tree_depth * CHK_PER_INODE * - sizeof (struct ContentHashKey)); + te->chk_tree + = GNUNET_new_array (te->chk_tree_depth * CHK_PER_INODE, + struct ContentHashKey); GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created tree encoder for file with %llu bytes and depth %u\n", (unsigned long long) size, diff --git a/src/fs/fs_uri.c b/src/fs/fs_uri.c index fa27e6e9b..11968b750 100644 --- a/src/fs/fs_uri.c +++ b/src/fs/fs_uri.c @@ -309,7 +309,8 @@ uri_ksk_parse (const char *s, } iret = max; dup = GNUNET_strdup (s); - keywords = GNUNET_malloc (max * sizeof (char *)); + keywords = GNUNET_new_array (max, + char *); for (i = slen - 1; i >= (int) pos; i--) { if ((s[i] == '%') && (&s[i] == strstr (&s[i], "%22"))) @@ -937,7 +938,8 @@ GNUNET_FS_uri_ksk_merge (const struct GNUNET_FS_Uri *u1, return NULL; } kc = u1->data.ksk.keywordCount; - kl = GNUNET_malloc ((kc + u2->data.ksk.keywordCount) * sizeof (char *)); + kl = GNUNET_new_array (kc + u2->data.ksk.keywordCount, + char *); for (i = 0; i < u1->data.ksk.keywordCount; i++) kl[i] = GNUNET_strdup (u1->data.ksk.keywords[i]); for (i = 0; i < u2->data.ksk.keywordCount; i++) @@ -991,8 +993,9 @@ GNUNET_FS_uri_dup (const struct GNUNET_FS_Uri *uri) } if (ret->data.ksk.keywordCount > 0) { - ret->data.ksk.keywords = - GNUNET_malloc (ret->data.ksk.keywordCount * sizeof (char *)); + ret->data.ksk.keywords + = GNUNET_new_array (ret->data.ksk.keywordCount, + char *); for (i = 0; i < ret->data.ksk.keywordCount; i++) ret->data.ksk.keywords[i] = GNUNET_strdup (uri->data.ksk.keywords[i]); } @@ -1078,7 +1081,8 @@ GNUNET_FS_uri_ksk_create (const char *keywords, *emsg = GNUNET_strdup (_("Number of double-quotes not balanced!\n")); return NULL; } - keywordarr = GNUNET_malloc (num_Words * sizeof (char *)); + keywordarr = GNUNET_new_array (num_Words, + char *); num_Words = 0; inWord = 0; pos = searchString; @@ -1151,7 +1155,8 @@ GNUNET_FS_uri_ksk_create_from_args (unsigned int argc, uri = GNUNET_new (struct GNUNET_FS_Uri); uri->type = GNUNET_FS_URI_KSK; uri->data.ksk.keywordCount = argc; - uri->data.ksk.keywords = GNUNET_malloc (argc * sizeof (char *)); + uri->data.ksk.keywords = GNUNET_new_array (argc, + char *); for (i = 0; i < argc; i++) { keyword = argv[i]; @@ -1766,8 +1771,9 @@ GNUNET_FS_uri_ksk_create_from_meta_data (const struct GNUNET_CONTAINER_MetaData } /* x3 because there might be a normalized variant of every keyword, plus theoretically one more for mime... */ - ret->data.ksk.keywords = GNUNET_malloc - (sizeof (char *) * (ent + tok_keywords + paren_keywords) * 3); + ret->data.ksk.keywords + = GNUNET_new_array ((ent + tok_keywords + paren_keywords) * 3, + char *); GNUNET_CONTAINER_meta_data_iterate (md, &gather_uri_data, ret); } if (tok_keywords > 0) -- cgit v1.2.3 From 8a32cac23d7289cfb7d1d356603a523cf6effd13 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sun, 5 Mar 2017 15:56:14 +0100 Subject: fix #4839 --- src/fs/fs_download.c | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'src') diff --git a/src/fs/fs_download.c b/src/fs/fs_download.c index ed24a164a..ce852f2d0 100644 --- a/src/fs/fs_download.c +++ b/src/fs/fs_download.c @@ -378,8 +378,7 @@ check_completed (struct GNUNET_FS_DownloadContext *dc) struct GNUNET_FS_DownloadContext *pos; /* first, check if we need to download children */ - if ( (NULL == dc->child_head) && - (is_recursive_download (dc)) ) + if (is_recursive_download (dc)) full_recursive_download (dc); /* then, check if children are done already */ for (pos = dc->child_head; NULL != pos; pos = pos->next) -- cgit v1.2.3 From 65f138e9a6156983ac74f8f1a5b8051d8f9be86a Mon Sep 17 00:00:00 2001 From: Daniel Golle Date: Sun, 5 Mar 2017 16:19:37 +0100 Subject: build profilers only if testing is enabled build fails of consensus and secretsharing fails otherwise make[7]: *** No rule to make target '../../src/testbed/libgnunettestbed.la', needed by 'gnunet-consensus-profiler'. Stop --- src/consensus/Makefile.am | 5 +++-- src/secretsharing/Makefile.am | 6 +++--- 2 files changed, 6 insertions(+), 5 deletions(-) (limited to 'src') diff --git a/src/consensus/Makefile.am b/src/consensus/Makefile.am index 2b1987fbc..c0205ee5d 100644 --- a/src/consensus/Makefile.am +++ b/src/consensus/Makefile.am @@ -18,8 +18,6 @@ if USE_COVERAGE AM_CFLAGS = -fprofile-arcs -ftest-coverage endif -bin_PROGRAMS = \ - gnunet-consensus-profiler libexec_PROGRAMS = \ gnunet-service-consensus @@ -86,6 +84,9 @@ libgnunet_plugin_block_consensus_la_LDFLAGS = \ if HAVE_TESTING +bin_PROGRAMS = \ + gnunet-consensus-profiler + check_PROGRAMS = \ test_consensus_api diff --git a/src/secretsharing/Makefile.am b/src/secretsharing/Makefile.am index 485183e36..4b9a06c40 100644 --- a/src/secretsharing/Makefile.am +++ b/src/secretsharing/Makefile.am @@ -17,9 +17,6 @@ if USE_COVERAGE endif -bin_PROGRAMS = \ - gnunet-secretsharing-profiler - libexec_PROGRAMS = \ gnunet-service-secretsharing @@ -57,6 +54,9 @@ libgnunetsecretsharing_la_LDFLAGS = \ $(GN_LIB_LDFLAGS) if HAVE_TESTING +bin_PROGRAMS = \ + gnunet-secretsharing-profiler + check_PROGRAMS = \ test_secretsharing_api -- cgit v1.2.3 From 542de3e5df8dbe2bfc3d4290e75f5684e0deaf59 Mon Sep 17 00:00:00 2001 From: David Barksdale Date: Mon, 6 Mar 2017 21:28:43 -0600 Subject: Update comment to match code --- src/fs/fs_unindex.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src') diff --git a/src/fs/fs_unindex.c b/src/fs/fs_unindex.c index a672b84d5..ad1499f00 100644 --- a/src/fs/fs_unindex.c +++ b/src/fs/fs_unindex.c @@ -454,7 +454,8 @@ continue_after_remove (void *cls, * Function called from datastore with result from us looking for * a UBlock. There are four cases: * 1) no result, means we move on to the next keyword - * 2) UID is the same as the first UID, means we move on to next keyword + * 2) data hash is the same as an already seen data hash, means we move on to + * next keyword * 3) UBlock for a different CHK, means we keep looking for more * 4) UBlock is for our CHK, means we remove the block and then move * on to the next keyword -- cgit v1.2.3 From 831572e37e88c219e13d558d9abac23160a10741 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Tue, 7 Mar 2017 23:46:34 +0100 Subject: remove dead API --- src/include/gnunet_core_service.h | 53 +-------------------------------------- 1 file changed, 1 insertion(+), 52 deletions(-) (limited to 'src') diff --git a/src/include/gnunet_core_service.h b/src/include/gnunet_core_service.h index 8136770b7..ace223c11 100644 --- a/src/include/gnunet_core_service.h +++ b/src/include/gnunet_core_service.h @@ -1,6 +1,6 @@ /* This file is part of GNUnet. - Copyright (C) 2009-2014, 2016 GNUnet e.V. + Copyright (C) 2009-2017 GNUnet e.V. GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published @@ -196,57 +196,6 @@ GNUNET_CORE_get_mq (const struct GNUNET_CORE_Handle *h, const struct GNUNET_PeerIdentity *pid); -/** - * Handle for a transmission request. - */ -struct GNUNET_CORE_TransmitHandle; - - -/** - * Ask the core to call @a notify once it is ready to transmit the - * given number of bytes to the specified @a target. Must only be - * called after a connection to the respective peer has been - * established (and the client has been informed about this). You may - * have one request of this type pending for each connected peer at - * any time. If a peer disconnects, the application MUST call - * #GNUNET_CORE_notify_transmit_ready_cancel() on the respective - * transmission request, if one such request is pending. - * - * @param handle connection to core service - * @param cork is corking allowed for this transmission? - * @param priority how important is the message? - * @param maxdelay how long can the message wait? Only effective if @a cork is #GNUNET_YES - * @param target who should receive the message, never NULL (can be this peer's identity for loopback) - * @param notify_size how many bytes of buffer space does @a notify want? - * @param notify function to call when buffer space is available; - * will be called with NULL on timeout; clients MUST cancel - * all pending transmission requests DURING the disconnect - * handler - * @param notify_cls closure for @a notify - * @return non-NULL if the notify callback was queued, - * NULL if we can not even queue the request (request already pending); - * if NULL is returned, @a notify will NOT be called. - */ -struct GNUNET_CORE_TransmitHandle * -GNUNET_CORE_notify_transmit_ready (struct GNUNET_CORE_Handle *handle, - int cork, - enum GNUNET_CORE_Priority priority, - struct GNUNET_TIME_Relative maxdelay, - const struct GNUNET_PeerIdentity *target, - size_t notify_size, - GNUNET_CONNECTION_TransmitReadyNotify notify, - void *notify_cls); - - -/** - * Cancel the specified transmission-ready notification. - * - * @param th handle that was returned by #GNUNET_CORE_notify_transmit_ready(). - */ -void -GNUNET_CORE_notify_transmit_ready_cancel (struct GNUNET_CORE_TransmitHandle *th); - - /** * Handle to a CORE monitoring operation. */ -- cgit v1.2.3 From baffe75109684b28fbf814582984cc780ca93951 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Wed, 8 Mar 2017 15:05:40 +0100 Subject: fix more of #4890 --- src/arm/gnunet-arm.c | 38 ++++++++++++++++++-------------------- 1 file changed, 18 insertions(+), 20 deletions(-) (limited to 'src') diff --git a/src/arm/gnunet-arm.c b/src/arm/gnunet-arm.c index 65a6463cf..3c52137bc 100644 --- a/src/arm/gnunet-arm.c +++ b/src/arm/gnunet-arm.c @@ -245,27 +245,27 @@ ret_string (enum GNUNET_ARM_Result result) switch (result) { case GNUNET_ARM_RESULT_STOPPED: - return _("%s is stopped"); + return _("is stopped"); case GNUNET_ARM_RESULT_STARTING: - return _("%s is starting"); + return _("is starting"); case GNUNET_ARM_RESULT_STOPPING: - return _("%s is stopping"); + return _("is stopping"); case GNUNET_ARM_RESULT_IS_STARTING_ALREADY: - return _("%s is starting already"); + return _("is starting already"); case GNUNET_ARM_RESULT_IS_STOPPING_ALREADY: - return _("%s is stopping already"); + return _("is stopping already"); case GNUNET_ARM_RESULT_IS_STARTED_ALREADY: - return _("%s is started already"); + return _("is started already"); case GNUNET_ARM_RESULT_IS_STOPPED_ALREADY: - return _("%s is stopped already"); + return _("is stopped already"); case GNUNET_ARM_RESULT_IS_NOT_KNOWN: - return _("%s service is not known to ARM"); + return _("service is not known to ARM"); case GNUNET_ARM_RESULT_START_FAILED: - return _("%s service failed to start"); + return _("service failed to start"); case GNUNET_ARM_RESULT_IN_SHUTDOWN: - return _("%s service cannot be started because ARM is shutting down"); + return _("service cannot be started because ARM is shutting down"); } - return _("%.s Unknown result code."); + return _("Unknown result code."); } @@ -378,10 +378,9 @@ stop_callback (void *cls, (GNUNET_ARM_RESULT_STOPPED != result) && (GNUNET_ARM_RESULT_IS_STOPPED_ALREADY != result)) { - GNUNET_asprintf (&msg, "%s", - _("Failed to stop the ARM service: %s\n")); - FPRINTF (stdout, msg, ret_string (result)); - GNUNET_free (msg); + FPRINTF (stdout, + _("Failed to stop the ARM service: %s\n"), + ret_string (result)); GNUNET_SCHEDULER_shutdown (); return; } @@ -476,11 +475,10 @@ term_callback (void *cls, if ((GNUNET_ARM_RESULT_STOPPED != result) && (GNUNET_ARM_RESULT_IS_STOPPED_ALREADY != result)) { - GNUNET_asprintf (&msg, - _("Failed to kill the `%s' service: %s\n"), - term, ret_string (result)); - FPRINTF (stdout, "%s", msg); - GNUNET_free (msg); + FPRINTF (stdout, + _("Failed to kill the `%s' service: %s\n"), + term, + ret_string (result)); GNUNET_SCHEDULER_shutdown (); return; } -- cgit v1.2.3 From 95646a7b495153841c53034abca516c9261b2fb7 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Wed, 8 Mar 2017 18:54:17 +0100 Subject: remove dead enum values --- src/arm/gnunet-arm.c | 8 +------- src/include/gnunet_arm_service.h | 18 +----------------- src/testbed/gnunet-service-testbed_peers.c | 6 ------ 3 files changed, 2 insertions(+), 30 deletions(-) (limited to 'src') diff --git a/src/arm/gnunet-arm.c b/src/arm/gnunet-arm.c index 3c52137bc..49886eb56 100644 --- a/src/arm/gnunet-arm.c +++ b/src/arm/gnunet-arm.c @@ -220,14 +220,8 @@ req_string (enum GNUNET_ARM_RequestStatus rs) { case GNUNET_ARM_REQUEST_SENT_OK: return _("Message was sent successfully"); - case GNUNET_ARM_REQUEST_CONFIGURATION_ERROR: - return _("Misconfiguration (can not connect to the ARM service)"); case GNUNET_ARM_REQUEST_DISCONNECTED: return _("We disconnected from ARM before we could send a request"); - case GNUNET_ARM_REQUEST_BUSY: - return _("ARM API is busy"); - case GNUNET_ARM_REQUEST_TIMEOUT: - return _("Request timed out"); } return _("Unknown request status"); } @@ -263,7 +257,7 @@ ret_string (enum GNUNET_ARM_Result result) case GNUNET_ARM_RESULT_START_FAILED: return _("service failed to start"); case GNUNET_ARM_RESULT_IN_SHUTDOWN: - return _("service cannot be started because ARM is shutting down"); + return _("service cannot be manipulated because ARM is shutting down"); } return _("Unknown result code."); } diff --git a/src/include/gnunet_arm_service.h b/src/include/gnunet_arm_service.h index 7fb14d3ac..f8d71bd8b 100644 --- a/src/include/gnunet_arm_service.h +++ b/src/include/gnunet_arm_service.h @@ -61,26 +61,10 @@ enum GNUNET_ARM_RequestStatus */ GNUNET_ARM_REQUEST_SENT_OK = 0, - /** - * Misconfiguration (can't connect to the ARM service). - */ - GNUNET_ARM_REQUEST_CONFIGURATION_ERROR = 1, - /** * We disconnected from ARM, and request was not sent. */ - GNUNET_ARM_REQUEST_DISCONNECTED = 2, - - /** - * ARM API is busy (probably trying to connect to ARM), - * and request was not sent. Try again later. - */ - GNUNET_ARM_REQUEST_BUSY = 3, - - /** - * Request time ran out before we had a chance to send it. - */ - GNUNET_ARM_REQUEST_TIMEOUT = 5 + GNUNET_ARM_REQUEST_DISCONNECTED = 2 }; diff --git a/src/testbed/gnunet-service-testbed_peers.c b/src/testbed/gnunet-service-testbed_peers.c index a977b2b9b..aacd62583 100644 --- a/src/testbed/gnunet-service-testbed_peers.c +++ b/src/testbed/gnunet-service-testbed_peers.c @@ -1137,14 +1137,8 @@ arm_req_string (enum GNUNET_ARM_RequestStatus rs) { case GNUNET_ARM_REQUEST_SENT_OK: return _("Message was sent successfully"); - case GNUNET_ARM_REQUEST_CONFIGURATION_ERROR: - return _("Misconfiguration (can't connect to the ARM service)"); case GNUNET_ARM_REQUEST_DISCONNECTED: return _("We disconnected from ARM before we could send a request"); - case GNUNET_ARM_REQUEST_BUSY: - return _("ARM API is busy"); - case GNUNET_ARM_REQUEST_TIMEOUT: - return _("Request timed out"); } return _("Unknown request status"); } -- cgit v1.2.3