/*
This file is part of GNUnet.
- (C) 2001, 2002, 2003, 2004, 2005, 2006, 2008, 2009, 2010, 2011 Christian Grothoff (and other contributing authors)
+ (C) 2001--2012 Christian Grothoff (and other contributing authors)
GNUnet is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published
#include "fs_api.h"
#include "fs_tree.h"
+/**
+ * How many block requests can we have outstanding in parallel at a time by default?
+ */
+#define DEFAULT_MAX_PARALLEL_REQUESTS (1024 * 10)
+
+/**
+ * How many downloads can we have outstanding in parallel at a time by default?
+ */
+#define DEFAULT_MAX_PARALLEL_DOWNLOADS 16
/**
* Start the given job (send signal, remove from pending queue, update
{
GNUNET_assert (NULL == qe->client);
qe->client = GNUNET_CLIENT_connect ("fs", qe->h->cfg);
- if (qe->client == NULL)
+ if (NULL == qe->client)
{
GNUNET_break (0);
return;
qe->start (qe->cls, qe->client);
qe->start_times++;
qe->h->active_blocks += qe->blocks;
+ qe->h->active_downloads++;
qe->start_time = GNUNET_TIME_absolute_get ();
GNUNET_CONTAINER_DLL_remove (qe->h->pending_head, qe->h->pending_tail, qe);
GNUNET_CONTAINER_DLL_insert_after (qe->h->running_head, qe->h->running_tail,
{
qe->client = NULL;
qe->stop (qe->cls);
+ GNUNET_assert (0 < qe->h->active_downloads);
qe->h->active_downloads--;
qe->h->active_blocks -= qe->blocks;
qe->run_time =
struct GNUNET_TIME_Relative restart_at;
struct GNUNET_TIME_Relative rst;
struct GNUNET_TIME_Absolute end_time;
+ unsigned int num_downloads_waiting;
+ unsigned int num_downloads_active;
+ unsigned int num_downloads_expired;
+ unsigned int num_probes_active;
+ unsigned int num_probes_waiting;
+ unsigned int num_probes_expired;
+ int num_probes_change;
+ int num_downloads_change;
+ int block_limit_hit;
h->queue_job = GNUNET_SCHEDULER_NO_TASK;
- next = h->pending_head;
- while (NULL != (qe = next))
+ /* restart_at will be set to the time when it makes sense to
+ re-evaluate the job queue (unless, of course, jobs complete
+ or are added, then we'll be triggered immediately */
+ restart_at = GNUNET_TIME_UNIT_FOREVER_REL;
+ /* first, calculate some basic statistics on pending jobs */
+ num_probes_waiting = 0;
+ num_downloads_waiting = 0;
+ for (qe = h->pending_head; NULL != qe; qe = qe->next)
{
- next = qe->next;
- if (h->running_head == NULL)
- {
- start_job (qe);
- continue;
- }
- if ((qe->blocks + h->active_blocks <= h->max_parallel_requests) &&
- (h->active_downloads + 1 <= h->max_parallel_downloads))
+ switch (qe->priority)
{
- start_job (qe);
- continue;
+ case GNUNET_FS_QUEUE_PRIORITY_PROBE:
+ num_probes_waiting++;
+ break;
+ case GNUNET_FS_QUEUE_PRIORITY_NORMAL:
+ num_downloads_waiting++;
+ break;
+ default:
+ GNUNET_break (0);
+ break;
}
}
- if (h->pending_head == NULL)
- return; /* no need to stop anything */
- restart_at = GNUNET_TIME_UNIT_FOREVER_REL;
+ /* now, calculate some basic statistics on running jobs */
+ num_probes_active = 0;
+ num_probes_expired = 0;
+ num_downloads_active = 0;
+ num_downloads_expired = 0;
next = h->running_head;
while (NULL != (qe = next))
{
next = qe->next;
- run_time =
+ switch (qe->priority)
+ {
+ case GNUNET_FS_QUEUE_PRIORITY_PROBE:
+ run_time = GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 2);
+ end_time = GNUNET_TIME_absolute_add (qe->start_time, run_time);
+ rst = GNUNET_TIME_absolute_get_remaining (end_time);
+ if (0 == rst.rel_value)
+ {
+ num_probes_expired++;
+ stop_job (qe);
+ }
+ else
+ {
+ num_probes_active++;
+ restart_at = GNUNET_TIME_relative_min (rst, restart_at);
+ }
+ break;
+ case GNUNET_FS_QUEUE_PRIORITY_NORMAL:
+ run_time =
GNUNET_TIME_relative_multiply (h->avg_block_latency,
qe->blocks * qe->start_times);
- end_time = GNUNET_TIME_absolute_add (qe->start_time, run_time);
- rst = GNUNET_TIME_absolute_get_remaining (end_time);
- restart_at = GNUNET_TIME_relative_min (rst, restart_at);
- if (rst.rel_value > 0)
+ end_time = GNUNET_TIME_absolute_add (qe->start_time, run_time);
+ rst = GNUNET_TIME_absolute_get_remaining (end_time);
+ if (0 == rst.rel_value)
+ {
+ num_downloads_expired++;
+ stop_job (qe);
+ }
+ else
+ {
+ num_downloads_active++;
+ restart_at = GNUNET_TIME_relative_min (rst, restart_at);
+ }
+ break;
+ default:
+ GNUNET_break (0);
+ break;
+ }
+ }
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "PA: %u, PE: %u, PW: %u; DA: %u, DE: %u, DW: %u\n",
+ num_probes_active,
+ num_probes_expired,
+ num_probes_waiting,
+ num_downloads_active,
+ num_downloads_expired,
+ num_downloads_waiting);
+ /* calculate start/stop decisions */
+ if (h->active_downloads + num_downloads_waiting > h->max_parallel_requests)
+ {
+ /* stop probes if possible */
+ num_probes_change = - num_probes_active;
+ num_downloads_change = h->max_parallel_requests - h->active_downloads;
+ }
+ else
+ {
+ /* start all downloads */
+ num_downloads_change = num_downloads_waiting;
+ /* start as many probes as we can */
+ num_probes_change = GNUNET_MIN (num_probes_waiting,
+ h->max_parallel_requests - (h->active_downloads + num_downloads_waiting));
+ }
+
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Changing %d probes and %d downloads\n",
+ num_probes_change,
+ num_downloads_change);
+ /* actually stop probes */
+ next = h->running_head;
+ while (NULL != (qe = next))
+ {
+ next = qe->next;
+ if (GNUNET_FS_QUEUE_PRIORITY_PROBE != qe->priority)
continue;
- stop_job (qe);
+ if (num_probes_change < 0)
+ {
+ stop_job (qe);
+ num_probes_change++;
+ if (0 == num_probes_change)
+ break;
+ }
+ }
+ GNUNET_break (0 <= num_probes_change);
+
+ /* start some more tasks if we now have empty slots */
+ block_limit_hit = GNUNET_NO;
+ next = h->pending_head;
+ while ( (NULL != (qe = next)) &&
+ ( (num_probes_change > 0) ||
+ (num_downloads_change > 0) ) )
+ {
+ next = qe->next;
+ switch (qe->priority)
+ {
+ case GNUNET_FS_QUEUE_PRIORITY_PROBE:
+ if (num_probes_change > 0)
+ {
+ start_job (qe);
+ num_probes_change--;
+ run_time = GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 2);
+ restart_at = GNUNET_TIME_relative_min (run_time, restart_at);
+ }
+ break;
+ case GNUNET_FS_QUEUE_PRIORITY_NORMAL:
+ if ( (num_downloads_change > 0) &&
+ ( (qe->blocks + h->active_blocks <= h->max_parallel_requests) ||
+ ( (qe->blocks > h->max_parallel_requests) &&
+ (0 == h->active_downloads) ) ) )
+ {
+ start_job (qe);
+ num_downloads_change--;
+ }
+ else if (num_downloads_change > 0)
+ block_limit_hit = GNUNET_YES;
+ break;
+ default:
+ GNUNET_break (0);
+ break;
+ }
}
+ GNUNET_break ( (0 == num_downloads_change) || (GNUNET_YES == block_limit_hit) );
+ GNUNET_break (0 == num_probes_change);
+
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "AD: %u, MP: %u; %d probes and %d downloads to start, will run again in %s\n",
+ h->active_downloads,
+ h->max_parallel_requests,
+ num_probes_change,
+ num_downloads_change,
+ GNUNET_STRINGS_relative_time_to_string (restart_at, GNUNET_YES));
+
+ /* make sure we run again */
h->queue_job =
GNUNET_SCHEDULER_add_delayed (restart_at, &process_job_queue, h);
}
* @param stop function to call to pause the job, or on dequeue (if the job was running)
* @param cls closure for start and stop
* @param blocks number of blocks this jobs uses
+ * @param priority how important is this download
* @return queue handle
*/
struct GNUNET_FS_QueueEntry *
GNUNET_FS_queue_ (struct GNUNET_FS_Handle *h, GNUNET_FS_QueueStart start,
- GNUNET_FS_QueueStop stop, void *cls, unsigned int blocks)
+ GNUNET_FS_QueueStop stop, void *cls, unsigned int blocks,
+ enum GNUNET_FS_QueuePriority priority)
{
struct GNUNET_FS_QueueEntry *qe;
qe->cls = cls;
qe->queue_time = GNUNET_TIME_absolute_get ();
qe->blocks = blocks;
+ qe->priority = priority;
GNUNET_CONTAINER_DLL_insert_after (h->pending_head, h->pending_tail,
h->pending_tail, qe);
if (h->queue_job != GNUNET_SCHEDULER_NO_TASK)
struct GNUNET_FS_Handle *h;
h = qh->h;
- if (qh->client != NULL)
+ if (NULL != qh->client)
stop_job (qh);
GNUNET_CONTAINER_DLL_remove (h->pending_head, h->pending_tail, qh);
GNUNET_free (qh);
* @param cls closure (points to the file information)
* @param offset offset to read from; it is possible
* that the caller might need to go backwards
- * a bit at times
+ * a bit at times; set to UINT64_MAX to tell
+ * the reader that we won't be reading for a while
+ * (used to close the file descriptor but NOT fully
+ * clean up the reader's state); in this case,
+ * a value of '0' for max should be ignored
* @param max maximum number of bytes that should be
* copied to buf; readers are not allowed
* to provide less data unless there is an error;
struct FileInfo *fi = cls;
ssize_t ret;
- if (max == 0)
+ if (UINT64_MAX == offset)
+ {
+ if (NULL != fi->fd)
+ {
+ GNUNET_DISK_file_close (fi->fd);
+ fi->fd = NULL;
+ }
+ return 0;
+ }
+ if (0 == max)
{
- if (fi->fd != NULL)
+ if (NULL != fi->fd)
GNUNET_DISK_file_close (fi->fd);
GNUNET_free (fi->filename);
GNUNET_free (fi);
return 0;
}
- if (fi->fd == NULL)
+ if (NULL == fi->fd)
{
fi->fd =
GNUNET_DISK_file_open (fi->filename, GNUNET_DISK_OPEN_READ,
GNUNET_DISK_PERM_NONE);
- if (fi->fd == NULL)
+ if (NULL == fi->fd)
{
GNUNET_asprintf (emsg, _("Could not open file `%s': %s"), fi->filename,
STRERROR (errno));
return 0;
}
}
- GNUNET_DISK_file_seek (fi->fd, offset, GNUNET_DISK_SEEK_SET);
- ret = GNUNET_DISK_file_read (fi->fd, buf, max);
- if (ret == -1)
+ if ( (GNUNET_SYSERR ==
+ GNUNET_DISK_file_seek (fi->fd, offset, GNUNET_DISK_SEEK_SET)) ||
+ (-1 == (ret = GNUNET_DISK_file_read (fi->fd, buf, max))) )
{
GNUNET_asprintf (emsg, _("Could not read file `%s': %s"), fi->filename,
STRERROR (errno));
fi = GNUNET_malloc (sizeof (struct FileInfo));
fi->filename = GNUNET_STRINGS_filename_expand (filename);
- if (fi->filename == NULL)
+ if (NULL == fi->filename)
{
GNUNET_free (fi);
return NULL;
* @param cls closure (points to the buffer)
* @param offset offset to read from; it is possible
* that the caller might need to go backwards
- * a bit at times
+ * a bit at times; set to UINT64_MAX to tell
+ * the reader that we won't be reading for a while
+ * (used to close the file descriptor but NOT fully
+ * clean up the reader's state); in this case,
+ * a value of '0' for max should be ignored
* @param max maximum number of bytes that should be
* copied to buf; readers are not allowed
* to provide less data unless there is an error;
{
char *data = cls;
- if (max == 0)
+ if (UINT64_MAX == offset)
+ return 0;
+ if (0 == max)
{
GNUNET_free_non_null (data);
return 0;
struct GNUNET_BIO_ReadHandle *ret;
fn = get_serialization_file_name (h, ext, ent);
- if (fn == NULL)
+ if (NULL == fn)
return NULL;
ret = GNUNET_BIO_read_open (fn);
GNUNET_free (fn);
struct GNUNET_BIO_WriteHandle *ret;
fn = get_serialization_file_name (h, ext, ent);
- if (fn == NULL)
- {
+ if (NULL == fn)
return NULL;
- }
ret = GNUNET_BIO_write_open (fn);
- if (ret == NULL)
- GNUNET_break (0);
+ GNUNET_break (NULL != ret);
GNUNET_free (fn);
return ret;
}
struct GNUNET_BIO_WriteHandle *ret;
fn = get_serialization_file_name_in_dir (h, ext, uni, ent);
- if (fn == NULL)
+ if (NULL == fn)
return NULL;
ret = GNUNET_BIO_write_open (fn);
GNUNET_free (fn);
return;
}
filename = get_serialization_file_name (h, ext, ent);
- if (filename != NULL)
+ if (NULL != filename)
{
if (0 != UNLINK (filename))
GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", filename);
return;
}
filename = get_serialization_file_name_in_dir (h, ext, uni, ent);
- if (filename != NULL)
- {
- if (0 != UNLINK (filename))
- GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", filename);
- GNUNET_free (filename);
- }
+ if (NULL == filename)
+ return;
+ if (0 != UNLINK (filename))
+ GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", filename);
+ GNUNET_free (filename);
}
{
char *dn;
- if (uni == NULL)
+ if (NULL == uni)
return;
dn = get_serialization_file_name_in_dir (h, ext, uni, "");
- if (dn == NULL)
+ if (NULL == dn)
return;
if ((GNUNET_OK == GNUNET_DISK_directory_test (dn)) &&
(GNUNET_OK != GNUNET_DISK_directory_remove (dn)))
filename = NULL;
if ((GNUNET_OK != GNUNET_BIO_read_meta_data (rh, "metadata", &ret->meta)) ||
(GNUNET_OK != GNUNET_BIO_read_string (rh, "ksk-uri", &ksks, 32 * 1024)) ||
- ((ksks != NULL) &&
- (NULL == (ret->keywords = GNUNET_FS_uri_parse (ksks, NULL)))) ||
- (GNUNET_YES != GNUNET_FS_uri_test_ksk (ret->keywords)) ||
+ ( (NULL != ksks) &&
+ ( (NULL == (ret->keywords = GNUNET_FS_uri_parse (ksks, NULL))) ||
+ (GNUNET_YES != GNUNET_FS_uri_test_ksk (ret->keywords)) ) ) ||
(GNUNET_OK != GNUNET_BIO_read_string (rh, "chk-uri", &chks, 1024)) ||
- ((chks != NULL) &&
- ((NULL == (ret->chk_uri = GNUNET_FS_uri_parse (chks, NULL))) ||
- (GNUNET_YES != GNUNET_FS_uri_test_chk (ret->chk_uri)))) ||
+ ( (NULL != chks) &&
+ ( (NULL == (ret->chk_uri = GNUNET_FS_uri_parse (chks, NULL))) ||
+ (GNUNET_YES != GNUNET_FS_uri_test_chk (ret->chk_uri))) ) ||
(GNUNET_OK != read_start_time (rh, &ret->start_time)) ||
(GNUNET_OK != GNUNET_BIO_read_string (rh, "emsg", &ret->emsg, 16 * 1024))
|| (GNUNET_OK !=
if ((GNUNET_OK != GNUNET_BIO_read_int64 (rh, &ret->data.file.file_size)) ||
(GNUNET_OK !=
GNUNET_BIO_read (rh, "fileid", &ret->data.file.file_id,
- sizeof (GNUNET_HashCode))))
+ sizeof (struct GNUNET_HashCode))))
{
GNUNET_break (0);
goto cleanup;
if ((GNUNET_OK != GNUNET_BIO_read_int64 (rh, &ret->data.file.file_size)) ||
(GNUNET_OK !=
GNUNET_BIO_read (rh, "fileid", &ret->data.file.file_id,
- sizeof (GNUNET_HashCode))))
+ sizeof (struct GNUNET_HashCode))))
{
GNUNET_break (0);
goto cleanup;
goto cleanup;
}
ret->data.dir.dir_size = (uint32_t) dsize;
- if (filename != NULL)
+ if (NULL != filename)
{
ret->data.dir.entries = deserialize_file_information (h, filename);
GNUNET_free (filename);
filename = NULL;
nxt = ret->data.dir.entries;
- while (nxt != NULL)
+ while (NULL != nxt)
{
nxt->dir = ret;
nxt = nxt->next;
GNUNET_break (0);
goto cleanup;
}
- if (filename != NULL)
+ if (NULL != filename)
{
ret->next = deserialize_file_information (h, filename);
GNUNET_free (filename);
struct GNUNET_FS_FileInformation *ret;
struct GNUNET_BIO_ReadHandle *rh;
char *emsg;
+ char *fn;
rh = get_read_handle (h, GNUNET_FS_SYNC_PATH_FILE_INFO, filename);
- if (rh == NULL)
+ if (NULL == rh)
return NULL;
ret = deserialize_fi_node (h, filename, rh);
if (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg))
filename, emsg);
GNUNET_free (emsg);
}
- if (ret == NULL)
+ if (NULL == ret)
{
- if (0 != UNLINK (filename))
- GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", filename);
+ fn = get_serialization_file_name (h, GNUNET_FS_SYNC_PATH_FILE_INFO, filename);
+ if (NULL != fn)
+ {
+ if (0 != UNLINK (fn))
+ GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", fn);
+ GNUNET_free (fn);
+ }
}
return ret;
}
end = nxt + 1;
nxt++;
}
- if ((end == NULL) || (strlen (end) == 0))
+ if ((NULL == end) || (0 == strlen (end)))
{
GNUNET_break (0);
return NULL;
if (0 == (h->flags & GNUNET_FS_FLAGS_PERSISTENCE))
return NULL; /* persistence not requested */
dn = get_serialization_file_name (h, ext, "");
- if (dn == NULL)
+ if (NULL == dn)
return NULL;
if (GNUNET_OK != GNUNET_DISK_directory_create_for_file (dn))
{
}
fn = GNUNET_DISK_mktemp (dn);
GNUNET_free (dn);
- if (fn == NULL)
+ if (NULL == fn)
return NULL; /* epic fail */
ret = get_serialization_short_name (fn);
GNUNET_free (fn);
if (0 == (h->flags & GNUNET_FS_FLAGS_PERSISTENCE))
return NULL; /* persistence not requested */
dn = get_serialization_file_name_in_dir (h, ext, uni, "");
- if (dn == NULL)
+ if (NULL == dn)
return NULL;
if (GNUNET_OK != GNUNET_DISK_directory_create_for_file (dn))
{
}
fn = GNUNET_DISK_mktemp (dn);
GNUNET_free (dn);
- if (fn == NULL)
+ if (NULL == fn)
return NULL; /* epic fail */
ret = get_serialization_short_name (fn);
GNUNET_free (fn);
left = GNUNET_MIN (sizeof (buf), fi->data.file.file_size - off);
ret =
fi->data.file.reader (fi->data.file.reader_cls, off, left, buf, &emsg);
- if (ret == 0)
+ if (0 == ret)
{
GNUNET_free (emsg);
return GNUNET_SYSERR;
return;
wh = get_write_handle (fi->h, GNUNET_FS_SYNC_PATH_FILE_INFO,
fi->serialization);
- if (wh == NULL)
+ if (NULL == wh)
{
GNUNET_free (fi->serialization);
fi->serialization = NULL;
b = 1;
else
b = 0;
- if (fi->keywords != NULL)
+ if (NULL != fi->keywords)
ksks = GNUNET_FS_uri_to_string (fi->keywords);
else
ksks = NULL;
- if (fi->chk_uri != NULL)
+ if (NULL != fi->chk_uri)
chks = GNUNET_FS_uri_to_string (fi->chk_uri);
else
chks = NULL;
if ((GNUNET_OK != GNUNET_BIO_write_int64 (wh, fi->data.file.file_size)) ||
(GNUNET_OK !=
GNUNET_BIO_write (wh, &fi->data.file.file_id,
- sizeof (GNUNET_HashCode))))
+ sizeof (struct GNUNET_HashCode))))
{
GNUNET_break (0);
goto cleanup;
}
return; /* done! */
cleanup:
- if (wh != NULL)
+ if (NULL != wh)
(void) GNUNET_BIO_write_close (wh);
GNUNET_free_non_null (chks);
GNUNET_free_non_null (ksks);
{
struct GNUNET_FS_FileInformation *r;
- while (pos != NULL)
+ while (NULL != pos)
{
if (0 == strcmp (srch, pos->serialization))
return pos;
- if (pos->is_directory)
- {
- r = find_file_position (pos->data.dir.entries, srch);
- if (r != NULL)
- return r;
- }
+ if ( (GNUNET_YES == pos->is_directory) &&
+ (NULL != (r = find_file_position (pos->data.dir.entries, srch))) )
+ return r;
pos = pos->next;
}
return NULL;
struct GNUNET_FS_BlockOptions *bo, int *do_index,
void **client_info)
{
- struct GNUNET_FS_PublishContext *sc = cls;
+ struct GNUNET_FS_PublishContext *pc = cls;
struct GNUNET_FS_ProgressInfo pi;
+ if (GNUNET_YES == pc->skip_next_fi_callback)
+ {
+ pc->skip_next_fi_callback = GNUNET_NO;
+ return GNUNET_OK;
+ }
pi.status = GNUNET_FS_STATUS_PUBLISH_RESUME;
- pi.value.publish.specifics.resume.message = sc->fi->emsg;
- pi.value.publish.specifics.resume.chk_uri = sc->fi->chk_uri;
- *client_info = GNUNET_FS_publish_make_status_ (&pi, sc, fi, 0);
+ pi.value.publish.specifics.resume.message = pc->fi->emsg;
+ pi.value.publish.specifics.resume.chk_uri = pc->fi->chk_uri;
+ *client_info = GNUNET_FS_publish_make_status_ (&pi, pc, fi, 0);
+ if (GNUNET_YES == GNUNET_FS_meta_data_test_for_directory (meta))
+ {
+ /* process entries in directory */
+ pc->skip_next_fi_callback = GNUNET_YES;
+ GNUNET_FS_file_information_inspect (fi, &fip_signal_resume, pc);
+ }
return GNUNET_OK;
}
fi_pos = NULL;
ns = NULL;
rh = GNUNET_BIO_read_open (filename);
- if (rh == NULL)
+ if (NULL == rh)
{
GNUNET_break (0);
goto cleanup;
goto cleanup;
}
pc->fi = deserialize_file_information (h, fi_root);
- if (pc->fi == NULL)
+ if (NULL == pc->fi)
{
GNUNET_break (0);
goto cleanup;
}
- if (ns != NULL)
+ if (NULL != ns)
{
- pc->namespace = GNUNET_FS_namespace_create (h, ns);
- if (pc->namespace == NULL)
+ pc->ns = GNUNET_FS_namespace_create (h, ns);
+ if (NULL == pc->ns)
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
_
if (NULL == pc->dsh)
goto cleanup;
}
- if (fi_pos != NULL)
+ if (NULL != fi_pos)
{
pc->fi_pos = find_file_position (pc->fi, fi_pos);
GNUNET_free (fi_pos);
fi_pos = NULL;
- if (pc->fi_pos == NULL)
+ if (NULL == pc->fi_pos)
{
/* failed to find position for resuming, outch! Will start from root! */
GNUNET_break (0);
- if (pc->all_done != GNUNET_YES)
+ if (GNUNET_YES != pc->all_done)
pc->fi_pos = pc->fi;
}
}
GNUNET_FS_file_information_inspect (pc->fi, &fip_signal_resume, pc);
/* re-start publishing (if needed)... */
- if (pc->all_done != GNUNET_YES)
+ if (GNUNET_YES != pc->all_done)
{
GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == pc->upload_task);
pc->upload_task =
GNUNET_SCHEDULER_add_with_priority
- (GNUNET_SCHEDULER_PRIORITY_BACKGROUND, &GNUNET_FS_publish_main_, pc);
+ (GNUNET_SCHEDULER_PRIORITY_BACKGROUND,
+ &GNUNET_FS_publish_main_, pc);
}
if (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg))
{
GNUNET_free_non_null (fi_root);
GNUNET_free_non_null (fi_pos);
GNUNET_free_non_null (ns);
- if ((rh != NULL) && (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg)))
+ if ((NULL != rh) && (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg)))
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
_("Failed to resume publishing operation `%s': %s\n"), filename,
emsg);
GNUNET_free (emsg);
}
- if (pc->fi != NULL)
+ if (NULL != pc->fi)
GNUNET_FS_file_information_destroy (pc->fi, NULL, NULL);
if (0 != UNLINK (filename))
GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", filename);
}
wh = get_write_handle (pc->h, GNUNET_FS_SYNC_PATH_MASTER_PUBLISH,
pc->serialization);
- if (wh == NULL)
+ if (NULL == wh)
{
GNUNET_break (0);
goto cleanup;
(GNUNET_OK != GNUNET_BIO_write_string (wh, pc->fi->serialization)) ||
(GNUNET_OK !=
GNUNET_BIO_write_string (wh,
- (pc->fi_pos ==
- NULL) ? NULL : pc->fi_pos->serialization)) ||
+ (NULL == pc->fi_pos) ? NULL : pc->fi_pos->serialization)) ||
(GNUNET_OK !=
GNUNET_BIO_write_string (wh,
- (pc->namespace ==
- NULL) ? NULL : pc->namespace->name)))
+ (NULL == pc->ns) ? NULL : pc->ns->name)))
{
GNUNET_break (0);
goto cleanup;
}
return;
cleanup:
- if (wh != NULL)
+ if (NULL != wh)
(void) GNUNET_BIO_write_close (wh);
GNUNET_FS_remove_sync_file_ (pc->h, GNUNET_FS_SYNC_PATH_MASTER_PUBLISH,
pc->serialization);
GNUNET_FS_unindex_sync_ (struct GNUNET_FS_UnindexContext *uc)
{
struct GNUNET_BIO_WriteHandle *wh;
+ char *uris;
if (NULL == uc->serialization)
uc->serialization =
return;
wh = get_write_handle (uc->h, GNUNET_FS_SYNC_PATH_MASTER_UNINDEX,
uc->serialization);
- if (wh == NULL)
+ if (NULL == wh)
{
GNUNET_break (0);
goto cleanup;
}
+ if (NULL != uc->ksk_uri)
+ uris = GNUNET_FS_uri_to_string (uc->ksk_uri);
+ else
+ uris = NULL;
if ((GNUNET_OK != GNUNET_BIO_write_string (wh, uc->filename)) ||
(GNUNET_OK != GNUNET_BIO_write_int64 (wh, uc->file_size)) ||
(GNUNET_OK != write_start_time (wh, uc->start_time)) ||
(GNUNET_OK != GNUNET_BIO_write_int32 (wh, (uint32_t) uc->state)) ||
+ (GNUNET_OK !=
+ GNUNET_BIO_write (wh, &uc->chk, sizeof (struct ContentHashKey))) ||
+ (GNUNET_OK != GNUNET_BIO_write_string (wh, uris)) ||
+ (GNUNET_OK != GNUNET_BIO_write_int32 (wh, (uint32_t) uc->ksk_offset)) ||
((uc->state == UNINDEX_STATE_FS_NOTIFY) &&
(GNUNET_OK !=
- GNUNET_BIO_write (wh, &uc->file_id, sizeof (GNUNET_HashCode)))) ||
+ GNUNET_BIO_write (wh, &uc->file_id, sizeof (struct GNUNET_HashCode)))) ||
((uc->state == UNINDEX_STATE_ERROR) &&
(GNUNET_OK != GNUNET_BIO_write_string (wh, uc->emsg))))
{
}
return;
cleanup:
- if (wh != NULL)
+ if (NULL != wh)
(void) GNUNET_BIO_write_close (wh);
GNUNET_FS_remove_sync_file_ (uc->h, GNUNET_FS_SYNC_PATH_MASTER_UNINDEX,
uc->serialization);
(GNUNET_OK != GNUNET_BIO_write_int32 (wh, dr->num_children)) ||
(GNUNET_OK != GNUNET_BIO_write_int32 (wh, dr->depth)))
return GNUNET_NO;
- if ((dr->state == BRS_CHK_SET) &&
+ if ((BRS_CHK_SET == dr->state) &&
(GNUNET_OK !=
GNUNET_BIO_write (wh, &dr->chk, sizeof (struct ContentHashKey))))
return GNUNET_NO;
unsigned int i;
dr = GNUNET_malloc (sizeof (struct DownloadRequest));
-
if ((GNUNET_OK != GNUNET_BIO_read_int32 (rh, &dr->state)) ||
(GNUNET_OK != GNUNET_BIO_read_int64 (rh, &dr->offset)) ||
(GNUNET_OK != GNUNET_BIO_read_int32 (rh, &dr->num_children)) ||
(dr->num_children > CHK_PER_INODE) ||
- (GNUNET_OK != GNUNET_BIO_read_int32 (rh, &dr->depth)) || ((dr->depth == 0)
+ (GNUNET_OK != GNUNET_BIO_read_int32 (rh, &dr->depth)) || ((0 == dr->depth)
&&
(dr->num_children
> 0)) ||
- ((dr->depth > 0) && (dr->num_children == 0)))
+ ((dr->depth > 0) && (0 == dr->num_children)))
{
GNUNET_break (0);
dr->num_children = 0;
}
if (dr->num_children > 0)
dr->children =
- GNUNET_malloc (dr->num_children * sizeof (struct ContentHashKey));
+ GNUNET_malloc (dr->num_children * sizeof (struct DownloadRequest *));
switch (dr->state)
{
case BRS_INIT:
if (dc->parent == NULL)
return get_serialization_file_name (dc->h,
- (dc->search !=
- NULL) ?
- GNUNET_FS_SYNC_PATH_CHILD_DOWNLOAD :
+ (dc->search != NULL) ?
+ GNUNET_FS_SYNC_PATH_CHILD_DOWNLOAD :
GNUNET_FS_SYNC_PATH_MASTER_DOWNLOAD,
uni);
- if (dc->parent->serialization == NULL)
+ if (NULL == dc->parent->serialization)
return NULL;
par = get_download_sync_filename (dc->parent, dc->parent->serialization, "");
- if (par == NULL)
+ if (NULL == par)
return NULL;
GNUNET_asprintf (&epar, "%s.dir%s%s%s", par, DIR_SEPARATOR_STR, uni, ext);
GNUNET_free (par);
char *fn;
char *dir;
+ if (0 != (dc->options & GNUNET_FS_DOWNLOAD_IS_PROBE))
+ return; /* we don't sync probes */
if (NULL == dc->serialization)
{
dir = get_download_sync_filename (dc, "", "");
- if (dir == NULL)
+ if (NULL == dir)
return;
if (GNUNET_OK != GNUNET_DISK_directory_create_for_file (dir))
{
}
fn = GNUNET_DISK_mktemp (dir);
GNUNET_free (dir);
- if (fn == NULL)
+ if (NULL == fn)
return;
dc->serialization = get_serialization_short_name (fn);
}
else
{
fn = get_download_sync_filename (dc, dc->serialization, "");
- if (fn == NULL)
+ if (NULL == fn)
{
GNUNET_free (dc->serialization);
dc->serialization = NULL;
}
}
wh = GNUNET_BIO_write_open (fn);
- if (wh == NULL)
+ if (NULL == wh)
{
GNUNET_free (dc->serialization);
dc->serialization = NULL;
NULL) ? GNUNET_FS_SYNC_PATH_MASTER_SEARCH :
GNUNET_FS_SYNC_PATH_CHILD_SEARCH,
sr->sc->serialization, sr->serialization);
- if (wh == NULL)
+ if (NULL == wh)
{
GNUNET_break (0);
goto cleanup;
sr->update_search !=
NULL ? sr->update_search->serialization : NULL))
|| (GNUNET_OK != GNUNET_BIO_write_meta_data (wh, sr->meta)) ||
- (GNUNET_OK != GNUNET_BIO_write (wh, &sr->key, sizeof (GNUNET_HashCode)))
+ (GNUNET_OK != GNUNET_BIO_write (wh, &sr->key, sizeof (struct GNUNET_HashCode)))
|| (GNUNET_OK != GNUNET_BIO_write_int32 (wh, sr->mandatory_missing)) ||
(GNUNET_OK != GNUNET_BIO_write_int32 (wh, sr->optional_support)) ||
(GNUNET_OK != GNUNET_BIO_write_int32 (wh, sr->availability_success)) ||
- (GNUNET_OK != GNUNET_BIO_write_int32 (wh, sr->availability_trials)))
+ (GNUNET_OK != GNUNET_BIO_write_int32 (wh, sr->availability_trials)) )
+ {
+ GNUNET_break (0);
+ goto cleanup;
+ }
+ if ( (NULL != sr->uri) &&
+ (ksk == sr->sc->uri->type) &&
+ (GNUNET_OK != GNUNET_BIO_write (wh, sr->keyword_bitmap,
+ (sr->sc->uri->data.ksk.keywordCount + 7) / 8)) )
{
GNUNET_break (0);
goto cleanup;
return;
cleanup:
GNUNET_free_non_null (uris);
- if (wh != NULL)
+ if (NULL != wh)
(void) GNUNET_BIO_write_close (wh);
remove_sync_file_in_dir (sr->sc->h,
- (sr->sc->psearch_result ==
- NULL) ? GNUNET_FS_SYNC_PATH_MASTER_SEARCH :
- GNUNET_FS_SYNC_PATH_CHILD_SEARCH,
+ (NULL == sr->sc->psearch_result)
+ ? GNUNET_FS_SYNC_PATH_MASTER_SEARCH
+ : GNUNET_FS_SYNC_PATH_CHILD_SEARCH,
sr->sc->serialization, sr->serialization);
GNUNET_free (sr->serialization);
sr->serialization = NULL;
const char *category;
category =
- (sc->psearch_result ==
- NULL) ? GNUNET_FS_SYNC_PATH_MASTER_SEARCH :
- GNUNET_FS_SYNC_PATH_CHILD_SEARCH;
+ (NULL == sc->psearch_result)
+ ? GNUNET_FS_SYNC_PATH_MASTER_SEARCH
+ : GNUNET_FS_SYNC_PATH_CHILD_SEARCH;
if (NULL == sc->serialization)
sc->serialization = make_serialization_file_name (sc->h, category);
if (NULL == sc->serialization)
return;
uris = NULL;
wh = get_write_handle (sc->h, category, sc->serialization);
- if (wh == NULL)
+ if (NULL == wh)
{
GNUNET_break (0);
goto cleanup;
}
return;
cleanup:
- if (wh != NULL)
+ if (NULL != wh)
(void) GNUNET_BIO_write_close (wh);
GNUNET_free_non_null (uris);
GNUNET_FS_remove_sync_file_ (sc->h, category, sc->serialization);
struct GNUNET_FS_UnindexContext *uc;
struct GNUNET_FS_ProgressInfo pi;
char *emsg;
+ char *uris;
uint32_t state;
uc = GNUNET_malloc (sizeof (struct GNUNET_FS_UnindexContext));
uc->h = h;
uc->serialization = get_serialization_short_name (filename);
rh = GNUNET_BIO_read_open (filename);
- if (rh == NULL)
+ if (NULL == rh)
{
GNUNET_break (0);
goto cleanup;
}
+ uris = NULL;
if ((GNUNET_OK !=
GNUNET_BIO_read_string (rh, "unindex-fn", &uc->filename, 10 * 1024)) ||
(GNUNET_OK != GNUNET_BIO_read_int64 (rh, &uc->file_size)) ||
(GNUNET_OK != read_start_time (rh, &uc->start_time)) ||
- (GNUNET_OK != GNUNET_BIO_read_int32 (rh, &state)))
+ (GNUNET_OK != GNUNET_BIO_read_int32 (rh, &state)) ||
+ (GNUNET_OK != GNUNET_BIO_read (rh, "uri", &uc->chk, sizeof (struct ContentHashKey))) ||
+ (GNUNET_OK != GNUNET_BIO_read_string (rh, "unindex-kskuri", &uris, 10 * 1024)) ||
+ (GNUNET_OK != GNUNET_BIO_read_int32 (rh, &uc->ksk_offset)) )
{
+ GNUNET_free_non_null (uris);
GNUNET_break (0);
goto cleanup;
}
+ if (NULL != uris)
+ {
+ uc->ksk_uri = GNUNET_FS_uri_parse (uris, &emsg);
+ GNUNET_free (uris);
+ if (NULL == uc->ksk_uri)
+ {
+ GNUNET_break (0);
+ goto cleanup;
+ }
+ }
+ if ( (uc->ksk_offset > 0) &&
+ ( (NULL == uc->ksk_uri) ||
+ (uc->ksk_offset > uc->ksk_uri->data.ksk.keywordCount) ) )
+ {
+ GNUNET_break (0);
+ goto cleanup;
+ }
uc->state = (enum UnindexState) state;
switch (state)
{
case UNINDEX_STATE_FS_NOTIFY:
if (GNUNET_OK !=
GNUNET_BIO_read (rh, "unindex-hash", &uc->file_id,
- sizeof (GNUNET_HashCode)))
+ sizeof (struct GNUNET_HashCode)))
{
GNUNET_break (0);
goto cleanup;
}
break;
case UNINDEX_STATE_DS_REMOVE:
+ case UNINDEX_STATE_EXTRACT_KEYWORDS:
+ case UNINDEX_STATE_DS_REMOVE_KBLOCKS:
break;
case UNINDEX_STATE_COMPLETE:
break;
case UNINDEX_STATE_DS_REMOVE:
GNUNET_FS_unindex_do_remove_ (uc);
break;
+ case UNINDEX_STATE_EXTRACT_KEYWORDS:
+ GNUNET_FS_unindex_do_extract_keywords_ (uc);
+ break;
+ case UNINDEX_STATE_DS_REMOVE_KBLOCKS:
+ GNUNET_FS_unindex_do_remove_kblocks_ (uc);
+ break;
case UNINDEX_STATE_COMPLETE:
case UNINDEX_STATE_ERROR:
/* no need to resume any operation, we were done */
return GNUNET_OK;
cleanup:
GNUNET_free_non_null (uc->filename);
- if ((rh != NULL) && (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg)))
+ if ((NULL != rh) && (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg)))
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
_("Failed to resume unindexing operation `%s': %s\n"), filename,
emsg);
GNUNET_free (emsg);
}
- if (uc->serialization != NULL)
+ if (NULL != uc->serialization)
GNUNET_FS_remove_sync_file_ (h, GNUNET_FS_SYNC_PATH_MASTER_UNINDEX,
uc->serialization);
GNUNET_free_non_null (uc->serialization);
ser = get_serialization_short_name (filename);
rh = GNUNET_BIO_read_open (filename);
- if (rh == NULL)
+ if (NULL == rh)
{
- if (ser != NULL)
+ if (NULL != ser)
{
remove_sync_file_in_dir (sc->h,
- (sc->psearch_result ==
- NULL) ? GNUNET_FS_SYNC_PATH_MASTER_SEARCH :
- GNUNET_FS_SYNC_PATH_CHILD_SEARCH,
+ (NULL == sc->psearch_result)
+ ? GNUNET_FS_SYNC_PATH_MASTER_SEARCH
+ : GNUNET_FS_SYNC_PATH_CHILD_SEARCH,
sc->serialization, ser);
GNUNET_free (ser);
}
GNUNET_BIO_read_string (rh, "search-lnk", &update_srch, 16)) ||
(GNUNET_OK != GNUNET_BIO_read_meta_data (rh, "result-meta", &sr->meta)) ||
(GNUNET_OK !=
- GNUNET_BIO_read (rh, "result-key", &sr->key, sizeof (GNUNET_HashCode)))
+ GNUNET_BIO_read (rh, "result-key", &sr->key, sizeof (struct GNUNET_HashCode)))
|| (GNUNET_OK != GNUNET_BIO_read_int32 (rh, &sr->mandatory_missing)) ||
(GNUNET_OK != GNUNET_BIO_read_int32 (rh, &sr->optional_support)) ||
(GNUNET_OK != GNUNET_BIO_read_int32 (rh, &sr->availability_success)) ||
GNUNET_break (0);
goto cleanup;
}
+ if (ksk == sr->sc->uri->type)
+ {
+ sr->keyword_bitmap = GNUNET_malloc ((sr->sc->uri->data.ksk.keywordCount + 7) / 8); /* round up, count bits */
+ if (GNUNET_OK != GNUNET_BIO_read (rh, "keyword-bitmap",
+ sr->keyword_bitmap,
+ (sr->sc->uri->data.ksk.keywordCount + 7) / 8))
+ {
+ GNUNET_break (0);
+ goto cleanup;
+ }
+ }
GNUNET_free (uris);
- if (download != NULL)
+ if (NULL != download)
{
drh = get_read_handle (sc->h, GNUNET_FS_SYNC_PATH_CHILD_DOWNLOAD, download);
- if (drh != NULL)
+ if (NULL != drh)
{
deserialize_download (sc->h, drh, NULL, sr, download);
if (GNUNET_OK != GNUNET_BIO_read_close (drh, &emsg))
}
GNUNET_free (download);
}
- if (update_srch != NULL)
+ if (NULL != update_srch)
{
drh =
get_read_handle (sc->h, GNUNET_FS_SYNC_PATH_CHILD_SEARCH, update_srch);
- if (drh != NULL)
+ if (NULL != drh)
{
deserialize_search (sc->h, drh, sr, update_srch);
if (GNUNET_OK != GNUNET_BIO_read_close (drh, &emsg))
}
GNUNET_free (update_srch);
}
- GNUNET_CONTAINER_multihashmap_put (sc->master_result_map, &sr->key, sr,
- GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
+ GNUNET_break (GNUNET_YES ==
+ GNUNET_CONTAINER_multihashmap_put (sc->master_result_map, &sr->key, sr,
+ GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE));
if (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg))
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
GNUNET_free_non_null (emsg);
GNUNET_free_non_null (uris);
GNUNET_free_non_null (update_srch);
- if (sr->uri != NULL)
+ if (NULL != sr->uri)
GNUNET_FS_uri_destroy (sr->uri);
- if (sr->meta != NULL)
+ if (NULL != sr->meta)
GNUNET_CONTAINER_meta_data_destroy (sr->meta);
GNUNET_free (sr->serialization);
GNUNET_free (sr);
signal_download_resume (dcc);
dcc = dcc->next;
}
- if (dc->pending_head != NULL)
+ if (NULL != dc->pending_head)
GNUNET_FS_download_start_downloading_ (dc);
}
* @return GNUNET_YES (we should continue to iterate)
*/
static int
-signal_result_resume (void *cls, const GNUNET_HashCode * key, void *value)
+signal_result_resume (void *cls, const struct GNUNET_HashCode * key, void *value)
{
struct GNUNET_FS_SearchContext *sc = cls;
struct GNUNET_FS_ProgressInfo pi;
sr->optional_support;
sr->client_info = GNUNET_FS_search_make_status_ (&pi, sc);
}
- if (sr->download != NULL)
+ if (NULL != sr->download)
{
signal_download_resume (sr->download);
}
{
GNUNET_FS_search_start_probe_ (sr);
}
- if (sr->update_search != NULL)
+ if (NULL != sr->update_search)
signal_search_resume (sr->update_search);
return GNUNET_YES;
}
* @return GNUNET_YES (we should continue to iterate)
*/
static int
-free_result (void *cls, const GNUNET_HashCode * key, void *value)
+free_result (void *cls, const struct GNUNET_HashCode * key, void *value)
{
struct GNUNET_FS_SearchResult *sr = value;
- if (sr->update_search != NULL)
+ if (NULL != sr->update_search)
{
free_search_context (sr->update_search);
GNUNET_assert (NULL == sr->update_search);
static void
free_search_context (struct GNUNET_FS_SearchContext *sc)
{
- if (sc->serialization != NULL)
+ if (NULL != sc->serialization)
{
GNUNET_FS_remove_sync_file_ (sc->h,
(sc->psearch_result ==
}
GNUNET_free_non_null (sc->serialization);
GNUNET_free_non_null (sc->emsg);
- if (sc->uri != NULL)
+ if (NULL != sc->uri)
GNUNET_FS_uri_destroy (sc->uri);
- if (sc->master_result_map != NULL)
+ if (NULL != sc->master_result_map)
{
GNUNET_CONTAINER_multihashmap_iterate (sc->master_result_map, &free_result,
sc);
ser = get_serialization_short_name (filename);
rh = GNUNET_BIO_read_open (filename);
- if (rh == NULL)
+ if (NULL == rh)
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
_
{
struct GNUNET_FS_DownloadContext *dcc;
- if (dc->meta != NULL)
+ if (NULL != dc->meta)
GNUNET_CONTAINER_meta_data_destroy (dc->meta);
- if (dc->uri != NULL)
+ if (NULL != dc->uri)
GNUNET_FS_uri_destroy (dc->uri);
GNUNET_free_non_null (dc->temp_filename);
GNUNET_free_non_null (dc->emsg);
}
dc->options = (enum GNUNET_FS_DownloadOptions) options;
dc->active =
- GNUNET_CONTAINER_multihashmap_create (1 + 2 * (dc->length / DBLOCK_SIZE));
+ GNUNET_CONTAINER_multihashmap_create (1 + 2 * (dc->length / DBLOCK_SIZE), GNUNET_NO);
dc->has_finished = (int) status;
dc->treedepth =
GNUNET_FS_compute_depth (GNUNET_FS_uri_chk_get_file_size (dc->uri));
if (GNUNET_FS_uri_test_loc (dc->uri))
GNUNET_assert (GNUNET_OK ==
GNUNET_FS_uri_loc_get_peer_identity (dc->uri, &dc->target));
- if (dc->emsg == NULL)
+ if (NULL == dc->emsg)
{
dc->top_request = read_download_request (rh);
- if (dc->top_request == NULL)
+ if (NULL == dc->top_request)
{
GNUNET_break (0);
goto cleanup;
}
}
dn = get_download_sync_filename (dc, dc->serialization, ".dir");
- if (dn != NULL)
+ if (NULL != dn)
{
if (GNUNET_YES == GNUNET_DISK_directory_test (dn))
GNUNET_DISK_directory_scan (dn, &deserialize_subdownload, dc);
GNUNET_free (dn);
}
- if (parent != NULL)
+ if (NULL != parent)
{
GNUNET_abort (); // for debugging for now - FIXME
GNUNET_CONTAINER_DLL_insert (parent->child_head, parent->child_tail, dc);
}
- if (search != NULL)
+ if (NULL != search)
{
dc->search = search;
search->download = dc;
}
- if ((parent == NULL) && (search == NULL))
+ if ((NULL == parent) && (NULL == search))
{
dc->top =
GNUNET_FS_make_top (dc->h, &GNUNET_FS_download_signal_suspend_, dc);
pi.status = GNUNET_FS_STATUS_SEARCH_RESUME;
pi.value.search.specifics.resume.message = sc->emsg;
pi.value.search.specifics.resume.is_paused =
- (sc->client == NULL) ? GNUNET_YES : GNUNET_NO;
+ (NULL == sc->client) ? GNUNET_YES : GNUNET_NO;
sc->client_info = GNUNET_FS_search_make_status_ (&pi, sc);
GNUNET_CONTAINER_multihashmap_iterate (sc->master_result_map,
&signal_result_resume, sc);
uint32_t options;
char in_pause;
- if ((psearch_result != NULL) && (psearch_result->update_search != NULL))
+ if ((NULL != psearch_result) && (NULL != psearch_result->update_search))
{
GNUNET_break (0);
return NULL;
uris = NULL;
emsg = NULL;
sc = GNUNET_malloc (sizeof (struct GNUNET_FS_SearchContext));
- if (psearch_result != NULL)
+ if (NULL != psearch_result)
{
sc->psearch_result = psearch_result;
psearch_result->update_search = sc;
goto cleanup;
}
sc->options = (enum GNUNET_FS_SearchOptions) options;
- sc->master_result_map = GNUNET_CONTAINER_multihashmap_create (16);
+ sc->master_result_map = GNUNET_CONTAINER_multihashmap_create (16, GNUNET_NO);
dn = get_serialization_file_name_in_dir (h,
(sc->psearch_result ==
NULL) ?
GNUNET_FS_SYNC_PATH_MASTER_SEARCH :
GNUNET_FS_SYNC_PATH_CHILD_SEARCH,
sc->serialization, "");
- if (dn != NULL)
+ if (NULL != dn)
{
if (GNUNET_YES == GNUNET_DISK_directory_test (dn))
GNUNET_DISK_directory_scan (dn, &deserialize_search_result, sc);
char *emsg;
struct GNUNET_BIO_ReadHandle *rh;
struct GNUNET_FS_SearchContext *sc;
+ struct stat buf;
+ if (0 != STAT (filename, &buf))
+ {
+ GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "stat", filename);
+ return GNUNET_OK;
+ }
+ if (S_ISDIR (buf.st_mode))
+ return GNUNET_OK; /* skip directories */
ser = get_serialization_short_name (filename);
rh = GNUNET_BIO_read_open (filename);
- if (rh == NULL)
+ if (NULL == rh)
{
- if (ser != NULL)
+ if (NULL != ser)
{
GNUNET_FS_remove_sync_file_ (h, GNUNET_FS_SYNC_PATH_MASTER_SEARCH, ser);
GNUNET_free (ser);
return GNUNET_OK;
}
sc = deserialize_search (h, rh, NULL, ser);
- if (sc != NULL)
+ if (NULL != sc)
sc->top = GNUNET_FS_make_top (h, &GNUNET_FS_search_signal_suspend_, sc);
GNUNET_free (ser);
if (GNUNET_OK != GNUNET_BIO_read_close (rh, &emsg))
ser = get_serialization_short_name (filename);
rh = GNUNET_BIO_read_open (filename);
- if (rh == NULL)
+ if (NULL == rh)
{
if (0 != UNLINK (filename))
GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING, "unlink", filename);
char *dn;
dn = get_serialization_file_name (h, master_path, "");
- if (dn == NULL)
+ if (NULL == dn)
return;
if (GNUNET_YES == GNUNET_DISK_directory_test (dn))
GNUNET_DISK_directory_scan (dn, proc, h);
ret->upcb = upcb;
ret->upcb_cls = upcb_cls;
ret->flags = flags;
- ret->max_parallel_downloads = 1;
- ret->max_parallel_requests = 1;
+ ret->max_parallel_downloads = DEFAULT_MAX_PARALLEL_DOWNLOADS;
+ ret->max_parallel_requests = DEFAULT_MAX_PARALLEL_REQUESTS;
ret->avg_block_latency = GNUNET_TIME_UNIT_MINUTES; /* conservative starting point */
va_start (ap, flags);
while (GNUNET_FS_OPTIONS_END != (opt = va_arg (ap, enum GNUNET_FS_OPTIONS)))
projects / oweals / gnunet.git / blobdiff