Changeset: 78f3c5695c10 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=78f3c5695c10
Modified Files:
monetdb5/modules/mal/tablet_sql.c
Branch: default
Log Message:
Some parallel IO initiations.
At the end of the COPY into phase, all BATs should be saved.
This can be initiated by the worker threads in parallel.
diffs (19 lines):
diff --git a/monetdb5/modules/mal/tablet_sql.c
b/monetdb5/modules/mal/tablet_sql.c
--- a/monetdb5/modules/mal/tablet_sql.c
+++ b/monetdb5/modules/mal/tablet_sql.c
@@ -342,10 +342,14 @@ SQLworker(void *arg)
MT_sema_down(&task->sema, "SQLworker");
if (task->next < 0) {
+ MT_sema_up(&task->reply, "SQLworker");
+ /* stage three, save all BATs to disk before quiting */
+ for (i = 0; i < task->as->nr_attrs; i++)
+ if ( task->fields[0][i] && task->cols[i]>0)
+ BATsave(task->as->format[task->cols[i]-1].c[0]);
#ifdef _DEBUG_TABLET_
mnstr_printf(GDKout, "SQLworker terminated\n");
#endif
- MT_sema_up(&task->reply, "SQLworker");
return;
}
_______________________________________________
Checkin-list mailing list
[email protected]
http://mail.monetdb.org/mailman/listinfo/checkin-list
