X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=history.h;h=f06c2e44e46cb189c34d06f870063a75a0dcd772;hp=82a1a0109835c05f2c5f7a8971a52a3b34421620;hb=da918c450a8fb8524ed99da0a35a7e417eb85777;hpb=f6903f05c59c2f59ae9d22f177985aba6cf35e03 diff --git a/history.h b/history.h index 82a1a010..f06c2e44 100644 --- a/history.h +++ b/history.h @@ -28,7 +28,7 @@ public: FuncNode * get_curr_func_node(thread_id_t tid); void update_write_history(void * location, uint64_t write_val); - HashTable * getWriteHistory() { return write_history; } + HashTable * getWriteHistory() { return write_history; } void update_loc_rd_func_nodes_map(void * location, FuncNode * node); void update_loc_wr_func_nodes_map(void * location, FuncNode * node); SnapVector * getRdFuncNodes(void * location); @@ -42,6 +42,7 @@ public: WaitObj * getWaitObj(thread_id_t tid); void add_waiting_thread(thread_id_t self_id, thread_id_t waiting_for_id, FuncNode * target_node, int dist); void remove_waiting_thread(thread_id_t tid); + void stop_waiting_for_node(thread_id_t self_id, thread_id_t waiting_for_id, FuncNode * target_node); SnapVector * getThrdInstActMap(uint32_t func_id); @@ -63,7 +64,7 @@ private: ModelVector func_nodes; /* Map a location to a set of values that have been written to it */ - HashTable * write_history; + HashTable * write_history; /* Map a location to FuncNodes that may read from it */ HashTable *, uintptr_t, 0> * loc_rd_func_nodes_map; @@ -72,6 +73,20 @@ private: HashTable *, uintptr_t, 0> * loc_wr_func_nodes_map; HashTable *, uintptr_t, 0> * loc_waiting_writes_map; + + /* Keeps track of atomic actions that thread i has performed in some + * function. Index of SnapVector is thread id. SnapList simulates + * the call stack. + */ + SnapVector< SnapList *> * thrd_func_act_lists; + + /* thrd_func_list stores a list of function ids for each thread. + * Each element in thrd_func_list stores the functions that + * thread i has entered and yet to exit from + */ + SnapVector * thrd_func_list; + SnapVector * thrd_last_entered_func; + /* The write values each paused thread is waiting for */ SnapVector * thrd_waiting_write; SnapVector * thrd_wait_obj; @@ -82,6 +97,8 @@ private: bool skip_action(ModelAction * act, SnapList * curr_act_list); void monitor_waiting_thread(uint32_t func_id, thread_id_t tid); + void monitor_waiting_thread_counter(thread_id_t tid); + }; #endif /* __HISTORY_H__ */