Changeset 25697163 in mainline for uspace/srv/sysman/job_closure.c
- Timestamp:
- 2019-10-06T19:47:15Z (5 years ago)
- Children:
- 9559cf8
- Parents:
- 102f641
- git-author:
- Matthieu Riolo <matthieu.riolo@…> (2019-09-06 17:58:36)
- git-committer:
- Matthieu Riolo <matthieu.riolo@…> (2019-10-06 19:47:15)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/sysman/job_closure.c
r102f641 r25697163 51 51 * return result of visit (error stops further traversal) 52 52 */ 53 int (*visit)(unit_t *, unit_edge_t *, bfs_ops_t *, void *);53 errno_t (*visit)(unit_t *, unit_edge_t *, bfs_ops_t *, void *); 54 54 55 55 /** Clean units remaining in BFS queue after error */ … … 61 61 */ 62 62 63 static int job_add_blocked_job(job_t *blocking_job, job_t *blocked_job)63 static errno_t job_add_blocked_job(job_t *blocking_job, job_t *blocked_job) 64 64 { 65 65 assert(blocking_job->blocked_jobs.size == 66 66 blocking_job->blocked_jobs_count); 67 67 68 int rc = dyn_array_append(&blocking_job->blocked_jobs, job_t *,68 errno_t rc = dyn_array_append(&blocking_job->blocked_jobs, job_t *, 69 69 blocked_job); 70 70 if (rc != EOK) { … … 86 86 * @return EOK on success 87 87 */ 88 static int visit_propagate_job(unit_t *u, unit_edge_t *e, bfs_ops_t *ops,88 static errno_t visit_propagate_job(unit_t *u, unit_edge_t *e, bfs_ops_t *ops, 89 89 void *arg) 90 90 { 91 int rc = EOK;91 errno_t rc = EOK; 92 92 job_t *created_job = NULL; 93 93 job_closure_t *closure = arg; … … 138 138 } 139 139 140 static int visit_isolate(unit_t *u, unit_edge_t *e, bfs_ops_t *ops, void *arg)141 { 142 int rc = EOK;140 static errno_t visit_isolate(unit_t *u, unit_edge_t *e, bfs_ops_t *ops, void *arg) 141 { 142 errno_t rc = EOK; 143 143 job_t *created_job = NULL; 144 144 job_closure_t *closure = arg; … … 187 187 } 188 188 189 static int bfs_traverse_component_internal(unit_t *origin, bfs_ops_t *ops,189 static errno_t bfs_traverse_component_internal(unit_t *origin, bfs_ops_t *ops, 190 190 void *arg) 191 191 { 192 int rc;192 errno_t rc; 193 193 list_t units_fifo; 194 194 list_initialize(&units_fifo); … … 247 247 } 248 248 249 static int bfs_traverse_component(unit_t *origin, bfs_ops_t *ops, void *arg)249 static errno_t bfs_traverse_component(unit_t *origin, bfs_ops_t *ops, void *arg) 250 250 { 251 251 /* Check invariant */ … … 253 253 assert(u->bfs_tag == false); 254 254 } 255 int rc = bfs_traverse_component_internal(origin, ops, arg);255 errno_t rc = bfs_traverse_component_internal(origin, ops, arg); 256 256 257 257 /* Clean after ourselves (BFS tag jobs) */ … … 262 262 } 263 263 264 static int bfs_traverse_all(bfs_ops_t *ops, void *arg)264 static errno_t bfs_traverse_all(bfs_ops_t *ops, void *arg) 265 265 { 266 266 /* Check invariant */ … … 268 268 assert(u->bfs_tag == false); 269 269 } 270 int rc = EOK;270 errno_t rc = EOK; 271 271 272 272 repo_foreach(origin) { … … 299 299 * @return EOK on success otherwise propagated error 300 300 */ 301 int job_create_closure(job_t *main_job, job_closure_t *job_closure, int flags)301 errno_t job_create_closure(job_t *main_job, job_closure_t *job_closure, int flags) 302 302 { 303 303 sysman_log(LVL_DEBUG2, "%s(%s)", __func__, unit_name(main_job->unit)); … … 308 308 } 309 309 310 int rc = dyn_array_append(job_closure, job_t *, main_job);310 errno_t rc = dyn_array_append(job_closure, job_t *, main_job); 311 311 if (rc != EOK) { 312 312 return rc;
Note:
See TracChangeset
for help on using the changeset viewer.