X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=fuzzer.cc;h=5b5be9ff4441942fbfd22461d13b0c3788a9c7d6;hp=3a3f98831b1c64245a5ab85569667e604878b361;hb=e9468a45f910f5f2b72847aab656892a97ff41bd;hpb=5e7a1a00c4645f90d860274e2f25c33992c2ad86

diff --git a/fuzzer.cc b/fuzzer.cc
index 3a3f9883..5b5be9ff 100644
--- a/fuzzer.cc
+++ b/fuzzer.cc
@@ -2,13 +2,14 @@
 #include <stdlib.h>
 #include "threads-model.h"
 #include "model.h"
+#include "action.h"
 
-int Fuzzer::selectWrite(ModelAction *read, SnapVector<const ModelAction *> * rf_set) {
+int Fuzzer::selectWrite(ModelAction *read, SnapVector<ModelAction *> * rf_set) {
 	int random_index = random() % rf_set->size();
 	return random_index;
 }
 
-Thread * Fuzzer::selectThread(Node *n, int * threadlist, int numthreads) {
+Thread * Fuzzer::selectThread(int * threadlist, int numthreads) {
 	int random_index = random() % numthreads;
 	int thread = threadlist[random_index];
 	thread_id_t curr_tid = int_to_id(thread);
@@ -18,9 +19,22 @@ Thread * Fuzzer::selectThread(Node *n, int * threadlist, int numthreads) {
 Thread * Fuzzer::selectNotify(action_list_t * waiters) {
 	int numwaiters = waiters->size();
 	int random_index = random() % numwaiters;
-	action_list_t::iterator it = waiters->begin();
-	advance(it, random_index);
-	Thread *thread = model->get_thread(*it);
+	sllnode<ModelAction*> * it = waiters->begin();
+	while(random_index--)
+		it=it->getNext();
+	Thread *thread = model->get_thread(it->getVal());
 	waiters->erase(it);
 	return thread;
 }
+
+bool Fuzzer::shouldSleep(const ModelAction *sleep) {
+	return true;
+}
+
+bool Fuzzer::shouldWake(const ModelAction *sleep) {
+	struct timespec currtime;
+	clock_gettime(CLOCK_MONOTONIC, &currtime);
+	uint64_t lcurrtime = currtime.tv_sec * 1000000000 + currtime.tv_nsec;
+
+	return ((sleep->get_time()+sleep->get_value()) >= lcurrtime);
+}