diff options
author | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
---|---|---|
committer | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
commit | 75a33a1499cf60ea4364c9aa673816629a6c1413 (patch) | |
tree | 0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/fs/test_gnunet_service_fs_p2p.c | |
parent | 7217c601ad30760872823193d62307e7a335d226 (diff) | |
download | gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.tar.gz gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.zip |
big scheduler refactoring, expect some issues
Diffstat (limited to 'src/fs/test_gnunet_service_fs_p2p.c')
-rw-r--r-- | src/fs/test_gnunet_service_fs_p2p.c | 25 |
1 files changed, 7 insertions, 18 deletions
diff --git a/src/fs/test_gnunet_service_fs_p2p.c b/src/fs/test_gnunet_service_fs_p2p.c index f026baf6b..3bb808c48 100644 --- a/src/fs/test_gnunet_service_fs_p2p.c +++ b/src/fs/test_gnunet_service_fs_p2p.c | |||
@@ -44,8 +44,6 @@ | |||
44 | 44 | ||
45 | static struct GNUNET_FS_TestDaemon *daemons[NUM_DAEMONS]; | 45 | static struct GNUNET_FS_TestDaemon *daemons[NUM_DAEMONS]; |
46 | 46 | ||
47 | static struct GNUNET_SCHEDULER_Handle *sched; | ||
48 | |||
49 | static int ok; | 47 | static int ok; |
50 | 48 | ||
51 | static struct GNUNET_TIME_Absolute start_time; | 49 | static struct GNUNET_TIME_Absolute start_time; |
@@ -57,8 +55,7 @@ do_stop (void *cls, | |||
57 | struct GNUNET_TIME_Relative del; | 55 | struct GNUNET_TIME_Relative del; |
58 | char *fancy; | 56 | char *fancy; |
59 | 57 | ||
60 | GNUNET_FS_TEST_daemons_stop (sched, | 58 | GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, |
61 | NUM_DAEMONS, | ||
62 | daemons); | 59 | daemons); |
63 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) | 60 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) |
64 | { | 61 | { |
@@ -89,8 +86,7 @@ do_download (void *cls, | |||
89 | { | 86 | { |
90 | if (NULL == uri) | 87 | if (NULL == uri) |
91 | { | 88 | { |
92 | GNUNET_FS_TEST_daemons_stop (sched, | 89 | GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, |
93 | NUM_DAEMONS, | ||
94 | daemons); | 90 | daemons); |
95 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 91 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
96 | "Timeout during upload attempt, shutting down with error\n"); | 92 | "Timeout during upload attempt, shutting down with error\n"); |
@@ -101,8 +97,7 @@ do_download (void *cls, | |||
101 | "Downloading %llu bytes\n", | 97 | "Downloading %llu bytes\n", |
102 | (unsigned long long) FILESIZE); | 98 | (unsigned long long) FILESIZE); |
103 | start_time = GNUNET_TIME_absolute_get (); | 99 | start_time = GNUNET_TIME_absolute_get (); |
104 | GNUNET_FS_TEST_download (sched, | 100 | GNUNET_FS_TEST_download (daemons[0], |
105 | daemons[0], | ||
106 | TIMEOUT, | 101 | TIMEOUT, |
107 | 1, SEED, uri, | 102 | 1, SEED, uri, |
108 | VERBOSE, | 103 | VERBOSE, |
@@ -116,8 +111,7 @@ do_publish (void *cls, | |||
116 | { | 111 | { |
117 | if (0 == (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) | 112 | if (0 == (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) |
118 | { | 113 | { |
119 | GNUNET_FS_TEST_daemons_stop (sched, | 114 | GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, |
120 | NUM_DAEMONS, | ||
121 | daemons); | 115 | daemons); |
122 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 116 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
123 | "Timeout during connect attempt, shutting down with error\n"); | 117 | "Timeout during connect attempt, shutting down with error\n"); |
@@ -127,8 +121,7 @@ do_publish (void *cls, | |||
127 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 121 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
128 | "Publishing %llu bytes\n", | 122 | "Publishing %llu bytes\n", |
129 | (unsigned long long) FILESIZE); | 123 | (unsigned long long) FILESIZE); |
130 | GNUNET_FS_TEST_publish (sched, | 124 | GNUNET_FS_TEST_publish (daemons[1], |
131 | daemons[1], | ||
132 | TIMEOUT, | 125 | TIMEOUT, |
133 | 1, GNUNET_NO, FILESIZE, SEED, | 126 | 1, GNUNET_NO, FILESIZE, SEED, |
134 | VERBOSE, | 127 | VERBOSE, |
@@ -143,8 +136,7 @@ do_connect (void *cls, | |||
143 | GNUNET_assert (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)); | 136 | GNUNET_assert (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)); |
144 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 137 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
145 | "Daemons started, will now try to connect them\n"); | 138 | "Daemons started, will now try to connect them\n"); |
146 | GNUNET_FS_TEST_daemons_connect (sched, | 139 | GNUNET_FS_TEST_daemons_connect (daemons[0], |
147 | daemons[0], | ||
148 | daemons[1], | 140 | daemons[1], |
149 | TIMEOUT, | 141 | TIMEOUT, |
150 | &do_publish, | 142 | &do_publish, |
@@ -154,14 +146,11 @@ do_connect (void *cls, | |||
154 | 146 | ||
155 | static void | 147 | static void |
156 | run (void *cls, | 148 | run (void *cls, |
157 | struct GNUNET_SCHEDULER_Handle *s, | ||
158 | char *const *args, | 149 | char *const *args, |
159 | const char *cfgfile, | 150 | const char *cfgfile, |
160 | const struct GNUNET_CONFIGURATION_Handle *cfg) | 151 | const struct GNUNET_CONFIGURATION_Handle *cfg) |
161 | { | 152 | { |
162 | sched = s; | 153 | GNUNET_FS_TEST_daemons_start ("fs_test_lib_data.conf", |
163 | GNUNET_FS_TEST_daemons_start (sched, | ||
164 | "fs_test_lib_data.conf", | ||
165 | TIMEOUT, | 154 | TIMEOUT, |
166 | NUM_DAEMONS, | 155 | NUM_DAEMONS, |
167 | daemons, | 156 | daemons, |