Changeset: 982967454e38 for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=982967454e38
Modified Files:
sql/backends/monet5/sql_bincopyfrom2.c
Branch: copybinary
Log Message:
Printf debugging how many imports run concurrently?
diffs (24 lines):
diff --git a/sql/backends/monet5/sql_bincopyfrom2.c
b/sql/backends/monet5/sql_bincopyfrom2.c
--- a/sql/backends/monet5/sql_bincopyfrom2.c
+++ b/sql/backends/monet5/sql_bincopyfrom2.c
@@ -458,6 +458,10 @@ finish_mapi_file_upload(backend *be, boo
static str
importColumn(backend *be, bat *ret, lng *retcnt, str method, str path, int
onclient, lng nrows)
{
+ static ATOMIC_TYPE concurrent = ATOMIC_VAR_INIT(0);
+ int current_concurrent = ATOMIC_INC(&concurrent);
+ fprintf(stderr, "IMP start, %d running\n", current_concurrent);
+
// In this function we create the BAT and open the file, and tidy
// up when things go wrong. The actual work happens in load_column().
@@ -532,6 +536,9 @@ end:
*retcnt = 0;
}
+ current_concurrent = ATOMIC_DEC(&concurrent);
+ fprintf(stderr, "IMP done, %d running\n", current_concurrent);
+
return msg;
}
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list
