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/util/test_os_start_process.c | |
parent | 7217c601ad30760872823193d62307e7a335d226 (diff) | |
download | gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.tar.gz gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.zip |
big scheduler refactoring, expect some issues
Diffstat (limited to 'src/util/test_os_start_process.c')
-rw-r--r-- | src/util/test_os_start_process.c | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/src/util/test_os_start_process.c b/src/util/test_os_start_process.c index bce1c7151..f82860e83 100644 --- a/src/util/test_os_start_process.c +++ b/src/util/test_os_start_process.c | |||
@@ -78,8 +78,8 @@ read_call (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
78 | { | 78 | { |
79 | GNUNET_break (0); | 79 | GNUNET_break (0); |
80 | ok = 1; | 80 | ok = 1; |
81 | GNUNET_SCHEDULER_cancel(tc->sched, die_task); | 81 | GNUNET_SCHEDULER_cancel(die_task); |
82 | GNUNET_SCHEDULER_add_now(tc->sched, &end_task, NULL); | 82 | GNUNET_SCHEDULER_add_now(&end_task, NULL); |
83 | return; | 83 | return; |
84 | } | 84 | } |
85 | 85 | ||
@@ -89,13 +89,12 @@ read_call (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
89 | #endif | 89 | #endif |
90 | if (ok == 0) | 90 | if (ok == 0) |
91 | { | 91 | { |
92 | GNUNET_SCHEDULER_cancel(tc->sched, die_task); | 92 | GNUNET_SCHEDULER_cancel(die_task); |
93 | GNUNET_SCHEDULER_add_now(tc->sched, &end_task, NULL); | 93 | GNUNET_SCHEDULER_add_now(&end_task, NULL); |
94 | return; | 94 | return; |
95 | } | 95 | } |
96 | 96 | ||
97 | GNUNET_SCHEDULER_add_read_file (tc->sched, | 97 | GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL, |
98 | GNUNET_TIME_UNIT_FOREVER_REL, | ||
99 | stdout_read_handle, &read_call, stdout_read_handle); | 98 | stdout_read_handle, &read_call, stdout_read_handle); |
100 | 99 | ||
101 | } | 100 | } |
@@ -145,10 +144,9 @@ task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
145 | 144 | ||
146 | stdout_read_handle = GNUNET_DISK_pipe_handle(hello_pipe_stdout, GNUNET_DISK_PIPE_END_READ); | 145 | stdout_read_handle = GNUNET_DISK_pipe_handle(hello_pipe_stdout, GNUNET_DISK_PIPE_END_READ); |
147 | 146 | ||
148 | die_task = GNUNET_SCHEDULER_add_delayed(tc->sched, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MINUTES, 1), &end_task, NULL); | 147 | die_task = GNUNET_SCHEDULER_add_delayed(GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MINUTES, 1), &end_task, NULL); |
149 | 148 | ||
150 | GNUNET_SCHEDULER_add_read_file (tc->sched, | 149 | GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL, |
151 | GNUNET_TIME_UNIT_FOREVER_REL, | ||
152 | stdout_read_handle, &read_call, (void *)stdout_read_handle); | 150 | stdout_read_handle, &read_call, (void *)stdout_read_handle); |
153 | 151 | ||
154 | } | 152 | } |