*/
#include <stdio.h>
#include <pthread.h>
+#include "runtime.h"
#include "CuTest.h"
#include "common.h"
-#include "nbd.h"
-#include "rcu.h"
#include "ht.h"
#include "mem.h"
hash_table_t *ht = wd->ht;
CuTest* tc = wd->tc;
uint64_t d = wd->id;
- int iters = 20000;
+ int iters = 1000000;
- nbd_thread_init(d);
SYNC_ADD(wd->wait, -1);
do { } while (*((volatile worker_data_t *)wd)->wait); // wait for all workers to be ready
wd[i].tc = tc;
wd[i].ht = ht;
wd[i].wait = &wait;
- int rc = pthread_create(thread + i, NULL, simple_worker, wd + i);
- if (rc != 0) { perror("pthread_create"); return; }
+ int rc = nbd_thread_create(thread + i, i, simple_worker, wd + i);
+ if (rc != 0) { perror("nbd_thread_create"); return; }
}
for (i = 0; i < 2; ++i) {
pthread_join(thread[i], NULL);
int main (void) {
nbd_init();
- nbd_thread_init(0);
-
//lwt_set_trace_level("h4");
// Create and run test suite