MonetDB: default - Destroy semaphores after use.

[Sjoerd Mullender]

Changeset: f947be44b1b7 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=f947be44b1b7
Modified Files:
        gdk/gdk_mapreduce.c
        monetdb5/mal/mal_client.c
        monetdb5/modules/mal/tablet.c
Branch: default
Log Message:

Destroy semaphores after use.


diffs (41 lines):

diff --git a/gdk/gdk_mapreduce.c b/gdk/gdk_mapreduce.c
--- a/gdk/gdk_mapreduce.c
+++ b/gdk/gdk_mapreduce.c
@@ -156,4 +156,5 @@ MRschedule(int taskcnt, void **arg, void
        /* waiting for all report result */
        for (i = 0; i < taskcnt; i++)
                MT_sema_down(&sema, "MRschedule");
+       MT_sema_destroy(&sema);
 }
diff --git a/monetdb5/mal/mal_client.c b/monetdb5/mal/mal_client.c
--- a/monetdb5/mal/mal_client.c
+++ b/monetdb5/mal/mal_client.c
@@ -381,6 +381,7 @@ freeClient(Client c)
        c->glb = NULL;
        if (t)
                THRdel(t);  /* you may perform suicide */
+       MT_sema_destroy(&c->s);
 }
 
 /*
diff --git a/monetdb5/modules/mal/tablet.c b/monetdb5/modules/mal/tablet.c
--- a/monetdb5/modules/mal/tablet.c
+++ b/monetdb5/modules/mal/tablet.c
@@ -1687,6 +1687,8 @@ SQLload_file(Client cntxt, Tablet *as, b
        for (j = 0; j < threads; j++) {
                MT_join_thread(ptask[j].tid);
                GDKfree(ptask[j].cols);
+               MT_sema_destroy(&ptask[j].sema);
+               MT_sema_destroy(&ptask[j].reply);
        }
        MT_join_thread(task->tid);
 
@@ -1699,6 +1701,8 @@ SQLload_file(Client cntxt, Tablet *as, b
        GDKfree(task->cols);
        GDKfree(task->time);
        GDKfree(task->base);
+       MT_sema_destroy(&task->consumer);
+       MT_sema_destroy(&task->producer);
        GDKfree(task);
 #ifdef MLOCK_TST
        munlockall();
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
http://mail.monetdb.org/mailman/listinfo/checkin-list