#include "threads-model.h"
#include "funcnode.h"
+#define COUNTER_THRESHOLD 1000
+
WaitObj::WaitObj(thread_id_t tid) :
tid(tid),
waiting_for(32),
WaitObj::~WaitObj()
{
- for (uint i = 0; i < thrd_dist_maps.size(); i++)
+ for (uint i = 0;i < thrd_dist_maps.size();i++)
delete thrd_dist_maps[i];
- for (uint i = 0; i < thrd_target_nodes.size(); i++)
+ for (uint i = 0;i < thrd_target_nodes.size();i++)
delete thrd_target_nodes[i];
}
if (old_size <= thread_id) {
thrd_dist_maps.resize(thread_id + 1);
- for (int i = old_size; i < thread_id + 1; i++) {
+ for (int i = old_size;i < thread_id + 1;i++) {
thrd_dist_maps[i] = new dist_map_t(16);
}
}
if (old_size <= thread_id) {
thrd_target_nodes.resize(thread_id + 1);
- for (int i = old_size; i < thread_id + 1; i++) {
+ for (int i = old_size;i < thread_id + 1;i++) {
thrd_target_nodes[i] = new node_set_t(16);
}
}
}
thrd_action_counters[thread_id]++;
- if (thrd_action_counters[thread_id] > 1000)
+ if (thrd_action_counters[thread_id] > COUNTER_THRESHOLD) {
+ thrd_action_counters[thread_id] = 0;
return true;
+ }
return false;
}
target_nodes->reset();
}
+ delete iter;
+
waiting_for.reset();
/* waited_by relation should be kept */
}
model_print("%d ", waiting_for_id);
}
model_print("\n");
+ delete it;
if (verbose) {
/* Print out the distances from each thread to target nodes */
model_print("\t");
- for (uint i = 0; i < thrd_target_nodes.size(); i++) {
+ for (uint i = 0;i < thrd_target_nodes.size();i++) {
dist_map_t * dist_map = getDistMap(i);
node_set_t * node_set = getTargetNodes(i);
node_set_iter * node_iter = node_set->iterator();
if (!node_set->isEmpty()) {
model_print("[thread %d](", int_to_id(i));
- while (node_iter->hasNext()){
+ while (node_iter->hasNext()) {
FuncNode * node = node_iter->next();
int dist = dist_map->get(node);
model_print("node %d: %d, ", node->get_func_id(), dist);
}
model_print(") ");
}
+
+ delete node_iter;
}
model_print("\n");
}
model_print("%d ", thread_id);
}
model_print("\n");
+
+ delete it;
}