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