shaba/systemd-stable
1
1
Fork 0
mirror of https://github.com/systemd/systemd-stable.git synced 2024-12-25 23:21:33 +03:00
Code

get rid of 'linked' notion for objects

Browse Source
This commit is contained in:
Lennart Poettering 2010-01-26 19:25:02 +01:00
parent c8d9aef34f
commit ac1135be1f
5 changed files with 43 additions and 128 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
job.c
View File

@ -30,12 +30,12 @@ void job_free(Job *j) {
assert(j);
/* Detach from next 'bigger' objects */
if (j->linked) {
if (j->installed) {
if (j->name->meta.job == j)
j->name->meta.job = NULL;
hashmap_remove(j->manager->jobs, UINT32_TO_PTR(j->id));
j->linked = false;
j->installed = false;
}
/* Detach from next 'smaller' objects */
@ -260,7 +260,7 @@ bool job_is_runnable(Job *j) {
Name *other;
assert(j);
assert(j->linked);
assert(j->installed);
/* Checks whether there is any job running for the names this
* job needs to be running after (in the case of a 'positive'
@ -308,7 +308,9 @@ bool job_is_runnable(Job *j) {
int job_run_and_invalidate(Job *j) {
int r;
assert(j);
assert(j->installed);
if (j->in_run_queue) {
LIST_REMOVE(Job, run_queue, j->manager->run_queue, j);
@ -401,6 +403,7 @@ int job_finish_and_invalidate(Job *j, bool success) {
Iterator i;
assert(j);
assert(j->installed);
/* Patch restart jobs so that they become normal start jobs */
if (success && (j->type == JOB_RESTART || j->type == JOB_TRY_RESTART)) {
@ -460,7 +463,7 @@ int job_finish_and_invalidate(Job *j, bool success) {
void job_schedule_run(Job *j) {
assert(j);
assert(j->linked);
assert(j->installed);
if (j->in_run_queue)
return;

2
job.h
View File

@ -69,7 +69,7 @@ struct Job {
JobType type;
JobState state;
bool linked:1;
bool installed:1;
bool in_run_queue:1;
bool matters_to_anchor:1;
bool forced:1;

31
manager.c
View File

@ -95,7 +95,7 @@ static void transaction_delete_job(Manager *m, Job *j) {
manager_transaction_unlink_job(m, j);
if (!j->linked)
if (!j->installed)
job_free(j);
}
@ -115,7 +115,7 @@ static void transaction_abort(Manager *m) {
assert(m);
while ((j = hashmap_first(m->transaction_jobs)))
if (j->linked)
if (j->installed)
transaction_delete_job(m, j);
else
job_free(j);
@ -162,7 +162,7 @@ static void transaction_merge_and_delete_job(Manager *m, Job *j, Job *other, Job
assert(j);
assert(other);
assert(j->name == other->name);
assert(!j->linked);
assert(!j->installed);
/* Merges 'other' into 'j' and then deletes j. */
@ -295,7 +295,7 @@ static int transaction_merge_jobs(Manager *m) {
job_type_merge(&t, j->name->meta.job->type); /* Might fail. Which is OK */
while ((k = j->transaction_next)) {
if (j->linked) {
if (j->installed) {
transaction_merge_and_delete_job(m, k, j, t);
j = k;
} else
@ -348,7 +348,7 @@ static int transaction_verify_order_one(Manager *m, Job *j, Job *from, unsigned
for (k = from; k; k = (k->generation == generation ? k->marker : NULL)) {
if (!k->linked &&
if (!k->installed &&
!name_matters_to_anchor(k->name, k)) {
/* Ok, we can drop this one, so let's
* do so. */
@ -513,7 +513,7 @@ static int transaction_apply(Manager *m, JobMode mode) {
assert(!j->transaction_prev);
assert(!j->transaction_next);
if (j->linked)
if (j->installed)
continue;
if ((r = hashmap_put(m->jobs, UINT32_TO_PTR(j->id), j)) < 0)
@ -521,14 +521,14 @@ static int transaction_apply(Manager *m, JobMode mode) {
}
while ((j = hashmap_steal_first(m->transaction_jobs))) {
if (j->linked)
if (j->installed)
continue;
if (j->name->meta.job)
job_free(j->name->meta.job);
j->name->meta.job = j;
j->linked = true;
j->installed = true;
/* We're fully installed. Now let's free data we don't
* need anymore. */
@ -549,7 +549,7 @@ static int transaction_apply(Manager *m, JobMode mode) {
rollback:
HASHMAP_FOREACH(j, m->transaction_jobs, i) {
if (j->linked)
if (j->installed)
continue;
hashmap_remove(m->jobs, UINT32_TO_PTR(j->id));
@ -822,7 +822,6 @@ static void dispatch_load_queue(Manager *m) {
* tries to load its data until the queue is empty */
while ((meta = m->load_queue)) {
assert(meta->linked);
assert(meta->in_load_queue);
name_load(NAME(meta));
@ -855,15 +854,7 @@ int manager_load_name(Manager *m, const char *name, Name **_ret) {
return r;
}
if ((r = name_link(ret)) < 0) {
name_free(ret);
return r;
}
/* At this point the new entry is created and linked. However
* not loaded. Now load this entry and all its dependencies
* recursively */
name_add_to_load_queue(ret);
dispatch_load_queue(m);
*_ret = ret;
@ -914,7 +905,7 @@ void manager_dispatch_run_queue(Manager *m) {
m->dispatching_run_queue = true;
while ((j = m->run_queue)) {
assert(j->linked);
assert(j->installed);
assert(j->in_run_queue);
job_run_and_invalidate(j);

122
name.c
View File

@ -83,8 +83,6 @@ Name *name_new(Manager *m) {
n->meta.manager = m;
n->meta.type = _NAME_TYPE_INVALID;
/* We don't link the name here, that is left for name_link() */
return n;
}
@ -110,6 +108,12 @@ int name_add_name(Name *n, const char *text) {
return r;
}
if ((r = hashmap_put(n->meta.manager->names, s, n)) < 0) {
set_remove(n->meta.names, s);
free(s);
return r;
}
n->meta.type = t;
if (!n->meta.id)
@ -118,61 +122,14 @@ int name_add_name(Name *n, const char *text) {
return 0;
}
/* FIXME: Does not rollback on failure! */
int name_link_names(Name *n, bool replace) {
char *t;
Iterator i;
int r;
void name_add_to_load_queue(Name *n) {
assert(n);
if (!n->meta.linked)
return 0;
if (n->meta.load_state != NAME_STUB || n->meta.in_load_queue)
return;
/* Link all names that aren't linked yet. */
SET_FOREACH(t, n->meta.names, i)
if (replace) {
if ((r = hashmap_replace(n->meta.manager->names, t, n)) < 0)
return r;
} else {
if ((r = hashmap_put(n->meta.manager->names, t, n)) < 0)
return r;
}
return 0;
}
int name_link(Name *n) {
int r;
assert(n);
assert(!set_isempty(n->meta.names));
assert(!n->meta.linked);
if ((r = name_sanitize(n)) < 0)
return r;
n->meta.linked = true;
if ((r = name_link_names(n, false)) < 0) {
char *t;
Iterator i;
/* Rollback the registered names */
SET_FOREACH(t, n->meta.names, i)
hashmap_remove_value(n->meta.manager->names, t, n);
n->meta.linked = false;
return r;
}
if (n->meta.load_state == NAME_STUB) {
LIST_PREPEND(Meta, load_queue, n->meta.manager->load_queue, &n->meta);
n->meta.in_load_queue = true;
}
return 0;
LIST_PREPEND(Meta, load_queue, n->meta.manager->load_queue, &n->meta);
n->meta.in_load_queue = true;
}
static void bidi_set_free(Name *name, Set *s) {
@ -184,13 +141,11 @@ static void bidi_set_free(Name *name, Set *s) {
/* Frees the set and makes sure we are dropped from the
* inverse pointers */
if (name->meta.linked) {
SET_FOREACH(other, s, i) {
NameDependency d;
SET_FOREACH(other, s, i) {
NameDependency d;
for (d = 0; d < _NAME_DEPENDENCY_MAX; d++)
set_remove(other->meta.dependencies[d], name);
}
for (d = 0; d < _NAME_DEPENDENCY_MAX; d++)
set_remove(other->meta.dependencies[d], name);
}
set_free(s);
@ -198,21 +153,18 @@ static void bidi_set_free(Name *name, Set *s) {
void name_free(Name *name) {
NameDependency d;
Iterator i;
char *t;
assert(name);
/* Detach from next 'bigger' objects */
if (name->meta.linked) {
char *t;
Iterator i;
SET_FOREACH(t, name->meta.names, i)
hashmap_remove_value(name->meta.manager->names, t, name);
SET_FOREACH(t, name->meta.names, i)
hashmap_remove_value(name->meta.manager->names, t, name);
if (name->meta.in_load_queue)
LIST_REMOVE(Meta, load_queue, name->meta.manager->load_queue, &name->meta);
}
if (name->meta.in_load_queue)
LIST_REMOVE(Meta, load_queue, name->meta.manager->load_queue, &name->meta);
if (name->meta.load_state == NAME_LOADED)
if (NAME_VTABLE(name)->done)
@ -285,27 +237,6 @@ int name_merge(Name *name, Name *other) {
if ((r = ensure_merge(&name->meta.dependencies[d], other->meta.dependencies[d])) < 0)
return r;
/* Hookup new deps and names */
if (name->meta.linked) {
if ((r = name_sanitize(name)) < 0)
return r;
if ((r = name_link_names(name, true)) < 0)
return r;
}
return 0;
}
int name_sanitize(Name *n) {
NameDependency d;
assert(n);
/* Remove loops */
for (d = 0; d < _NAME_DEPENDENCY_MAX; d++)
set_remove(n->meta.dependencies[d], n);
return 0;
}
@ -467,19 +398,9 @@ int name_load(Name *name) {
if ((r = NAME_VTABLE(name)->init(name)) < 0)
goto fail;
if ((r = name_sanitize(name)) < 0)
goto fail_undo_init;
if ((r = name_link_names(name, false)) < 0)
goto fail_undo_init;
name->meta.load_state = NAME_LOADED;
return 0;
fail_undo_init:
if (NAME_VTABLE(name)->done)
NAME_VTABLE(name)->done(name);
fail:
name->meta.load_state = NAME_FAILED;
return r;
@ -893,6 +814,9 @@ int name_add_dependency(Name *n, NameDependency d, Name *other) {
assert(inverse_table[d] != _NAME_DEPENDENCY_INVALID);
assert(other);
if (n == other)
return 0;
if ((r = set_ensure_allocated(&n->meta.dependencies[d], trivial_hash_func, trivial_compare_func)) < 0)
return r;

5
name.h
View File

@ -108,7 +108,6 @@ struct Meta {
* the job for it */
Job *job;
bool linked:1;
bool in_load_queue:1;
usec_t active_enter_timestamp;
@ -200,10 +199,8 @@ bool name_is_valid(const char *n);
Name *name_new(Manager *m);
void name_free(Name *name);
int name_link(Name *name);
int name_link_names(Name *name, bool replace);
void name_add_to_load_queue(Name *n);
int name_merge(Name *name, Name *other);
int name_sanitize(Name *n);
int name_load_fragment_and_dropin(Name *n);
int name_load(Name *name);
const char* name_id(Name *n);