181 unsigned long long x;
182 unsigned long long y;
183 unsigned long long t;
185 while (3 == sscanf (pattern,
194 pattern = strstr (pattern,
")");
214 "%llu", (
unsigned long long) kval);
237 unsigned long long i;
246 for (i = 0; i < length; i += 8)
248 xor = length ^ kval ^ (uint64_t) (i / 32 / 1024);
276 while (NULL != (p = publish_head))
285 while (NULL != (p = download_head))
289 if (NULL != p->
stask)
298 if (NULL != fs_handle)
303 if (NULL != stats_handle)
391 "Publishing failed\n");
393 "# failed publish operations", 1,
GNUNET_NO);
401 "# publishing time (ms)",
424 "Download failed\n");
434 "# download time (ms)",
464 "# search time (ms)",
562 const char *cfgfile GNUNET_UNUSED,
579 "TESTBED",
"PEERID");
586 "FSPROFILER",
"ANONYMITY_LEVEL",
591 "FSPROFILER",
"REPLICATION_LEVEL",
598 "FSPROFILER", myoptname,
605 "FSPROFILER", myoptname,
630 if (NULL == fs_handle)
633 "Could not acquire FS handle. Exiting.\n");
638 for (p = publish_head; NULL !=
p; p = p->
next)
641 for (p = download_head; NULL !=
p; p = p->
next)
655 main (
int argc,
char *
const *argv)
667 "Daemon to use file-sharing to measure its performance."),
#define GNUNET_CONTAINER_DLL_remove(head, tail, element)
Remove an element from a DLL.
struct GNUNET_TIME_Absolute expiration_time
At what time should the block expire? Data blocks (DBLOCKS and IBLOCKS) may still be used even if the...
Notification that we have started this download.
struct GNUNET_SCHEDULER_Task * stask
Secondary task to run the operation.
No options (use defaults for everything).
static void * progress_cb(void *cls, const struct GNUNET_FS_ProgressInfo *info)
Notification of FS to a client about the progress of an operation.
static struct GNUNET_FS_Uri * make_keywords(uint64_t kval)
Create a KSK URI from a number.
void GNUNET_FS_publish_stop(struct GNUNET_FS_PublishContext *pc)
Stop an upload.
static struct GNUNET_FS_FileInformation * make_file(uint64_t length, uint64_t kval, void *ctx)
Create a file of the given length with a deterministic amount of data to be published under keyword '...
enum GNUNET_GenericReturnValue GNUNET_PROGRAM_run(int argc, char *const *argv, const char *binaryName, const char *binaryHelp, const struct GNUNET_GETOPT_CommandLineOption *options, GNUNET_PROGRAM_Main task, void *task_cls)
Run a standard GNUnet command startup sequence (initialize loggers and configuration, parse options).
uint64_t rel_value_us
The actual value.
This search has yielded a result.
Last message from a search; this signals that there will be no further events associated with this se...
#define GNUNET_CONTAINER_DLL_insert(head, tail, element)
Insert an element at the head of a DLL.
struct GNUNET_FS_ProgressInfo::@25::@27 download
Values for all "GNUNET_FS_STATUS_DOWNLOAD_*" events.
Notification that we are making progress sharing a file structure.
void * ctx
Execution context for the pattern (FS-handle to the operation).
struct GNUNET_FS_PublishContext * GNUNET_FS_publish_start(struct GNUNET_FS_Handle *h, struct GNUNET_FS_FileInformation *fi, const struct GNUNET_CRYPTO_EcdsaPrivateKey *ns, const char *nid, const char *nuid, enum GNUNET_FS_PublishOptions options)
Publish a file or directory.
Event generated for each search result when the respective search is stopped.
#define GNUNET_UNUSED
gcc-ism to document unused arguments
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_shutdown(GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run on shutdown, that is when a CTRL-C signal is received, or when GNUNET_SCHEDULER_shutdown() is being invoked.
Master context for most FS operations.
unsigned long long y
Y-value.
struct GNUNET_STATISTICS_Handle * GNUNET_STATISTICS_create(const char *subsystem, const struct GNUNET_CONFIGURATION_Handle *cfg)
Get handle for the statistics service.
int GNUNET_STRINGS_get_utf8_args(int argc, char *const *argv, int *u8argc, char *const **u8argv)
Returns utf-8 encoded arguments.
static char * download_pattern
String describing which download operations this peer should perform.
struct GNUNET_TIME_Absolute GNUNET_TIME_relative_to_absolute(struct GNUNET_TIME_Relative rel)
Convert relative time to an absolute time in the future.
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
struct GNUNET_TIME_Relative delay
With how much delay should this operation be started?
static struct Pattern * download_head
Head of the DLL of publish patterns.
struct GNUNET_FS_FileInformation * GNUNET_FS_file_information_create_from_data(struct GNUNET_FS_Handle *h, void *client_info, uint64_t length, void *data, const struct GNUNET_FS_Uri *keywords, const struct GNUNET_CONTAINER_MetaData *meta, int do_index, const struct GNUNET_FS_BlockOptions *bo)
Create an entry for a file in a publish-structure.
Last option in the VARARG list.
#define GNUNET_memcpy(dst, src, n)
Call memcpy() but check for n being 0 first.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_number(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option, unsigned long long *number)
Get a configuration value that should be a number.
First event generated when a client requests a search to begin or when a namespace result automatical...
#define GNUNET_new(type)
Allocate a struct or union of the given type.
Definition of a command line option.
static struct GNUNET_SCHEDULER_Task * t
Main task.
static int global_ret
Return value from 'main'.
void GNUNET_STATISTICS_destroy(struct GNUNET_STATISTICS_Handle *h, int sync_first)
Destroy a handle (free all state associated with it).
void GNUNET_STATISTICS_update(struct GNUNET_STATISTICS_Handle *handle, const char *name, int64_t delta, int make_persistent)
Set statistic value for the peer.
We have discovered a new namespace.
void GNUNET_SCHEDULER_shutdown(void)
Request the shutdown of a scheduler.
static const struct GNUNET_CONFIGURATION_Handle * cfg
Configuration we use.
void GNUNET_FS_stop(struct GNUNET_FS_Handle *h)
Close our connection with the file-sharing service.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_string(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option, char **value)
Get a configuration value that should be a string.
#define GNUNET_malloc_large(size)
Wrapper around malloc.
#define GNUNET_strdup(a)
Wrapper around GNUNET_xstrdup_.
We use 'patterns' of the form (x,y,t) to specify desired download/publish activities of a peer...
struct GNUNET_FS_DownloadContext * GNUNET_FS_download_start(struct GNUNET_FS_Handle *h, const struct GNUNET_FS_Uri *uri, const struct GNUNET_CONTAINER_MetaData *meta, const char *filename, const char *tempname, uint64_t offset, uint64_t length, uint32_t anonymity, enum GNUNET_FS_DownloadOptions options, void *cctx, struct GNUNET_FS_DownloadContext *parent)
Download parts of a file.
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur...
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_OPTION_END
struct GNUNET_FS_Handle * GNUNET_FS_start(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *client_name, GNUNET_FS_ProgressCallback upcb, void *upcb_cls, enum GNUNET_FS_Flags flags,...)
Setup a connection to the file-sharing service.
Notification that we have stopped the process of uploading a file structure; no further events will b...
int GNUNET_snprintf(char *buf, size_t size, const char *format,...) __attribute__((format(printf
Like snprintf, just aborts if the buffer is of insufficient size.
Do not append temporary data to the target file (for the IBlocks).
static struct GNUNET_FS_Uri * uri
Value of URI provided on command-line (when not publishing a file but just creating UBlocks to refer ...
uint32_t anonymity_level
At which anonymity level should the block be shared? (0: no anonymity, 1: normal GAP, >1: with cover traffic).
Notification that we have started to publish a file structure.
static unsigned long long anonymity_level
Desired anonymity level.
struct Pattern * next
Kept in a DLL.
static unsigned long long replication_level
Desired replication level.
static void publish_stop_task(void *cls)
Task run when a publish operation should be stopped.
Notification that this download completed.
union GNUNET_FS_ProgressInfo::@25 value
Values that depend on the event type.
static struct GNUNET_STATISTICS_Handle * stats_handle
Handle to the statistics service.
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_delayed(struct GNUNET_TIME_Relative delay, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay.
char ** keywords
Keywords start with a '+' if they are mandatory (in which case the '+' is NOT part of the keyword) an...
static struct GNUNET_OS_Process * p
Helper process we started.
Notification that we are making progress sharing a directory.
void GNUNET_log_config_missing(enum GNUNET_ErrorType kind, const char *section, const char *option)
Log error message about missing configuration option.
struct GNUNET_FS_ProgressInfo::@25::@28 search
Values for all "GNUNET_FS_STATUS_SEARCH_*" events.
struct GNUNET_SCHEDULER_Task * task
Task to run the operation.
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_now(GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run as soon as possible.
enum GNUNET_FS_Status status
Specific status code (determines the event type).
int main(int argc, char *const *argv)
Program that performs various "random" FS activities.
struct GNUNET_FS_SearchContext * GNUNET_FS_search_start(struct GNUNET_FS_Handle *h, const struct GNUNET_FS_Uri *uri, uint32_t anonymity, enum GNUNET_FS_SearchOptions options, void *cctx)
Start search for content.
void GNUNET_FS_download_stop(struct GNUNET_FS_DownloadContext *dc, int do_delete)
Stop a download (aborts if download is incomplete).
unsigned long long x
X-value.
static unsigned long long my_peerid
Unique number for this peer in the testbed.
void GNUNET_FS_uri_destroy(struct GNUNET_FS_Uri *uri)
Free URI.
struct GNUNET_TIME_Absolute start_time
When did the operation start?
struct GNUNET_TIME_Absolute GNUNET_TIME_absolute_get(void)
Get the current time.
int GNUNET_FS_uri_test_chk(const struct GNUNET_FS_Uri *uri)
Is this a file (or directory) URI?
Notification that this download is no longer actively being pursued (back in the queue).
Notification about progress with this download.
Select the desired amount of parallelism (this option should be followed by an "unsigned int" giving ...
Notification that this download is now actively being pursued (as opposed to waiting in the queue)...
Settings for publishing a block (which may of course also apply to an entire directory or file)...
Notification that we completed sharing a file structure.
static struct GNUNET_FS_Handle * fs_handle
Peer's FS handle.
Maximum number of requests that should be pending at a given point in time (invidivual downloads may ...
static struct Pattern * publish_head
Head of the DLL of publish patterns.
static int parse_pattern(struct Pattern **head, struct Pattern **tail, const char *pattern)
Parse a pattern string and store the corresponding 'struct Pattern' in the given head/tail.
#define GNUNET_TIME_UNIT_DAYS
One day.
static void start_download(void *cls)
Start download operation.
struct GNUNET_FS_Uri * GNUNET_FS_uri_ksk_create(const char *keywords, char **emsg)
Create an FS URI from a single user-supplied string of keywords.
uint32_t replication_level
How often should we try to migrate the block to other peers? Only used if "CONTENT_PUSHING" is set to...
static void download_stop_task(void *cls)
Task run when a download operation should be stopped.
Notification that an error was encountered sharing a file structure.
struct GNUNET_FS_ProgressInfo::@25::@26 publish
Values for all "GNUNET_FS_STATUS_PUBLISH_*" events.
static void search_stop_task(void *cls)
Task run when a download operation should be stopped.
uint64_t GNUNET_FS_uri_chk_get_file_size(const struct GNUNET_FS_Uri *uri)
What is the size of the file that this URI refers to?
static struct PendingResolutions * head
Head of list of pending resolution requests.
void * sctx
Secondary execution context for the pattern (FS-handle to the operation).
A Universal Resource Identifier (URI), opaque.
struct GNUNET_TIME_Relative GNUNET_TIME_absolute_get_duration(struct GNUNET_TIME_Absolute whence)
Get the duration of an operation as the difference of the current time and the given start time "henc...
static void run(void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg_)
Main function that will be run by the scheduler.
#define GNUNET_log(kind,...)
Entry in list of pending tasks.
uint32_t content_priority
How important is it for us to store the block? If we run out of space, the highest-priority, non-expired blocks will be kept.
static struct PendingResolutions * tail
Tail of list of pending resolution requests.
Signals a problem with this search.
We have additional data about the quality or availability of a search result.
Time for absolute times used by GNUnet, in microseconds.
static struct Pattern * publish_tail
Tail of the DLL of publish patterns.
No options (use defaults for everything).
Notification that this download was stopped (final event with respect to this action).
uint32_t data
The data value.
static char * publish_pattern
String describing which publishing operations this peer should perform.
struct Pattern * prev
Kept in a DLL.
void GNUNET_FS_search_stop(struct GNUNET_FS_SearchContext *sc)
Stop search for content.
Notification that this download encountered an error.
#define GNUNET_free(ptr)
Wrapper around free.
Argument given to the progress callback with information about what is going on.
Time for relative time used by GNUnet, in microseconds.
#define gettext_noop(String)
static void start_publish(void *cls)
Start publish operation.
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
static void shutdown_task(void *cls)
Task run during shutdown.
static struct Pattern * download_tail
Tail of the DLL of publish patterns.