X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=model.h;h=59a07597bb5bf0436752ad6a4fca2f22d9fa2fe8;hb=507434b53b00f7d32301050dd0ce8466ad42677b;hp=d2baaf45afee14661a02c620649e4efdfcf107ee;hpb=59eb730e1d19a0825008c40eb521bfc5c29df5f9;p=model-checker.git diff --git a/model.h b/model.h index d2baaf4..59a0759 100644 --- a/model.h +++ b/model.h @@ -36,11 +36,11 @@ struct model_params { int maxfuturedelay; unsigned int fairwindow; unsigned int enabledcount; + unsigned int bound; }; struct PendingFutureValue { - uint64_t value; - modelclock_t expiration; + ModelAction *writer; ModelAction * act; }; @@ -99,6 +99,7 @@ public: bool isfeasible(); bool isfeasibleotherthanRMW(); bool isfinalfeasible(); + void check_promises_thread_disabled(); void mo_check_promises(thread_id_t tid, const ModelAction *write); void check_promises(thread_id_t tid, ClockVector *old_cv, ClockVector * merge_cv); void get_release_seq_heads(ModelAction *act, rel_heads_list_t *release_heads); @@ -112,13 +113,16 @@ public: const model_params params; Scheduler * get_scheduler() { return scheduler;} + Node * get_curr_node(); MEMALLOC private: /** The scheduler to use: tracks the running/ready Threads */ Scheduler *scheduler; + bool sleep_can_read_from(ModelAction * curr, const ModelAction *write); bool thin_air_constraint_may_allow(const ModelAction * writer, const ModelAction *reader); + bool mo_may_allow(const ModelAction * writer, const ModelAction *reader); bool has_asserted() {return asserted;} void reset_asserted() {asserted=false;} int num_executions; @@ -136,11 +140,12 @@ private: */ void set_current_action(ModelAction *act) { priv->current_action = act; } Thread * check_current_action(ModelAction *curr); - ModelAction * initialize_curr_action(ModelAction *curr); + bool initialize_curr_action(ModelAction **curr); bool process_read(ModelAction *curr, bool second_part_of_rmw); bool process_write(ModelAction *curr); bool process_mutex(ModelAction *curr); bool process_thread_action(ModelAction *curr); + void process_relseq_fixup(ModelAction *curr, work_queue_t *work_queue); bool check_action_enabled(ModelAction *curr); bool take_step(); @@ -153,6 +158,7 @@ private: void reset_to_initial_state(); bool resolve_promises(ModelAction *curr); void compute_promises(ModelAction *curr); + void compute_relseq_breakwrites(ModelAction *curr); void check_curr_backtracking(ModelAction * curr); void add_action_to_lists(ModelAction *act); @@ -166,7 +172,6 @@ private: bool w_modification_order(ModelAction *curr); bool release_seq_heads(const ModelAction *rf, rel_heads_list_t *release_heads, struct release_seq *pending) const; bool resolve_release_sequences(void *location, work_queue_t *work_queue); - void do_complete_join(ModelAction *join); ModelAction *diverge; ModelAction *earliest_diverge; @@ -183,9 +188,13 @@ private: * to a trace of all actions performed on the object. */ HashTable *lock_waiters_map; + /** Per-object list of actions. Maps an object (i.e., memory location) + * to a trace of all actions performed on the object. */ + HashTable *condvar_waiters_map; + HashTable, uintptr_t, 4 > *obj_thrd_map; - std::vector *promises; - std::vector *futurevalues; + std::vector< Promise *, SnapshotAlloc > *promises; + std::vector< struct PendingFutureValue, SnapshotAlloc > *futurevalues; /** * List of pending release sequences. Release sequences might be @@ -193,15 +202,19 @@ private: * are established. Each entry in the list may only be partially * filled, depending on its pending status. */ - std::vector *pending_rel_seqs; + std::vector< struct release_seq *, SnapshotAlloc > *pending_rel_seqs; - std::vector *thrd_last_action; + std::vector< ModelAction *, SnapshotAlloc > *thrd_last_action; NodeStack *node_stack; /** Private data members that should be snapshotted. They are grouped * together for efficiency and maintainability. */ struct model_snapshot_members *priv; + /** A special model-checker Thread; used for associating with + * model-checker-related ModelAcitons */ + Thread *model_thread; + /** * @brief The modification order graph *