Re: MonetDB: default - Cleanup code upon request.

On 15-11-2012 08:31:51 +0100, Martin Kersten wrote:

+/* There is just a single queue for the workers */ static void MRqueueCreate(int sz) { @@ -54,14 +55,21 @@ MRqueueCreate(int sz) MT_lock_init(&mrqlock, "q_create"); MT_lock_set(&mrqlock, "q_create"); MT_sema_init(&mrqsema, 0, "q_create");

• sz = ((sz << 1) >> 1); /* we want a multiple of 2 */

• if ( mrqueue ) {

• GDKerror("One map-reduce queue allowed");
  

• return;
  

• }
• sz *= 2; mrqueue = (MRqueue *) GDKzalloc(sizeof(MRqueue) * sz);

• assert(mrqueue);

• if ( mrqueue == 0) {

• GDKerror("Could not create the map-reduce queue");
  

• return;
  

shouldn't you unset the mrqlock here?

• }

_______________________________________________ developers-list mailing list developers-list@monetdb.org http://mail.monetdb.org/mailman/listinfo/developers-list