+#include "my_queue.h"
+
+static int procs = 2;
+static int iterations = 1;
+static queue_t *queue;
+static thrd_t *threads;
+static int num_threads;
+
+int get_thread_num()
+{
+ thrd_t curr = thrd_current();
+ int i;
+ for (i = 0; i < num_threads; i++)
+ if (curr.priv == threads[i].priv)
+ return i;
+ assert(0);
+ return -1;
+}
+
+static void parse_args(int argc, char **argv)
+{
+ extern char *optarg;
+ int c;
+
+ while ((c = getopt(argc, argv, "i:p:")) != EOF) {
+ switch (c) {
+ case 'i':
+ iterations = atoi(optarg);
+ break;
+ case 'p':
+ procs = atoi(optarg);
+ break;
+ default:
+ assert(0);
+ }
+ }
+}