aboutsummaryrefslogtreecommitdiff
path: root/src/util/test_os_start_process.c
diff options
context:
space:
mode:
authorNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
committerNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
commit75a33a1499cf60ea4364c9aa673816629a6c1413 (patch)
tree0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/util/test_os_start_process.c
parent7217c601ad30760872823193d62307e7a335d226 (diff)
downloadgnunet-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.c16
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}