cpuctl_def_task01.c revision f600923885d241656bc95feb772962c5596fef4a
1/******************************************************************************/ 2/* */ 3/* Copyright (c) International Business Machines Corp., 2007 */ 4/* */ 5/* This program is free software; you can redistribute it and/or modify */ 6/* it under the terms of the GNU General Public License as published by */ 7/* the Free Software Foundation; either version 2 of the License, or */ 8/* (at your option) any later version. */ 9/* */ 10/* This program is distributed in the hope that it will be useful, */ 11/* but WITHOUT ANY WARRANTY; without even the implied warranty of */ 12/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See */ 13/* the GNU General Public License for more details. */ 14/* */ 15/* You should have received a copy of the GNU General Public License */ 16/* along with this program; if not, write to the Free Software */ 17/* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ 18/* */ 19/******************************************************************************/ 20 21/******************************************************************************/ 22/* */ 23/* File: cpuctl_task_def01.c */ 24/* */ 25/* Description: This is a c program that runs as a default task in a default */ 26/* group to create an ideal scenario. In this default group all */ 27/* the system tasks will be running along with this spinning task*/ 28/* The file is to be used by tests 1-3. */ 29/* */ 30/* Total Tests: 1 */ 31/* */ 32/* Test Name: cpu_controller_tests */ 33/* */ 34/* Test Assertion */ 35/* Please refer to the file cpuctl_testplan.txt */ 36/* */ 37/* Author: Sudhir Kumar skumar@linux.vnet.ibm.com */ 38/* */ 39/* History: */ 40/* Created- 14/11/2008 -Sudhir Kumar <skumar@linux.vnet.ibm.com> */ 41/* */ 42/******************************************************************************/ 43 44/* Standard Include Files */ 45#include <unistd.h> 46#include <math.h> 47#include <signal.h> 48#include <stdio.h> 49#include <stdlib.h> 50#include <string.h> 51#include <sys/resource.h> 52#include <sys/syscall.h> 53#include <sys/time.h> 54#include <sys/types.h> 55#include <sys/stat.h> 56#include <fcntl.h> 57#include <time.h> 58#include <unistd.h> 59 60#include "../libcontrollers/libcontrollers.h" 61#include "test.h" /* LTP harness APIs*/ 62 63#ifdef DEBUG 64#define dbg(x...) printf(x); 65#else 66#define dbg(x...) do {} while (0) 67#endif 68 69#define TIME_INTERVAL 30 /* Time interval in seconds*/ 70#define NUM_INTERVALS 3 /* How many iterations of TIME_INTERVAL */ 71#define NUM_SETS 4 /* How many share values (with same ratio)*/ 72#define MULTIPLIER 10 /* Rate at which share value gets multiplied*/ 73 74extern int Tst_count; 75char *TCID = "cpu_controller_tests"; 76int TST_TOTAL = 1; 77pid_t scriptpid; 78char path[FILENAME_MAX] = "/dev/cpuctl"; 79 80extern void cleanup() 81{ 82 kill(scriptpid, SIGUSR1);/* Inform the shell to do cleanup*/ 83 tst_exit(); /* Report exit status*/ 84} 85int timer_expired = 0; 86 87int main(int argc, char *argv[]) 88{ 89 90 int num_cpus, test_num, len; /* Total time = TIME_INTERVAL*num_cpus*/ 91 char mygroup[FILENAME_MAX], mytaskfile[FILENAME_MAX]; 92 char mysharesfile[FILENAME_MAX], ch; 93 pid_t pid; 94 int my_group_num, /* A number attached with a group*/ 95 fd, /* To open a fifo for synchronization*/ 96 first_counter = 0, /* To take n number of readings*/ 97 second_counter = 0; /* no of times shares have changed*/ 98 double total_cpu_time, /* Accumulated cpu time*/ 99 delta_cpu_time, /* Time the task could run on cpu(s)*/ 100 prev_cpu_time = 0; 101 double exp_cpu_time; /* Exp time in % by shares calculation*/ 102 struct rusage cpu_usage; 103 time_t current_time, prev_time, delta_time; 104 unsigned long int myshares = 2, baseshares = 1000; 105 unsigned int fmyshares, num_tasks; 106 struct sigaction newaction, oldaction; 107 108 /* Signal handling for alarm*/ 109 sigemptyset(&newaction.sa_mask); 110 newaction.sa_handler = signal_handler_alarm; 111 newaction.sa_flags = 0; 112 sigaction(SIGALRM, &newaction, &oldaction); 113 114 /* Check if all parameters passed are correct*/ 115 if ((argc < 5) || ((my_group_num = atoi(argv[1])) <= 0) || \ 116 ((scriptpid = atoi(argv[3])) <= 0) || \ 117 ((num_cpus = atoi(argv[4])) <= 0) || \ 118 (test_num = atoi(argv[5])) <= 0) 119 tst_brkm(TBROK, cleanup, "Invalid input parameters\n"); 120 121 if (test_num == 1) 122 myshares *= my_group_num; 123 else if (test_num == 3) 124 myshares = baseshares; 125 else 126 tst_brkm(TBROK, cleanup, "Wrong Test num passed. Exiting.\n"); 127 128 sprintf(mygroup, "%s", argv[2]); 129 sprintf(mytaskfile, "%s", mygroup); 130 sprintf(mysharesfile, "%s", mygroup); 131 strcat(mytaskfile, "/tasks"); 132 strcat(mysharesfile, "/cpu.shares"); 133 pid = getpid(); 134 write_to_file(mytaskfile, "a", pid); /* Assign task to it's group*/ 135 write_to_file(mysharesfile, "w", myshares); 136 dbg("Default task's initial shares = %u", myshares); 137 138 fd = open("./myfifo", 0); 139 if (fd == -1) 140 tst_brkm(TBROK, cleanup, "Could not open fifo to synchronizae"); 141 142 read(fd, &ch, 1); /* To fire all the tasks up at the same time*/ 143 144 /* 145 * We need not calculate the expected % cpu time of this task, as 146 * neither it is required nor it can be predicted as there are idle 147 * system tasks (and others too) in this group. 148 */ 149 FLAG = 0; 150 total_shares = 0; 151 shares_pointer = &total_shares; 152 len = strlen(path); 153 if (!strncpy(fullpath, path, len)) 154 tst_brkm(TBROK, cleanup, 155 "Could not copy directory path %s ", path); 156 157 if (scan_shares_files(shares_pointer) != 0) 158 tst_brkm(TBROK, cleanup, 159 "From function scan_shares_files in %s ", fullpath); 160 161 /* return val -1 in case of function error, else 2 is min share value */ 162 if ((fmyshares = read_shares_file(mysharesfile)) < 2) 163 tst_brkm(TBROK, cleanup, 164 "in reading shares files %s ", mysharesfile); 165 166 if ((read_file(mytaskfile, GET_TASKS, &num_tasks)) < 0) 167 tst_brkm(TBROK, cleanup, 168 "in reading tasks files %s ", mytaskfile); 169 170 exp_cpu_time = (double)(fmyshares * 100) / (total_shares * num_tasks); 171 172 prev_time = time(NULL); /* Note down the time*/ 173 174 while (1) { 175 /* 176 * Need to run some cpu intensive task, which also 177 * frequently checks the timer value 178 */ 179 double f = 274.345, mytime; /*just a float number for sqrt*/ 180 alarm(TIME_INTERVAL); 181 timer_expired = 0; 182 /* 183 * Let the task run on cpu for TIME_INTERVAL. Time of this 184 * operation should not be high otherwise we can exceed the 185 * TIME_INTERVAL to measure cpu usage 186 */ 187 while (!timer_expired) 188 f = sqrt(f * f); 189 190 current_time = time(NULL); 191 /* Duration in case its not exact TIME_INTERVAL*/ 192 delta_time = current_time - prev_time; 193 194 getrusage(0, &cpu_usage); 195 /* total_cpu_time = total user time + total sys time */ 196 total_cpu_time = (cpu_usage.ru_utime.tv_sec + 197 cpu_usage.ru_utime.tv_usec * 1e-6 + 198 cpu_usage.ru_stime.tv_sec + 199 cpu_usage.ru_stime.tv_usec * 1e-6) ; 200 delta_cpu_time = total_cpu_time - prev_cpu_time; 201 202 prev_cpu_time = total_cpu_time; 203 prev_time = current_time; 204 205 /* calculate % cpu time each task gets */ 206 if (delta_time > TIME_INTERVAL) 207 mytime = (delta_cpu_time * 100) / 208 (delta_time * num_cpus); 209 else 210 mytime = (delta_cpu_time * 100) / 211 (TIME_INTERVAL * num_cpus); 212 213 /* 214 * Lets print the results. The exp cpu time calculated may not 215 * be correct due to running system tasks at the moment 216 */ 217 fprintf(stdout, "DEF TASK:CPU TIME{calc:-%6.2f(s)" 218 " i.e. %6.2f(%%) exp:-%6.2f(%%)} with %lu(shares)" 219 " in %lu (s) INTERVAL\n", delta_cpu_time, mytime, 220 exp_cpu_time, myshares, delta_time); 221 first_counter++; 222 223 /* Take n sets of readings for each shares value*/ 224 if (first_counter >= NUM_INTERVALS) { 225 first_counter = 0; 226 second_counter++; 227 if (second_counter >= NUM_SETS) 228 exit(0); /* This task is done */ 229 230 /* Keep same ratio but change values*/ 231 if (test_num == 1) { 232 myshares = MULTIPLIER * myshares; 233 write_to_file(mysharesfile, "w", myshares); 234 } 235 /* No need to change shares for def task for test 3 */ 236 237 }/* end if*/ 238 }/* end while*/ 239}/* end main*/ 240 241