基于QPLMTS算法的边缘计算场景下的任务调度器源码+项目说明.zip

/****************************************************************************** * Copyright (c) 2007-2013. F. Suter, S. Hunold. * All rights reserved. * * This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL 2.1) which comes with this package. *****************************************************************************/ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <time.h> #include <math.h> #include <unistd.h> #include <getopt.h> #include "daggen_commons.h" /*********************************/ /** Command line option parsing **/ /*********************************/ /* * Parse the options and set default values * * returns -1 for usage * returns -2 for no usage * returns 0 when Ok */ int parseOptions(int argc, char *const *argv) { int ret_val = 0; int c; int oflag = 0; int nflag = 0; int fat_flag = 0; int density_flag = 0; int ccr_flag = 0; int mindata_flag = 0; int maxdata_flag = 0; int minalpha_flag = 0; int maxalpha_flag = 0; int regular_flag = 0; int jump_flag = 0; int dot_flag = 0; global.output_file=stdout; global.jump=1; global.mindata=2048; global.maxdata=11264; global.minalpha=0.0; global.maxalpha=0.2; global.ccr=0; global.density=0.5; global.fat=0.5; global.regular=0.9; global.n=100; global.dot_output=0; while (ret_val == 0) { static struct option long_options[] = { { "fat", 1, 0, 0 }, /* double */ { "density", 1, 0, 0 }, /* double */ { "ccr", 1, 0, 0 }, /* int */ { "mindata", 1, 0, 0 }, /* int */ { "maxdata", 1, 0, 0 }, /* int */ { "minalpha", 1, 0, 0 }, /* double */ { "maxalpha", 1, 0, 0 }, /* double */ { "regular", 1, 0, 0 }, /* double */ { "jump", 1, 0, 0 }, /* int */ { "dot", 0, 0, 0}, { 0, 0, 0, 0 } }; /* getopt_long stores the option index here. */ int option_index = 0; /* parameters h help o string output n int nodes */ c = getopt_long(argc, argv, "ho:n:", long_options, &option_index); /* Detect the end of the options. */ if (c == -1) break; switch (c) { case 0: /* If this option set a flag, do nothing else now. */ if (long_options[option_index].flag != 0) break; // we do nothing right now with the long opts const char *optname = long_options[option_index].name; if (!strcmp(optname, "fat")) { double fat=atof(optarg); fat_flag = 1; if ((fat < 0.0) || (fat > 1.0)) { fprintf(stderr,"Error: invalid fat value: %f\n",fat); ret_val = -1; } global.fat=fat; } else if (!strcmp(optname, "density")) { double density=atof(optarg); density_flag = 1; if ((density < 0.0) || (density > 1.0)) { fprintf(stderr,"Error: invalid density value: %f\n",density); ret_val = -1; } global.density=density; } else if (!strcmp(optname, "ccr")) { int ccr=atoi(optarg); ccr_flag = 1; if (ccr < 0) { fprintf(stderr,"Error: invalid ccr value: %d\n",ccr); ret_val = -1; } global.ccr=ccr; } else if (!strcmp(optname, "mindata")) { int mindata=atoi(optarg); mindata_flag = 1; if (mindata <= 0) { fprintf(stderr,"Error: invalid mindata value: %d\n",mindata); ret_val = -1; } global.mindata=mindata; } else if (!strcmp(optname, "maxdata")) { int maxdata=atoi(optarg); maxdata_flag = 1; if ((maxdata <= 0) || (maxdata < global.mindata)) { fprintf(stderr,"Error: invalid maxdata value: %d\n",maxdata); ret_val = -1; } global.maxdata=maxdata; } else if (!strcmp(optname, "minalpha")) { double minalpha=atof(optarg); minalpha_flag = 1; if (minalpha < 0.0) { fprintf(stderr,"Error: invalid minalpha value: %f\n",minalpha); ret_val = -1; } global.minalpha=minalpha; } else if (!strcmp(optname, "maxalpha")) { double maxalpha=atof(optarg); maxalpha_flag = 1; if ((maxalpha < 0.0) || (maxalpha < global.minalpha)) { fprintf(stderr,"Error: invalid maxalpha value: %f\n",maxalpha); ret_val = -1; } global.maxalpha=maxalpha; } else if (!strcmp(optname, "regular")) { double regular=atof(optarg); regular_flag = 1; if ((regular < 0.0) || (regular > 1.0)) { fprintf(stderr,"Error: invalid regular value: %f\n",regular); ret_val = -1; } global.regular=regular; } else if (!strcmp(optname, "jump")) { int jump = atoi(optarg); jump_flag = 1; if (jump < 0) { fprintf(stderr,"Error: invalud jump value: %d\n",jump); ret_val = -1; } global.jump=jump; } else if (!strcmp(optname, "dot")) { dot_flag = 1; global.dot_output=1; } else { fprintf(stderr, "unknown switch: %s\n", optname); } break; case 'n': { int n=atoi(optarg); nflag = 1; if (n <= 0) { fprintf(stderr,"Error: invalid n value: %d\n", n); ret_val = -1; } global.n=n; } break; case 'o': oflag = 1; const char *filename = optarg; if ((global.output_file=fopen(filename, "w")) == NULL) { fprintf(stderr,"Error: Cannot open file '%s' for output\n", filename); ret_val = -1; } break; case 'h': ret_val = -1; // show usage break; case '?': /* getopt_long already printed an error message. */ break; default: abort(); break; } } if( ret_val == 0 ) { if (!nflag) { fprintf(stderr,"Warning: using default n value (%d)\n", global.n); } if (!oflag) { fprintf(stderr,"Warning: Sending output to stdout\n"); } if (!jump_flag) { fprintf(stderr,"Warning: using default jump value (%d)\n", global.jump); } if (!fat_flag) { fprintf(stderr,"Warning: using default fat value (%g)\n", global.fat); } if (!density_flag) { fprintf(stderr,"Warning: using default density value (%g)\n", global.density); } if (!ccr_flag) { fprintf(stderr,"Warning: using default ccr value (%d)\n", global.ccr); } if (!mindata_flag) { fprintf(stderr,"Warning: using default mindata value (%g)\n", global.mindata); } if (!maxdata_flag) { fprintf(stderr,"Warning: using default maxdata value (%g)\n", global.maxdata); } if (!minalpha_flag) { fprintf(stderr,"Warning: using default minalpha value (%g)\n", global.minalpha); } if (!maxalpha_flag) { fprintf(stderr,"Warning: using default maxalpha value (%g)\n", global.maxalpha); } if (!regular_flag) { fprintf(stderr,"Warning: using default regular value (%g)\n", global.regular); } } return ret_val; } /* * printUsage() */ void printUsage(void) { fprintf(stderr,"daggen [options] [-o <output file>]\n" "\t -n <number of tasks>\n" "\t --mindata <minimum data size>\n" "\t --maxdata <maximum data size>\n" "\t --minalpha <minimum Amdahl's law parameter value>\n" "\t --maxalpha <maximum Amdahl's law parameter value>\n"); fprintf(stderr, "\t --fat <dag shape>\n" "\t fat=1.0: fat (maximum parallelism)\n" "\t fat=0.0: thin (minimum parallelism)\n" "\t --density <density>\n" "\t density=0.0: minimum number of dependencies\n" "\t density=1.0: full graph\n" "\t --regular <regularity for num tasks per level>\n" "\t regular= 1.0: perfectly regular\n" "\t regular= 0.0: irregular\n" "\t --ccr