# HG changeset patch # User Juergen Gross # Date 1321526262 -3600 # Node ID 0d1eb69dbd1c691b3bee9f95a40c5b000b3a8705 # Parent 714852e181d3c1fdb1cde4f28a592110a9c7cf0d [mq]: sched-sedf diff -r 714852e181d3 -r 0d1eb69dbd1c docs/man/xl.pod.1 --- a/docs/man/xl.pod.1 Thu Nov 17 09:58:36 2011 +0100 +++ b/docs/man/xl.pod.1 Thu Nov 17 11:37:42 2011 +0100 @@ -645,6 +645,48 @@ Restrict output to domains in the specif =back +=item B [I] + +Set or get Simple EDF (Earliest Deadline First) scheduler parameters. This +scheduler provides weighted CPU sharing in an intuitive way and uses +realtime-algorithms to ensure time guarantees. For more information see +docs/misc/sedf_scheduler_mini-HOWTO.txt in the Xen distribution. + +B + +=over 4 + +=item B<-d DOMAIN>, B<--domain=DOMAIN> + +Specify domain for which scheduler parameters are to be modified or retrieved. +Mandatory for modifying scheduler parameters. + +=item B<-p PERIOD>, B<--period=PERIOD> + +The normal EDF scheduling usage in milliseconds. + +=item B<-s SLICE>, B<--slice=SLICE> + +The normal EDF scheduling usage in milliseconds. + +=item B<-l LATENCY>, B<--latency=LATENCY> + +Scaled period if domain is doing heavy I/O. + +=item B<-e EXTRA>, B<--extra=EXTRA> + +Flag for allowing domain to run in extra time (0 or 1). + +=item B<-w WEIGHT>, B<--weight=WEIGHT> + +Another way of setting CPU slice. + +=item B<-c CPUPOOL>, B<--cpupool=CPUPOOL> + +Restrict output to domains in the specified cpupool. + +=back + =back =head1 CPUPOOLS COMMANDS diff -r 714852e181d3 -r 0d1eb69dbd1c tools/libxl/libxl.c --- a/tools/libxl/libxl.c Thu Nov 17 09:58:36 2011 +0100 +++ b/tools/libxl/libxl.c Thu Nov 17 11:37:42 2011 +0100 @@ -2777,6 +2777,55 @@ int libxl_sched_credit2_domain_set(libxl return 0; } +int libxl_sched_sedf_domain_get(libxl_ctx *ctx, uint32_t domid, libxl_sched_sedf *scinfo) +{ + uint64_t period; + uint64_t slice; + uint64_t latency; + uint16_t extratime; + uint16_t weight; + int rc; + + rc = xc_sedf_domain_get(ctx->xch, domid, &period, &slice, &latency, &extratime, &weight); + if (rc != 0) { + LIBXL__LOG_ERRNO(ctx, LIBXL__LOG_ERROR, "getting domain sched sedf"); + return ERROR_FAIL; + } + + scinfo->period = period / 1000000; + scinfo->slice = slice / 1000000; + scinfo->latency = latency / 1000000; + scinfo->extratime = extratime; + scinfo->weight = weight; + + return 0; +} + +int libxl_sched_sedf_domain_set(libxl_ctx *ctx, uint32_t domid, libxl_sched_sedf *scinfo) +{ + xc_domaininfo_t domaininfo; + int rc; + + rc = xc_domain_getinfolist(ctx->xch, domid, 1, &domaininfo); + if (rc < 0) { + LIBXL__LOG_ERRNO(ctx, LIBXL__LOG_ERROR, "getting domain info list"); + return ERROR_FAIL; + } + if (rc != 1 || domaininfo.domain != domid) + return ERROR_INVAL; + + + rc = xc_sedf_domain_set(ctx->xch, domid, scinfo->period * 1000000, + scinfo->slice * 1000000, scinfo->latency * 1000000, + scinfo->extratime, scinfo->weight); + if ( rc < 0 ) { + LIBXL__LOG_ERRNO(ctx, LIBXL__LOG_ERROR, "setting domain sched sedf"); + return ERROR_FAIL; + } + + return 0; +} + static int trigger_type_from_string(char *trigger_name) { if (!strcmp(trigger_name, "nmi")) diff -r 714852e181d3 -r 0d1eb69dbd1c tools/libxl/libxl.h --- a/tools/libxl/libxl.h Thu Nov 17 09:58:36 2011 +0100 +++ b/tools/libxl/libxl.h Thu Nov 17 11:37:42 2011 +0100 @@ -571,6 +571,10 @@ int libxl_sched_credit2_domain_get(libxl libxl_sched_credit2 *scinfo); int libxl_sched_credit2_domain_set(libxl_ctx *ctx, uint32_t domid, libxl_sched_credit2 *scinfo); +int libxl_sched_sedf_domain_get(libxl_ctx *ctx, uint32_t domid, + libxl_sched_sedf *scinfo); +int libxl_sched_sedf_domain_set(libxl_ctx *ctx, uint32_t domid, + libxl_sched_sedf *scinfo); int libxl_send_trigger(libxl_ctx *ctx, uint32_t domid, char *trigger_name, uint32_t vcpuid); int libxl_send_sysrq(libxl_ctx *ctx, uint32_t domid, char sysrq); diff -r 714852e181d3 -r 0d1eb69dbd1c tools/libxl/libxl_types.idl --- a/tools/libxl/libxl_types.idl Thu Nov 17 09:58:36 2011 +0100 +++ b/tools/libxl/libxl_types.idl Thu Nov 17 11:37:42 2011 +0100 @@ -377,3 +377,11 @@ libxl_sched_credit2 = Struct("sched_cred libxl_sched_credit2 = Struct("sched_credit2", [ ("weight", integer), ], dispose_fn=None) + +libxl_sched_sedf = Struct("sched_sedf", [ + ("period", integer), + ("slice", integer), + ("latency", integer), + ("extratime", integer), + ("weight", integer), + ], dispose_fn=None) diff -r 714852e181d3 -r 0d1eb69dbd1c tools/libxl/xl.h --- a/tools/libxl/xl.h Thu Nov 17 09:58:36 2011 +0100 +++ b/tools/libxl/xl.h Thu Nov 17 11:37:42 2011 +0100 @@ -56,6 +56,7 @@ int main_memset(int argc, char **argv); int main_memset(int argc, char **argv); int main_sched_credit(int argc, char **argv); int main_sched_credit2(int argc, char **argv); +int main_sched_sedf(int argc, char **argv); int main_domid(int argc, char **argv); int main_domname(int argc, char **argv); int main_rename(int argc, char **argv); diff -r 714852e181d3 -r 0d1eb69dbd1c tools/libxl/xl_cmdimpl.c --- a/tools/libxl/xl_cmdimpl.c Thu Nov 17 09:58:36 2011 +0100 +++ b/tools/libxl/xl_cmdimpl.c Thu Nov 17 11:37:42 2011 +0100 @@ -3766,6 +3766,57 @@ static int sched_credit2_domain_output( return 0; } +static int sched_sedf_domain_get( + int domid, libxl_sched_sedf *scinfo) +{ + int rc; + + rc = libxl_sched_sedf_domain_get(ctx, domid, scinfo); + if (rc) + fprintf(stderr, "libxl_sched_sedf_domain_get failed.\n"); + + return rc; +} + +static int sched_sedf_domain_set( + int domid, libxl_sched_sedf *scinfo) +{ + int rc; + + rc = libxl_sched_sedf_domain_set(ctx, domid, scinfo); + if (rc) + fprintf(stderr, "libxl_sched_sedf_domain_set failed.\n"); + + return rc; +} + +static int sched_sedf_domain_output( + int domid) +{ + char *domname; + libxl_sched_sedf scinfo; + int rc; + + if (domid < 0) { + printf("%-33s %4s %6s %-6s %7s %5s %6s\n", "Name", "ID", "Period", "Slice", "Latency", "Extra", "Weight"); + return 0; + } + rc = sched_sedf_domain_get(domid, &scinfo); + if (rc) + return rc; + domname = libxl_domid_to_name(ctx, domid); + printf("%-33s %4d %6d %6d %7d %5d %6d\n", + domname, + domid, + scinfo.period, + scinfo.slice, + scinfo.latency, + scinfo.extratime, + scinfo.weight); + free(domname); + return 0; +} + static int sched_domain_output( uint32_t sched, int (*output)(int), const char *cpupool) { @@ -3964,6 +4015,119 @@ int main_sched_credit2(int argc, char ** if (opt_w) scinfo.weight = weight; rc = sched_credit2_domain_set(domid, &scinfo); + if (rc) + return -rc; + } + } + + return 0; +} + +int main_sched_sedf(int argc, char **argv) +{ + libxl_sched_sedf scinfo; + const char *dom = NULL; + const char *cpupool = NULL; + int period = 0, opt_p = 0; + int slice = 0, opt_s = 0; + int latency = 0, opt_l = 0; + int extra = 0, opt_e = 0; + int weight = 0, opt_w = 0; + int opt, rc; + int option_index = 0; + static struct option long_options[] = { + {"period", 1, 0, 'p'}, + {"slice", 1, 0, 's'}, + {"latency", 1, 0, 'l'}, + {"extra", 1, 0, 'e'}, + {"weight", 1, 0, 'w'}, + {"cpupool", 1, 0, 'c'}, + {"help", 0, 0, 'h'}, + {0, 0, 0, 0} + }; + + while (1) { + opt = getopt_long(argc, argv, "d:p:s:l:e:w:c:h", long_options, &option_index); + if (opt == -1) + break; + switch (opt) { + case 0: case 2: + return opt; + case 'd': + dom = optarg; + break; + case 'p': + period = strtol(optarg, NULL, 10); + opt_p = 1; + break; + case 's': + slice = strtol(optarg, NULL, 10); + opt_s = 1; + break; + case 'l': + latency = strtol(optarg, NULL, 10); + opt_l = 1; + break; + case 'e': + extra = strtol(optarg, NULL, 10); + opt_e = 1; + break; + case 'w': + weight = strtol(optarg, NULL, 10); + opt_w = 1; + break; + case 'c': + cpupool = optarg; + break; + case 'h': + help("sched-sedf"); + return 0; + } + } + + if (cpupool && (dom || opt_p || opt_s || opt_l || opt_e || opt_w)) { + fprintf(stderr, "Specifying a cpupool is not allowed with other options.\n"); + return 1; + } + if (!dom && (opt_p || opt_s || opt_l || opt_e || opt_w)) { + fprintf(stderr, "Must specify a domain.\n"); + return 1; + } + if (opt_w && (opt_p || opt_s)) { + fprintf(stderr, "Specifying a weight AND period or slice is not allowed.\n"); + } + + if (!dom) { /* list all domain's credit scheduler info */ + return -sched_domain_output(XEN_SCHEDULER_SEDF, sched_sedf_domain_output, cpupool); + } else { + find_domain(dom); + + rc = sched_sedf_domain_get(domid, &scinfo); + if (rc) + return -rc; + + if (!opt_p && !opt_s && !opt_l && !opt_e && !opt_w) { /* output sedf scheduler info */ + sched_sedf_domain_output(-1); + return -sched_sedf_domain_output(domid); + } else { /* set sedf scheduler paramaters */ + if (opt_p) { + scinfo.period = period; + scinfo.weight = 0; + } + if (opt_s) { + scinfo.slice = slice; + scinfo.weight = 0; + } + if (opt_l) + scinfo.latency = latency; + if (opt_e) + scinfo.extratime = extra; + if (opt_w) { + scinfo.weight = weight; + scinfo.period = 0; + scinfo.slice = 0; + } + rc = sched_sedf_domain_set(domid, &scinfo); if (rc) return -rc; } diff -r 714852e181d3 -r 0d1eb69dbd1c tools/libxl/xl_cmdtable.c --- a/tools/libxl/xl_cmdtable.c Thu Nov 17 09:58:36 2011 +0100 +++ b/tools/libxl/xl_cmdtable.c Thu Nov 17 11:37:42 2011 +0100 @@ -205,6 +205,22 @@ struct cmd_spec cmd_table[] = { "-d DOMAIN, --domain=DOMAIN Domain to modify\n" "-w WEIGHT, --weight=WEIGHT Weight (int)\n" "-p CPUPOOL, --cpupool=CPUPOOL Restrict output to CPUPOOL" + }, + { "sched-sedf", + &main_sched_sedf, 0, + "Get/set sedf scheduler parameters", + "[options]", + "-d DOMAIN, --domain=DOMAIN Domain to modify\n" + "-p MS, --period=MS Relative deadline(ms)\n" + "-s MS, --slice=MS Worst-case execution time(ms). (slice <\n" + " period)\n" + "-l MS, --latency=MS Scaled period (ms) when domain performs\n" + " heavy I/O\n" + "-e FLAG, --extra=FLAG Flag (0 or 1) controls if domain can run\n" + " in extra time\n" + "-w FLOAT, --weight=FLOAT CPU Period/slice (do not set with\n" + " --period/--slice)\n" + "-c CPUPOOL, --cpupool=CPUPOOL Restrict output to CPUPOOL" }, { "domid", &main_domid, 0,