memory leak: RRR not freed in subset case

Author: petschow

INCLUDE/counter.h

@@ -57,6 +57,7 @@ counter_t *PMR_create_counter(int init_value);
 int PMR_get_counter_value(counter_t *counter);
 int PMR_set_counter_value(counter_t *counter, int value);
 int PMR_decrement_counter(counter_t *counter, int amount);
+int PMR_increment_counter(counter_t *counter, int amount);
 void PMR_destroy_counter(counter_t *counter);
 
 #endif

SRC/counter.c

@@ -151,3 +151,30 @@ int PMR_decrement_counter(counter_t *counter, int amount)
 
   return(value);
 }
+
+
+
+
+int PMR_increment_counter(counter_t *counter, int amount)
+{
+  int value, info;
+
+#ifdef NOSPINLOCKS
+  info = pthread_mutex_lock(&counter->lock);
+#else
+  info = pthread_spin_lock(&counter->lock);
+#endif
+  assert(info == 0);
+
+  counter->value += amount;
+  value = counter->value;
+
+#ifdef NOSPINLOCKS
+  info = pthread_mutex_unlock(&counter->lock);
+#else
+  info = pthread_spin_unlock(&counter->lock);
+#endif
+  assert(info == 0);
+
+  return(value);
+}

SRC/process_c_task.c

@@ -697,6 +697,7 @@ int create_subtasks(cluster_t *cl, int tid, proc_t *procinfo,
   int              pid       = procinfo->pid;
   int              nproc     = procinfo->nproc;
   int              nthreads  = procinfo->nthreads;
+  bool           proc_involved=true;
 
   double *restrict Wgap      = Wstruct->Wgap;
   double *restrict Wshifted  = Wstruct->Wshifted;
@@ -707,7 +708,7 @@ int create_subtasks(cluster_t *cl, int tid, proc_t *procinfo,
   int    *restrict Zindex    = Zstruct->Zindex;
 
   /* others */
-  int    i, l;
+  int    i, l, k;
   int    max_size;
   task_t *task;
   bool   task_inserted;
@@ -754,6 +755,21 @@ int create_subtasks(cluster_t *cl, int tid, proc_t *procinfo,
       if (i==cl_end || sn_size>=max_size ||
 	    Wgap[i+1] < MIN_RELGAP*fabs(Wshifted[i+1])) {
 
+	/* Check if process involved in s-task */
+	proc_involved = false;
+	for (k=sn_first; k<=sn_last; k++) {
+	  if (iproc[k] == pid) {
+	    proc_involved = true;
+	    break;
+	  }
+	}
+	if (proc_involved == false) {
+	  task_inserted = true;
+	  new_first = i + 1;
+	  continue;
+	}
+
+	/* Insert task as process is involved */
 	if (sn_first == cl_begin) {
 	  lgap = cl->lgap;
 	} else {