chiark
/
gitweb
/
~ianmdlvl
/
elogind.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
manager: configurable StartLimit default values
[elogind.git]
/
src
/
core
/
job.c
diff --git
a/src/core/job.c
b/src/core/job.c
index bf1d95690824818c593ff900a55ab479d40746d2..e5dcef7cf43d9f616665072f4e675028ecc711b3 100644
(file)
--- a/
src/core/job.c
+++ b/
src/core/job.c
@@
-99,10
+99,10
@@
void job_free(Job *j) {
assert(!j->object_list);
if (j->in_run_queue)
assert(!j->object_list);
if (j->in_run_queue)
- LIST_REMOVE(
Job,
run_queue, j->manager->run_queue, j);
+ LIST_REMOVE(run_queue, j->manager->run_queue, j);
if (j->in_dbus_queue)
if (j->in_dbus_queue)
- LIST_REMOVE(
Job,
dbus_queue, j->manager->dbus_job_queue, j);
+ LIST_REMOVE(dbus_queue, j->manager->dbus_job_queue, j);
if (j->timer_watch.type != WATCH_INVALID) {
assert(j->timer_watch.type == WATCH_JOB_TIMER);
if (j->timer_watch.type != WATCH_INVALID) {
assert(j->timer_watch.type == WATCH_JOB_TIMER);
@@
-114,7
+114,7
@@
void job_free(Job *j) {
}
while ((cl = j->bus_client_list)) {
}
while ((cl = j->bus_client_list)) {
- LIST_REMOVE(
JobBusClient,
client, j->bus_client_list, cl);
+ LIST_REMOVE(client, j->bus_client_list, cl);
free(cl);
}
free(j);
free(cl);
}
free(j);
@@
-267,9
+267,9
@@
JobDependency* job_dependency_new(Job *subject, Job *object, bool matters, bool
l->conflicts = conflicts;
if (subject)
l->conflicts = conflicts;
if (subject)
- LIST_PREPEND(
JobDependency,
subject, subject->subject_list, l);
+ LIST_PREPEND(subject, subject->subject_list, l);
- LIST_PREPEND(
JobDependency,
object, object->object_list, l);
+ LIST_PREPEND(object, object->object_list, l);
return l;
}
return l;
}
@@
-278,9
+278,9
@@
void job_dependency_free(JobDependency *l) {
assert(l);
if (l->subject)
assert(l);
if (l->subject)
- LIST_REMOVE(
JobDependency,
subject, l->subject->subject_list, l);
+ LIST_REMOVE(subject, l->subject->subject_list, l);
- LIST_REMOVE(
JobDependency,
object, l->object->object_list, l);
+ LIST_REMOVE(object, l->object->object_list, l);
free(l);
}
free(l);
}
@@
-491,7
+491,7
@@
int job_run_and_invalidate(Job *j) {
assert(j->type < _JOB_TYPE_MAX_IN_TRANSACTION);
assert(j->in_run_queue);
assert(j->type < _JOB_TYPE_MAX_IN_TRANSACTION);
assert(j->in_run_queue);
- LIST_REMOVE(
Job,
run_queue, j->manager->run_queue, j);
+ LIST_REMOVE(run_queue, j->manager->run_queue, j);
j->in_run_queue = false;
if (j->state != JOB_WAITING)
j->in_run_queue = false;
if (j->state != JOB_WAITING)
@@
-910,7
+910,7
@@
void job_add_to_run_queue(Job *j) {
if (j->in_run_queue)
return;
if (j->in_run_queue)
return;
- LIST_PREPEND(
Job,
run_queue, j->manager->run_queue, j);
+ LIST_PREPEND(run_queue, j->manager->run_queue, j);
j->in_run_queue = true;
}
j->in_run_queue = true;
}
@@
-925,7
+925,7
@@
void job_add_to_dbus_queue(Job *j) {
* job might just have been created and not yet assigned to a
* connection/client. */
* job might just have been created and not yet assigned to a
* connection/client. */
- LIST_PREPEND(
Job,
dbus_queue, j->manager->dbus_job_queue, j);
+ LIST_PREPEND(dbus_queue, j->manager->dbus_job_queue, j);
j->in_dbus_queue = true;
}
j->in_dbus_queue = true;
}