diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-03-25 15:13:45 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-03-25 15:13:45 +0000 |
commit | a8698c1dc9200d021e0aa38ae1dcad6a44e57a6d (patch) | |
tree | f9b72fdff41015633935dff95f9352741bc1350c | |
parent | 2d84aa485a4e0801ce82266e0edc7dacd2da649d (diff) | |
download | gnunet-a8698c1dc9200d021e0aa38ae1dcad6a44e57a6d.tar.gz gnunet-a8698c1dc9200d021e0aa38ae1dcad6a44e57a6d.zip |
polishing
-rw-r--r-- | src/fs/gnunet-service-fs_pr.c | 2 | ||||
-rw-r--r-- | src/fs/test_fs_download.c | 4 | ||||
-rw-r--r-- | src/fs/test_fs_namespace.c | 25 | ||||
-rw-r--r-- | src/fs/test_fs_namespace_data.conf | 2 |
4 files changed, 25 insertions, 8 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c index ea8f3b80c..b022cc23f 100644 --- a/src/fs/gnunet-service-fs_pr.c +++ b/src/fs/gnunet-service-fs_pr.c | |||
@@ -958,7 +958,7 @@ process_local_reply (void *cls, | |||
958 | { | 958 | { |
959 | #if DEBUG_FS | 959 | #if DEBUG_FS |
960 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 960 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
961 | "No further local repsonses available.\n"); | 961 | "No further local responses available.\n"); |
962 | #endif | 962 | #endif |
963 | pr->qe = NULL; | 963 | pr->qe = NULL; |
964 | if (NULL != (cont = pr->llc_cont)) | 964 | if (NULL != (cont = pr->llc_cont)) |
diff --git a/src/fs/test_fs_download.c b/src/fs/test_fs_download.c index 45df96043..5091c5a61 100644 --- a/src/fs/test_fs_download.c +++ b/src/fs/test_fs_download.c | |||
@@ -150,7 +150,7 @@ progress_cb (void *cls, | |||
150 | #endif | 150 | #endif |
151 | break; | 151 | break; |
152 | case GNUNET_FS_STATUS_PUBLISH_COMPLETED: | 152 | case GNUNET_FS_STATUS_PUBLISH_COMPLETED: |
153 | printf ("Publishing complete, %llu kbps.\n", | 153 | printf ("Publishing complete, %llu kb/s.\n", |
154 | (unsigned long long) (FILESIZE * 1000LL / (1+GNUNET_TIME_absolute_get_duration (start).rel_value) / 1024LL)); | 154 | (unsigned long long) (FILESIZE * 1000LL / (1+GNUNET_TIME_absolute_get_duration (start).rel_value) / 1024LL)); |
155 | GAUGER ("FS", | 155 | GAUGER ("FS", |
156 | "Publishing speed (insertion)", | 156 | "Publishing speed (insertion)", |
@@ -171,7 +171,7 @@ progress_cb (void *cls, | |||
171 | GNUNET_assert (download != NULL); | 171 | GNUNET_assert (download != NULL); |
172 | break; | 172 | break; |
173 | case GNUNET_FS_STATUS_DOWNLOAD_COMPLETED: | 173 | case GNUNET_FS_STATUS_DOWNLOAD_COMPLETED: |
174 | printf ("Download complete, %llu kbps.\n", | 174 | printf ("Download complete, %llu kb/s.\n", |
175 | (unsigned long long) (FILESIZE * 1000LL / (1+GNUNET_TIME_absolute_get_duration (start).rel_value) / 1024LL)); | 175 | (unsigned long long) (FILESIZE * 1000LL / (1+GNUNET_TIME_absolute_get_duration (start).rel_value) / 1024LL)); |
176 | GAUGER ("FS", | 176 | GAUGER ("FS", |
177 | "Local download speed (inserted)", | 177 | "Local download speed (inserted)", |
diff --git a/src/fs/test_fs_namespace.c b/src/fs/test_fs_namespace.c index 0d37affa2..b5e210f4c 100644 --- a/src/fs/test_fs_namespace.c +++ b/src/fs/test_fs_namespace.c | |||
@@ -22,16 +22,13 @@ | |||
22 | * @file fs/test_fs_namespace.c | 22 | * @file fs/test_fs_namespace.c |
23 | * @brief Test for fs_namespace.c | 23 | * @brief Test for fs_namespace.c |
24 | * @author Christian Grothoff | 24 | * @author Christian Grothoff |
25 | * | ||
26 | * TODO: | ||
27 | * - add timeout task | ||
28 | */ | 25 | */ |
29 | #include "platform.h" | 26 | #include "platform.h" |
30 | #include "gnunet_util_lib.h" | 27 | #include "gnunet_util_lib.h" |
31 | #include "gnunet_arm_service.h" | 28 | #include "gnunet_arm_service.h" |
32 | #include "gnunet_fs_service.h" | 29 | #include "gnunet_fs_service.h" |
33 | 30 | ||
34 | #define VERBOSE GNUNET_NO | 31 | #define VERBOSE GNUNET_YES |
35 | 32 | ||
36 | #define START_ARM GNUNET_YES | 33 | #define START_ARM GNUNET_YES |
37 | 34 | ||
@@ -49,6 +46,8 @@ static struct GNUNET_FS_SearchContext *sks_search; | |||
49 | 46 | ||
50 | static struct GNUNET_FS_SearchContext *ksk_search; | 47 | static struct GNUNET_FS_SearchContext *ksk_search; |
51 | 48 | ||
49 | static GNUNET_SCHEDULER_TaskIdentifier kill_task; | ||
50 | |||
52 | static int update_started; | 51 | static int update_started; |
53 | 52 | ||
54 | static int err; | 53 | static int err; |
@@ -91,6 +90,8 @@ stop_arm (struct PeerContext *p) | |||
91 | GNUNET_OS_process_close (p->arm_proc); | 90 | GNUNET_OS_process_close (p->arm_proc); |
92 | p->arm_proc = NULL; | 91 | p->arm_proc = NULL; |
93 | #endif | 92 | #endif |
93 | if (GNUNET_SCHEDULER_NO_TASK != kill_task) | ||
94 | GNUNET_SCHEDULER_cancel (kill_task); | ||
94 | GNUNET_CONFIGURATION_destroy (p->cfg); | 95 | GNUNET_CONFIGURATION_destroy (p->cfg); |
95 | } | 96 | } |
96 | 97 | ||
@@ -132,6 +133,19 @@ abort_sks_search_task (void *cls, | |||
132 | } | 133 | } |
133 | 134 | ||
134 | 135 | ||
136 | static void | ||
137 | do_timeout (void *cls, | ||
138 | const struct GNUNET_SCHEDULER_TaskContext *tc) | ||
139 | { | ||
140 | fprintf (stderr, | ||
141 | "Operation timed out\n"); | ||
142 | kill_task = GNUNET_SCHEDULER_NO_TASK; | ||
143 | abort_sks_search_task (NULL, tc); | ||
144 | abort_ksk_search_task (NULL, tc); | ||
145 | } | ||
146 | |||
147 | |||
148 | |||
135 | static void * | 149 | static void * |
136 | progress_cb (void *cls, | 150 | progress_cb (void *cls, |
137 | const struct GNUNET_FS_ProgressInfo *event) | 151 | const struct GNUNET_FS_ProgressInfo *event) |
@@ -370,6 +384,9 @@ testNamespace () | |||
370 | expiration, | 384 | expiration, |
371 | "root", | 385 | "root", |
372 | &adv_cont, NULL); | 386 | &adv_cont, NULL); |
387 | kill_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, | ||
388 | &do_timeout, | ||
389 | NULL); | ||
373 | GNUNET_FS_uri_destroy (ksk_uri); | 390 | GNUNET_FS_uri_destroy (ksk_uri); |
374 | GNUNET_FS_namespace_delete (ns, GNUNET_NO); | 391 | GNUNET_FS_namespace_delete (ns, GNUNET_NO); |
375 | GNUNET_CONTAINER_meta_data_destroy (meta); | 392 | GNUNET_CONTAINER_meta_data_destroy (meta); |
diff --git a/src/fs/test_fs_namespace_data.conf b/src/fs/test_fs_namespace_data.conf index d1ed94a8b..42c1f430b 100644 --- a/src/fs/test_fs_namespace_data.conf +++ b/src/fs/test_fs_namespace_data.conf | |||
@@ -37,7 +37,7 @@ HOSTNAME = localhost | |||
37 | PORT = 42471 | 37 | PORT = 42471 |
38 | HOSTNAME = localhost | 38 | HOSTNAME = localhost |
39 | IDENTITY_DIR = $SERVICEHOME/pseudos/ | 39 | IDENTITY_DIR = $SERVICEHOME/pseudos/ |
40 | # DEBUG = YES | 40 | DEBUG = YES |
41 | 41 | ||
42 | [testing] | 42 | [testing] |
43 | WEAKRANDOM = YES | 43 | WEAKRANDOM = YES |