X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fplanetlab.c;h=9300744a5be31fb2056ef7c45dbbcae72a506450;hb=c4ab647140e6387139cb7fd54c43e96fc6981a5c;hp=1c6cbccc30625c18b922754bb53bb77c28ef921e;hpb=66033b3d11dfc7db217940ead889491f71c84813;p=util-vserver-pl.git diff --git a/src/planetlab.c b/src/planetlab.c index 1c6cbcc..9300744 100644 --- a/src/planetlab.c +++ b/src/planetlab.c @@ -86,7 +86,7 @@ process: if (vc_set_ccaps(ctx, &vc_caps)) return -1; - if (pl_setsched(ctx, 1, 0) < 0) { + if (pl_setsched(ctx, 0, 1) < 0) { PERROR("pl_setsched(%u)", ctx); exit(1); } @@ -183,38 +183,33 @@ do \ while (0) int -pl_setsched(xid_t ctx, uint32_t cpu_share, uint32_t cpu_sched_flags) +pl_setsched(xid_t ctx, uint32_t cpu_min, uint32_t cpu_share) { struct vc_set_sched vc_sched; struct vc_ctx_flags vc_flags; - uint32_t new_flags; vc_sched.set_mask = (VC_VXSM_FILL_RATE | VC_VXSM_INTERVAL | VC_VXSM_TOKENS | VC_VXSM_TOKENS_MIN | VC_VXSM_TOKENS_MAX | VC_VXSM_MSEC | - VC_VXSM_FILL_RATE2 | VC_VXSM_INTERVAL2 | VC_VXSM_FORCE | - VC_VXSM_IDLE_TIME); - vc_sched.fill_rate = 0; - vc_sched.fill_rate2 = cpu_share; /* tokens accumulated per interval */ - vc_sched.interval = vc_sched.interval2 = 1000; /* milliseconds */ + VC_VXSM_FILL_RATE2 | VC_VXSM_INTERVAL2 | VC_VXSM_FORCE); + vc_sched.fill_rate = cpu_min; /* percent reserved */ + vc_sched.interval = 100; + vc_sched.fill_rate2 = cpu_share; /* best-effort fair share of unreserved */ + vc_sched.interval2 = 1000; /* milliseconds */ vc_sched.tokens = 100; /* initial allocation of tokens */ vc_sched.tokens_min = 50; /* need this many tokens to run */ vc_sched.tokens_max = 100; /* max accumulated number of tokens */ - if (cpu_share == (uint32_t)VC_LIM_KEEP) - vc_sched.set_mask &= ~(VC_VXSM_FILL_RATE|VC_VXSM_FILL_RATE2); - - /* guaranteed CPU corresponds to SCHED_SHARE flag being cleared */ - if (cpu_sched_flags & VS_SCHED_CPU_GUARANTEED) { - new_flags = 0; - vc_sched.fill_rate = vc_sched.fill_rate2; + if (cpu_share) { + if (cpu_share == (uint32_t)VC_LIM_KEEP) + vc_sched.set_mask &= ~(VC_VXSM_FILL_RATE|VC_VXSM_FILL_RATE2); + else + vc_sched.set_mask |= VC_VXSM_IDLE_TIME; } - else - new_flags = VC_VXF_SCHED_SHARE; VC_SYSCALL(vc_set_sched(ctx, &vc_sched)); vc_flags.mask = VC_VXF_SCHED_FLAGS; - vc_flags.flagword = new_flags | VC_VXF_SCHED_HARD; + vc_flags.flagword = VC_VXF_SCHED_HARD; VC_SYSCALL(vc_set_cflags(ctx, &vc_flags)); return 0;