PORT = 12470
UNIXPATH = /tmp/gnunet-p1-service-core.sock
#PREFIX = valgrind --tool=memcheck
+#PREFIX = valgrind --tool=callgrind
#OPTIONS = -l log-core-1
#PREFIX = xterm -e xterm -T core1 -e gdb --args
#PREFIX = xterm -T core1 -e
#define START_ARM GNUNET_YES
+/**
+ * Note that this value must not significantly exceed
+ * 'MAX_PENDING' in 'gnunet-service-transport.c', otherwise
+ * messages may be dropped even for a reliable transport.
+ */
+#define TOTAL_MSGS (600 * 200)
+
/**
* How long until we give up on transmitting the message?
*/
-#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60)
+#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 6000)
/**
* What delay do we request from the core service for transmission?
static struct GNUNET_TIME_Absolute start_time;
-/**
- * Note that this value must not significantly exceed
- * 'MAX_PENDING' in 'gnunet-service-transport.c', otherwise
- * messages may be dropped even for a reliable transport.
- */
-#define TOTAL_MSGS (600 * 2)
-
struct PeerContext
{
struct GNUNET_CONFIGURATION_Handle *cfg;
pc->qre = GNUNET_DATASTORE_release_reserve (pc->dsh,
pc->rid,
UINT_MAX,
- UNIT_MAX,
+ UINT_MAX,
GNUNET_TIME_UNIT_FOREVER_REL,
&finish_release_reserve,
pc);
const char *msg)
{
struct GNUNET_FS_PublishContext *pc = cls;
- struct GNUNET_FS_ProgressInfo pi;
pc->qre = NULL;
if ( (msg != NULL) ||
return;
}
pc->rid = success;
- ret->upload_task
- = GNUNET_SCHEDULER_add_with_priority (h->sched,
+ pc->upload_task
+ = GNUNET_SCHEDULER_add_with_priority (pc->h->sched,
GNUNET_SCHEDULER_PRIORITY_BACKGROUND,
&GNUNET_FS_publish_main_,
- ret);
+ pc);
}