promise.cc

   1 #include "promise.h"
   2 #include "model.h"
   3 #include "schedule.h"
   4
   5 /**
   6  * Eliminate a thread which no longer can satisfy this promise. Once all
   7  * enabled threads have been eliminated, this promise is unresolvable.
   8  *
   9  * @param tid The thread ID of the thread to eliminate
  10  * @return True, if this elimination has invalidated the promise; false
  11  * otherwise
  12  */
  13 bool Promise::eliminate_thread(thread_id_t tid)
  14 {
  15         unsigned int id = id_to_int(tid);
  16         if (id >= eliminated_thread.size())
  17                 eliminated_thread.resize(id + 1, false);
  18         if (eliminated_thread[id])
  19                 return false;
  20
  21         eliminated_thread[id] = true;
  22         return has_failed();
  23 }
  24
  25 /**
  26  * Check if a thread has already been eliminated from resolving this
  27  * promise
  28  * @param tid Thread ID of the thread to check
  29  * @return True if the thread is already eliminated; false otherwise
  30  */
  31 bool Promise::thread_is_eliminated(thread_id_t tid) const
  32 {
  33         unsigned int id = id_to_int(tid);
  34         if (id >= eliminated_thread.size())
  35                 return false;
  36         return eliminated_thread[id];
  37 }
  38
  39 /**
  40  * Check if this promise has failed. A promise can fail when all threads which
  41  * could possibly satisfy the promise have been eliminated.
  42  *
  43  * @return True, if this promise has failed; false otherwise
  44  */
  45 bool Promise::has_failed() const
  46 {
  47         for (unsigned int i = 1; i < model->get_num_threads(); i++) {
  48                 thread_id_t tid = int_to_id(i);
  49                 if (!thread_is_eliminated(tid) && model->is_enabled(tid))
  50                         return false;
  51         }
  52         return true;
  53 }