Changeset: 671dce274790 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=671dce274790
Modified Files:
        monetdb5/mal/mal_dataflow.c
Branch: default
Log Message:

Resource management before removing the queue.


diffs (22 lines):

diff --git a/monetdb5/mal/mal_dataflow.c b/monetdb5/mal/mal_dataflow.c
--- a/monetdb5/mal/mal_dataflow.c
+++ b/monetdb5/mal/mal_dataflow.c
@@ -342,16 +342,13 @@ DFLOWworker(void *t)
                        }
                MT_lock_unset(&flow->flowlock, "MALworker");
 
+               if ( fnxt == 0 && flow->cntxt->idx > 1 )
+                               MALresourceFairness(GDKusec()- 
flow->mb->starttime);
                q_enqueue(flow->done, fe);
                if ( fnxt == 0) {
                        assert(todo);
                        if (todo->last == 0)
                                profilerHeartbeatEvent("wait");
-                       /*
-                       else
-                       if ( flow->cntxt->idx > 1 )
-                                       MALresourceFairness(GDKusec()- 
flow->mb->starttime);
-                                       */
                }
        }
        GDKfree(GDKerrbuf);
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
http://mail.monetdb.org/mailman/listinfo/checkin-list

Reply via email to