123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472 |
- #include "libbb.h"
- #include <sys/resource.h> /* getrusage */
- typedef struct {
- int waitstatus;
- struct rusage ru;
- unsigned elapsed_ms;
- } resource_t;
- #define UL unsigned long
- static const char default_format[] ALIGN1 = "real\t%E\nuser\t%u\nsys\t%T";
- static const char posix_format[] ALIGN1 = "real %e\nuser %U\nsys %S";
- static const char long_format[] ALIGN1 =
- "\tCommand being timed: \"%C\"\n"
- "\tUser time (seconds): %U\n"
- "\tSystem time (seconds): %S\n"
- "\tPercent of CPU this job got: %P\n"
- "\tElapsed (wall clock) time (h:mm:ss or m:ss): %E\n"
- "\tAverage shared text size (kbytes): %X\n"
- "\tAverage unshared data size (kbytes): %D\n"
- "\tAverage stack size (kbytes): %p\n"
- "\tAverage total size (kbytes): %K\n"
- "\tMaximum resident set size (kbytes): %M\n"
- "\tAverage resident set size (kbytes): %t\n"
- "\tMajor (requiring I/O) page faults: %F\n"
- "\tMinor (reclaiming a frame) page faults: %R\n"
- "\tVoluntary context switches: %w\n"
- "\tInvoluntary context switches: %c\n"
- "\tSwaps: %W\n"
- "\tFile system inputs: %I\n"
- "\tFile system outputs: %O\n"
- "\tSocket messages sent: %s\n"
- "\tSocket messages received: %r\n"
- "\tSignals delivered: %k\n"
- "\tPage size (bytes): %Z\n"
- "\tExit status: %x";
- static void resuse_end(pid_t pid, resource_t *resp)
- {
- pid_t caught;
-
- while ((caught = wait3(&resp->waitstatus, 0, &resp->ru)) != pid) {
- if (caught == -1 && errno != EINTR) {
- bb_perror_msg("wait");
- return;
- }
- }
- resp->elapsed_ms = monotonic_ms() - resp->elapsed_ms;
- }
- static void printargv(char *const *argv)
- {
- const char *fmt = " %s" + 1;
- do {
- printf(fmt, *argv);
- fmt = " %s";
- } while (*++argv);
- }
- static unsigned long ptok(const unsigned pagesize, const unsigned long pages)
- {
- unsigned long tmp;
-
- if (pages > (LONG_MAX / pagesize)) {
- tmp = pages / 1024;
- return tmp * pagesize;
- }
-
- tmp = pages * pagesize;
- return tmp / 1024;
- }
- #ifndef TICKS_PER_SEC
- #define TICKS_PER_SEC 100
- #endif
- static void summarize(const char *fmt, char **command, resource_t *resp)
- {
- unsigned vv_ms;
- unsigned cpu_ticks;
- unsigned pagesize = getpagesize();
-
- if (WIFSIGNALED(resp->waitstatus))
- printf("Command terminated by signal %u\n",
- WTERMSIG(resp->waitstatus));
- else if (WIFEXITED(resp->waitstatus) && WEXITSTATUS(resp->waitstatus))
- printf("Command exited with non-zero status %u\n",
- WEXITSTATUS(resp->waitstatus));
- vv_ms = (resp->ru.ru_utime.tv_sec + resp->ru.ru_stime.tv_sec) * 1000
- + (resp->ru.ru_utime.tv_usec + resp->ru.ru_stime.tv_usec) / 1000;
- #if (1000 / TICKS_PER_SEC) * TICKS_PER_SEC == 1000
-
- cpu_ticks = vv_ms / (1000 / TICKS_PER_SEC);
- #else
- cpu_ticks = vv_ms * (unsigned long long)TICKS_PER_SEC / 1000;
- #endif
- if (!cpu_ticks) cpu_ticks = 1;
- while (*fmt) {
-
- int n = strcspn(fmt, "%\\");
- if (n) {
- printf("%.*s", n, fmt);
- fmt += n;
- continue;
- }
- switch (*fmt) {
- #ifdef NOT_NEEDED
-
-
- default:
- bb_putchar(*fmt);
- break;
- #endif
- case '%':
- switch (*++fmt) {
- #ifdef NOT_NEEDED_YET
-
-
- default:
- bb_putchar('%');
-
- case '%':
- if (!*fmt) goto ret;
- bb_putchar(*fmt);
- break;
- #endif
- case 'C':
- printargv(command);
- break;
- case 'D':
- printf("%lu",
- (ptok(pagesize, (UL) resp->ru.ru_idrss) +
- ptok(pagesize, (UL) resp->ru.ru_isrss)) / cpu_ticks);
- break;
- case 'E': {
- unsigned seconds = resp->elapsed_ms / 1000;
- if (seconds >= 3600)
- printf("%uh %um %02us",
- seconds / 3600,
- (seconds % 3600) / 60,
- seconds % 60);
- else
- printf("%um %u.%02us",
- seconds / 60,
- seconds % 60,
- (unsigned)(resp->elapsed_ms / 10) % 100);
- break;
- }
- case 'F':
- printf("%lu", resp->ru.ru_majflt);
- break;
- case 'I':
- printf("%lu", resp->ru.ru_inblock);
- break;
- case 'K':
- printf("%lu",
- (ptok(pagesize, (UL) resp->ru.ru_idrss) +
- ptok(pagesize, (UL) resp->ru.ru_isrss) +
- ptok(pagesize, (UL) resp->ru.ru_ixrss)) / cpu_ticks);
- break;
- case 'M':
- printf("%lu", ptok(pagesize, (UL) resp->ru.ru_maxrss));
- break;
- case 'O':
- printf("%lu", resp->ru.ru_oublock);
- break;
- case 'P':
-
- if (resp->elapsed_ms > 0)
- printf("%u%%", (unsigned)(vv_ms * 100 / resp->elapsed_ms));
- else
- printf("?%%");
- break;
- case 'R':
- printf("%lu", resp->ru.ru_minflt);
- break;
- case 'S':
- printf("%u.%02u",
- (unsigned)resp->ru.ru_stime.tv_sec,
- (unsigned)(resp->ru.ru_stime.tv_usec / 10000));
- break;
- case 'T':
- if (resp->ru.ru_stime.tv_sec >= 3600)
- printf("%uh %um %02us",
- (unsigned)(resp->ru.ru_stime.tv_sec / 3600),
- (unsigned)(resp->ru.ru_stime.tv_sec % 3600) / 60,
- (unsigned)(resp->ru.ru_stime.tv_sec % 60));
- else
- printf("%um %u.%02us",
- (unsigned)(resp->ru.ru_stime.tv_sec / 60),
- (unsigned)(resp->ru.ru_stime.tv_sec % 60),
- (unsigned)(resp->ru.ru_stime.tv_usec / 10000));
- break;
- case 'U':
- printf("%u.%02u",
- (unsigned)resp->ru.ru_utime.tv_sec,
- (unsigned)(resp->ru.ru_utime.tv_usec / 10000));
- break;
- case 'u':
- if (resp->ru.ru_utime.tv_sec >= 3600)
- printf("%uh %um %02us",
- (unsigned)(resp->ru.ru_utime.tv_sec / 3600),
- (unsigned)(resp->ru.ru_utime.tv_sec % 3600) / 60,
- (unsigned)(resp->ru.ru_utime.tv_sec % 60));
- else
- printf("%um %u.%02us",
- (unsigned)(resp->ru.ru_utime.tv_sec / 60),
- (unsigned)(resp->ru.ru_utime.tv_sec % 60),
- (unsigned)(resp->ru.ru_utime.tv_usec / 10000));
- break;
- case 'W':
- printf("%lu", resp->ru.ru_nswap);
- break;
- case 'X':
- printf("%lu", ptok(pagesize, (UL) resp->ru.ru_ixrss) / cpu_ticks);
- break;
- case 'Z':
- printf("%u", pagesize);
- break;
- case 'c':
- printf("%lu", resp->ru.ru_nivcsw);
- break;
- case 'e':
- printf("%u.%02u",
- (unsigned)resp->elapsed_ms / 1000,
- (unsigned)(resp->elapsed_ms / 10) % 100);
- break;
- case 'k':
- printf("%lu", resp->ru.ru_nsignals);
- break;
- case 'p':
- printf("%lu", ptok(pagesize, (UL) resp->ru.ru_isrss) / cpu_ticks);
- break;
- case 'r':
- printf("%lu", resp->ru.ru_msgrcv);
- break;
- case 's':
- printf("%lu", resp->ru.ru_msgsnd);
- break;
- case 't':
- printf("%lu", ptok(pagesize, (UL) resp->ru.ru_idrss) / cpu_ticks);
- break;
- case 'w':
- printf("%lu", resp->ru.ru_nvcsw);
- break;
- case 'x':
- printf("%u", WEXITSTATUS(resp->waitstatus));
- break;
- }
- break;
- #ifdef NOT_NEEDED_YET
- case '\\':
- switch (*++fmt) {
- default:
- bb_putchar('\\');
-
- case '\\':
- if (!*fmt) goto ret;
- bb_putchar(*fmt);
- break;
- case 't':
- bb_putchar('\t');
- break;
- case 'n':
- bb_putchar('\n');
- break;
- }
- break;
- #endif
- }
- ++fmt;
- }
-
- bb_putchar('\n');
- }
- static void run_command(char *const *cmd, resource_t *resp)
- {
- pid_t pid;
- void (*interrupt_signal)(int);
- void (*quit_signal)(int);
- resp->elapsed_ms = monotonic_ms();
- pid = xvfork();
- if (pid == 0) {
-
- BB_EXECVP_or_die((char**)cmd);
- }
-
- interrupt_signal = signal(SIGINT, SIG_IGN);
- quit_signal = signal(SIGQUIT, SIG_IGN);
- resuse_end(pid, resp);
-
- signal(SIGINT, interrupt_signal);
- signal(SIGQUIT, quit_signal);
- }
- int time_main(int argc, char **argv) MAIN_EXTERNALLY_VISIBLE;
- int time_main(int argc UNUSED_PARAM, char **argv)
- {
- resource_t res;
-
- const char *output_format = getenv("TIME") ? : default_format;
- char *output_filename;
- int output_fd;
- int opt;
- int ex;
- enum {
- OPT_v = (1 << 0),
- OPT_p = (1 << 1),
- OPT_a = (1 << 2),
- OPT_o = (1 << 3),
- OPT_f = (1 << 4),
- };
-
- opt = getopt32(argv, "^+" "vpao:f:" "\0" "-1",
- &output_filename, &output_format
- );
- argv += optind;
- if (opt & OPT_v)
- output_format = long_format;
- if (opt & OPT_p)
- output_format = posix_format;
- output_fd = STDERR_FILENO;
- if (opt & OPT_o) {
- #ifndef O_CLOEXEC
- # define O_CLOEXEC 0
- #endif
- output_fd = xopen(output_filename,
- (opt & OPT_a)
- ? (O_CREAT | O_WRONLY | O_CLOEXEC | O_APPEND)
- : (O_CREAT | O_WRONLY | O_CLOEXEC | O_TRUNC)
- );
- if (!O_CLOEXEC)
- close_on_exec_on(output_fd);
- }
- run_command(argv, &res);
-
- xdup2(output_fd, STDOUT_FILENO);
- summarize(output_format, argv, &res);
- ex = WEXITSTATUS(res.waitstatus);
-
- if (WIFSIGNALED(res.waitstatus))
- ex = WTERMSIG(res.waitstatus);
- fflush_stdout_and_exit(ex);
- }
|