X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=blobdiff_plain;f=manager.c;h=688d9fa65b28e831217faee879cf4977a241006f;hp=4cc7d30e24ef5732df9ad60822e6c11f9869aacf;hb=92aa6f363360cbb4e300648e5cbdb6fe4cce1b57;hpb=affda78706e2388902dd7c9ebdece52787afe3b4 diff --git a/manager.c b/manager.c index 4cc7d30e2..688d9fa65 100644 --- a/manager.c +++ b/manager.c @@ -57,7 +57,7 @@ #define GC_QUEUE_ENTRIES_MAX 16 /* As soon as 5s passed since a unit was added to our GC queue, make sure to run a gc sweep */ -#define GC_QUEUE_USEC_MAX (5*USEC_PER_SEC) +#define GC_QUEUE_USEC_MAX (10*USEC_PER_SEC) static int enable_special_signals(Manager *m) { char fd; @@ -1563,7 +1563,7 @@ int manager_load_unit_prepare(Manager *m, const char *name, const char *path, Un if ((ret = manager_get_unit(m, name))) { *_ret = ret; - return 0; + return 1; } if (!(ret = unit_new(m))) @@ -1582,6 +1582,7 @@ int manager_load_unit_prepare(Manager *m, const char *name, const char *path, Un unit_add_to_load_queue(ret); unit_add_to_dbus_queue(ret); + unit_add_to_gc_queue(ret); if (_ret) *_ret = ret; @@ -1590,7 +1591,6 @@ int manager_load_unit_prepare(Manager *m, const char *name, const char *path, Un } int manager_load_unit(Manager *m, const char *name, const char *path, Unit **_ret) { - Unit *ret; int r; assert(m); @@ -1598,13 +1598,13 @@ int manager_load_unit(Manager *m, const char *name, const char *path, Unit **_re /* This will load the service information files, but not actually * start any services or anything. */ - if ((r = manager_load_unit_prepare(m, name, path, &ret)) < 0) + if ((r = manager_load_unit_prepare(m, name, path, _ret)) != 0) return r; manager_dispatch_load_queue(m); if (_ret) - *_ret = unit_follow_merge(ret); + *_ret = unit_follow_merge(*_ret); return 0; } @@ -1949,19 +1949,19 @@ int manager_loop(Manager *m) { sleep(1); } - if (manager_dispatch_cleanup_queue(m) > 0) + if (manager_dispatch_load_queue(m) > 0) continue; - if (manager_dispatch_gc_queue(m) > 0) + if (manager_dispatch_run_queue(m) > 0) continue; - if (manager_dispatch_load_queue(m) > 0) + if (bus_dispatch(m) > 0) continue; - if (manager_dispatch_run_queue(m) > 0) + if (manager_dispatch_cleanup_queue(m) > 0) continue; - if (bus_dispatch(m) > 0) + if (manager_dispatch_gc_queue(m) > 0) continue; if (manager_dispatch_dbus_queue(m) > 0)