index 0beb37cb89ec4f4d5f9fb8d659c9174443627ad9..3790cebca58ca494cde55fcc38c00c51b47c45d9 100644 (file)
/*
- * Copyright (c) 2012-2013, Texas Instruments Incorporated
+ * Copyright (c) 2012-2014, Texas Instruments Incorporated
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
#define NUM_LOOPS_DFLT 1000
#define NUM_THREADS_DFLT 10
-#define MAX_NUM_THREADS 50
+#define MAX_NUM_THREADS 55
#define ONE_PROCESS_ONLY (-1)
/** ============================================================================
break;
default:
printf("Usage: %s [<numThreads>] [<numLoops>] [<Process #]>\n",
- argv[0]);
- printf("\tDefaults: numThreads: 10, numLoops: 100\n");
- printf("\tMax Threads: 100\n");
+ argv[0]);
+ printf("\tDefaults: numThreads: %d, numLoops: %d\n",
+ NUM_THREADS_DFLT, NUM_LOOPS_DFLT);
+ printf("\tMax Threads: %d\n", MAX_NUM_THREADS);
exit(0);
}
+
+ if (numThreads > MAX_NUM_THREADS) {
+ printf("Error: Maximum number of threads supported is %d\n",
+ MAX_NUM_THREADS);
+ exit(EXIT_FAILURE);
+ }
+
printf("Using numThreads: %d, numLoops: %d\n", numThreads, numLoops);
if (procNum != ONE_PROCESS_ONLY) {
printf("ProcNum: %d\n", procNum);
ret = pthread_join(threads[i].thread_id, NULL);
if (ret != 0) {
printf("MessageQMulti: failed to join thread: %d, %s\n",
- i, strerror(ret));
+ threads[i].thread_num, strerror(ret));
}
printf("MessageQMulti: Joined with thread %d\n",threads[i].thread_num);
}