Re: MonetDB: default - Cleanup code upon request.
15 Nov
2012
15 Nov
'12
7:36 a.m.
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
4187
Age (days ago)
4187
Last active (days ago)
0 comments
1 participants
participants (1)
-
Fabian Groffen