-/* (C) 2006 Hewlett-Packard Development Company, L.P. */
-/* Huschaam Hussain, TSG Solution Alliances Engineering, SAP Technology Group */
-/* eMail: Huschaam.Hussain@hp.com */
-
-#include <errno.h>
+/*
+ * Copyright (C) 2006 Hewlett-Packard Development Company, L.P.
+ * Huschaam Hussain <Huschaam.Hussain@hp.com>
+ * TSG Solution Alliances Engineering
+ * SAP Technology Group
+ *
+ * Copyright (C) 2015 Karel Zak <kzak@redhat.com>
+ */
+#include <error.h>
#include <libgen.h>
#include <pthread.h>
#include <stdio.h>
#include <uuid/uuid.h>
+#include "c.h"
+#include "xalloc.h"
+#include "strutils.h"
+
#define LOG(level,args) if (logging >= level) { fprintf args; }
-char *program;
pid_t pid;
int processes = 4;
int threads = 4;
int objects = 4096;
-int logging = 0;
+int logging = 1;
int help = 0;
struct threadentry {
int objectid;
object_t *object;
-void
-error(int line, char *text)
-{
- LOG(0,
- (stderr, "%s %d: line %d: %s: errno %d: %s\n", program, pid, line,
- text, errno, strerror(errno)));
- exit(errno);
-} /* of error */
-void
-uuid_error(int line, char *text, int status)
+static void __attribute__((__noreturn__)) usage(FILE *out)
{
- LOG(0,
- (stderr, "%s %d: line %d: %s: status %d\n", program, pid, line,
- text, status));
- exit(1);
-} /* of uuid error */
+ fprintf(out, "\n %s [options]\n", program_invocation_short_name);
-void
-pthread_error(int line, char *text, int value)
-{
- LOG(0,
- (stderr, "%s %d: line %d: %s: errno %d: %s\n", program, pid, line,
- text, value, strerror(value)));
- exit(value);
-} /* of pthread error */
+ fprintf(out, " -p <num> number of of processes (default:%d)\n", processes);
+ fprintf(out, " -t <num> number of threads (default:%d)\n", threads);
+ fprintf(out, " -o <num> number of objects (default:%d)\n", objects);
+ fprintf(out, " -l <level> log level (default:%d)\n", logging);
+ fprintf(out, " -h display help\n");
-void
-read_arguments(int argc, char *argv[])
-{
- int status, i;
- unsigned long parameter;
+ exit(out == stderr ? EXIT_FAILURE : EXIT_SUCCESS);
+}
- status = 0;
- while (!status && ((i = getopt(argc, argv, "p:t:o:l:h")) != -1)) {
- switch (i) {
- case 'p':
- processes = strtol(optarg, (char **)NULL, 10);
- status = errno != 0 || processes < 1
- || processes > 1024;
- if (status)
- LOG(0,
- (stderr,
- "error: bad value for <number of processes>\n"));
- break;
- case 't':
- threads = strtol(optarg, (char **)NULL, 10);
- status = errno != 0 || threads < 1 || threads > 8192;
- if (status)
- LOG(0,
- (stderr,
- "error: bad value for <number of threads>\n"));
- break;
- case 'o':
- objects = strtol(optarg, (char **)NULL, 10);
- status = errno != 0 || objects < 1 || objects > 1048576;
- if (status)
- LOG(0,
- (stderr,
- "error: bad value for <number of objects>\n"));
- break;
- case 'l':
- logging = strtol(optarg, (char **)NULL, 10);
- if (errno != 0 || logging < 0 || logging > 3) {
- status = 1;
- fprintf(stderr,
- "error: bad value for <logging level>\n");
- } /* of if */
- break;
- case 'h':
- help = 1;
- break;
- default:
- status = 1;
- } /* of switch */
- } /* of while */
- if (optind != argc)
- status = 1;
- if (status != 0 || help != 0) {
- LOG(0, (stderr, "usage: %s [options]\n", program));
- LOG(0,
- (stderr,
- " -p <number of processes> [1-1024] default:%d\n",
- processes));
- LOG(0,
- (stderr,
- " -t <number of threads> [1-8192] default:%d\n",
- threads));
- LOG(0,
- (stderr,
- " -o <number of objects> [1-1048576] default:%d\n",
- objects));
- LOG(0,
- (stderr, " -l <logging level> [0|1|2|3] default:%d\n",
- logging));
- LOG(0, (stderr, " -h display help\n"));
- exit(status);
- } /* of if */
- LOG(1, (stderr, "%s %d: processes=%d\n", program, pid, processes));
- LOG(1, (stderr, "%s %d: threads=%d\n", program, pid, threads));
- LOG(1, (stderr, "%s %d: objects=%d\n", program, pid, objects));
- LOG(1, (stderr, "%s %d: logging=%d\n", program, pid, logging));
- LOG(1, (stderr, "%s %d: help=%d\n", program, pid, help));
-} /* of read arguments */
-
-void
-allocate_segment(int *id, void **address, size_t number, size_t size)
+static void allocate_segment(int *id, void **address, size_t number, size_t size)
{
*id = shmget(IPC_PRIVATE, number * size, IPC_CREAT | 0600);
if (*id == -1)
- error(__LINE__ - 2, "shmget()");
+ err(EXIT_FAILURE, "shmget failed");
+
*address = shmat(*id, NULL, 0);
if (*address == (void *)-1)
- error(__LINE__ - 2, "shmat()");
- LOG(2,
- (stderr,
- "%s %d: allocate shared memory segment [id=%d,address=0x%p]\n",
- program, pid, *id, *address));
-} /* of allocate segment */
+ err(EXIT_FAILURE, "shmat failed");
+
+ LOG(2, (stderr,
+ "%d: allocate shared memory segment [id=%d,address=0x%p]\n",
+ pid, *id, *address));
+}
-void
-remove_segment(int id, void *address)
+static void remove_segment(int id, void *address)
{
if (shmdt(address) == -1)
- error(__LINE__ - 1, "shmdt()");
+ err(EXIT_FAILURE, "shmdt failed");
if (shmctl(id, IPC_RMID, NULL) == -1)
- error(__LINE__ - 1, "shmctl()");
+ err(EXIT_FAILURE, "shmctl failed");
LOG(2,
(stderr,
- "%s %d: remove shared memory segment [id=%d,address=0x%p]\n",
- program, pid, id, address));
-} /* of remove segment */
+ "%d: remove shared memory segment [id=%d,address=0x%p]\n",
+ pid, id, address));
+}
-void
-object_uuid_create(object_t * object)
+static void object_uuid_create(object_t * object)
{
uuid_generate_time(object->uuid);
-} /* of object uuid create */
+}
-void
-object_uuid_to_string(object_t * object, unsigned char **string_uuid)
+static void object_uuid_to_string(object_t * object, unsigned char **string_uuid)
{
uuid_unparse(object->uuid, *string_uuid);
-} /* of object uuid to string */
+}
-int
-object_uuid_compare(const void *object1, const void *object2)
+static int object_uuid_compare(const void *object1, const void *object2)
{
uuid_t *uuid1, *uuid2;
int result;
uuid2 = &((object_t *) object2)->uuid;
result = uuid_compare(*uuid1, *uuid2);
return (result);
-} /* of object uuid compare */
+}
-void *
-create_uuids(void *p)
+static void *create_uuids(void *p)
{
long index, i;
object[i].pid = pid;
object[i].tid = pthread_self();
object[i].pos = i - index;
- } /* of for */
+ }
return (0);
-} /* of create uuids */
+}
-void
-create_threads(int index)
+static void create_threads(int index)
{
thread_t *thread;
int i, result;
+ pid_t pid = getpid();
- pid = getpid();
- thread = (thread_t *) calloc(threads, sizeof(thread_t));
- if (thread == NULL)
- error(__LINE__ - 2, "calloc");
+ thread = (thread_t *) xcalloc(threads, sizeof(thread_t));
for (i = 0; i < threads; i++) {
result = pthread_attr_init(&thread[i].thread_attr);
- if (result != 0)
- pthread_error(__LINE__, "pthread_attr_init", result);
+ if (result)
+ error(EXIT_FAILURE, result, "pthread_attr_init failed");
+
thread[i].arg = index;
- result =
- pthread_create(&thread[i].thread, &thread[i].thread_attr,
+ result = pthread_create(&thread[i].thread, &thread[i].thread_attr,
&create_uuids, &thread[i].arg);
- if (result != 0)
- pthread_error(__LINE__, "pthread_create", result);
+ if (result)
+ error(EXIT_FAILURE, result, "pthread_create failed");
+
LOG(2,
- (stderr, "%s %d: started thread [tid=%d,arg=%d]\n", program,
+ (stderr, "%d: started thread [tid=%d,arg=%d]\n",
pid, thread[i].thread, thread[i].arg));
- index = index + objects;
- } /* of for */
+ index += objects;
+ }
+
for (i = 0; i < threads; i++) {
- result =
- pthread_join(thread[i].thread, (void *)&thread[i].value);
- if (result != 0)
- pthread_error(__LINE__, "pthread_join", result);
+ result = pthread_join(thread[i].thread, (void *)&thread[i].value);
+ if (result)
+ error(EXIT_FAILURE, result, "pthread_join failed");
LOG(2,
- (stderr, "%s %d: thread exited [tid=%d,value=%d]\n",
- program, pid, thread[i].thread, thread[i].value));
- } /* of for */
+ (stderr, "%d: thread exited [tid=%d,value=%d]\n",
+ pid, thread[i].thread, thread[i].value));
+ }
free(thread);
-} /* of create threads */
+}
-void
-create_processes()
+static void create_processes()
{
process_t *process;
int i;
- process = (process_t *) calloc(processes, sizeof(process_t));
- if (process == NULL)
- error(__LINE__ - 2, "calloc");
+ process = (process_t *) xcalloc(processes, sizeof(process_t));
for (i = 0; i < processes; i++) {
process[i].pid = fork();
switch (process[i].pid) {
case -1:
- error(__LINE__ - 3, "fork()");
+ err(EXIT_FAILURE, "fork failed");
break;
case 0:
create_threads(i * threads * objects);
- exit(0);
+ exit(EXIT_SUCCESS);
break;
default:
LOG(2,
- (stderr, "%s %d: started process [pid=%d]\n",
- program, pid, process[i].pid));
+ (stderr, "%d: started process [pid=%d]\n",
+ pid, process[i].pid));
break;
- } /* of switch */
- } /* of for */
+ }
+ }
+
for (i = 0; i < processes; i++) {
if (waitpid(process[i].pid, &process[i].status, 0) ==
(pid_t) - 1)
- error(__LINE__ - 1, "waitpid()");
+ err(EXIT_FAILURE, "waitpid failed");
+
LOG(2,
- (stderr, "%s %d: process exited [pid=%d,status=%d]\n",
- program, pid, process[i].pid, process[i].status));
- } /* of for */
+ (stderr, "%d: process exited [pid=%d,status=%d]\n",
+ pid, process[i].pid, process[i].status));
+ }
free(process);
-} /* of create processes */
+}
-void
-object_dump(int i)
+static void object_dump(int i)
{
unsigned char uuid_string[37], *p;
p = uuid_string;
object_uuid_to_string(&object[i], &p);
LOG(0,
- (stderr, "%s %d: object[%d]=[uuid=<%s>,pid=%d,tid=%d,pos=%d]\n",
- program, pid, i, p, object[i].pid, object[i].tid, object[i].pos));
-} /* of object dump */
+ (stderr, "%d: object[%d]=[uuid=<%s>,pid=%d,tid=%d,pos=%d]\n",
+ pid, i, p, object[i].pid, object[i].tid, object[i].pos));
+}
-int
-main(int argc, char *argv[])
+int main(int argc, char *argv[])
{
int i, count;
+ int c;
+
+ while (((c = getopt(argc, argv, "p:t:o:l:h")) != -1)) {
+ switch (c) {
+ case 'p':
+ processes = strtou32_or_err(optarg, "invalid processes number argument");
+ break;
+ case 't':
+ threads = strtou32_or_err(optarg, "invalid threads number argument");
+ break;
+ case 'o':
+ objects = strtou32_or_err(optarg, "invalid objects number argument");
+ break;
+ case 'l':
+ logging = strtou32_or_err(optarg, "invalid log level argument");
+ break;
+ case 'h':
+ usage(stdout);
+ break;
+ default:
+ usage(stderr);
+ break;
+ }
+ }
+
+ if (optind != argc)
+ usage(stderr);
+
+ if (logging == 1)
+ fprintf(stderr, "requested: %d processes, %d threads, %d objects\n",
+ processes, threads, objects);
+
- errno = 0;
- program = strdup(basename(argv[0]));
- pid = getpid();
- read_arguments(argc, argv);
allocate_segment(&objectid, (void **)&object,
processes * threads * objects, sizeof(object_t));
create_processes();
if (logging >= 3) {
for (i = 0; i < processes * threads * objects; i++) {
object_dump(i);
- } /* of for */
- } /* of if */
+ }
+ }
qsort(object, processes * threads * objects, sizeof(object_t),
object_uuid_compare);
- LOG(2, (stdout, "%s %d: qsort() done\n", program, pid));
+ LOG(2, (stdout, "%d: qsort() done\n", pid));
count = 0;
for (i = 0; i < processes * threads * objects - 1; i++) {
if (object_uuid_compare(&object[i], &object[i + 1]) == 0) {
if (logging >= 1) {
LOG(0,
(stdout,
- "%s %d: objects #%d and #%d have duplicate UUIDs\n",
- program, pid, i, i + 1));
+ "%d: objects #%d and #%d have duplicate UUIDs\n",
+ pid, i, i + 1));
object_dump(i);
object_dump(i + 1);
- } /* of if */
+ }
count = count + 1;
- } /* of if */
- } /* of for */
+ }
+ }
remove_segment(objectid, object);
if (count == 0) {
LOG(0,
(stdout, "test successful (no duplicate UUIDs found)\n"));
- } /* of if */
+ }
else {
LOG(0,
(stdout, "test failed (found %d duplicate UUIDs)\n",
count));
- } /* of else */
-} /* of main */
+ }
+}
projects / thirdparty / util-linux.git / commitdiff
