aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/sdp/output
diff options
context:
space:
mode:
authorRalph Amissah <ralph@amissah.com>2018-08-06 01:14:10 -0400
committerRalph Amissah <ralph@amissah.com>2019-04-10 15:14:15 -0400
commit8671dcef8815777bf3fb7d433f57a53dca162a14 (patch)
tree298bc2a5280a8f0ae286564a44da947dc757494e /src/sdp/output
parentnested parallelisation, output task scheduler (diff)
0.27.1 sqlite shared db actions cannot be parallelised
- regressive fix required
Diffstat (limited to 'src/sdp/output')
-rw-r--r--src/sdp/output/hub.d4
-rw-r--r--src/sdp/output/sqlite.d2
2 files changed, 2 insertions, 4 deletions
diff --git a/src/sdp/output/hub.d b/src/sdp/output/hub.d
index 832cda8..a95c348 100644
--- a/src/sdp/output/hub.d
+++ b/src/sdp/output/hub.d
@@ -61,9 +61,7 @@ template outputHub() {
Scheduled!()(schedule, doc_abstraction, doc_matters);
}
}
- if (doc_matters.opt.action.sqlite_insert
- || doc_matters.opt.action.sqlite_update
- ) {
+ if (doc_matters.opt.action.sqlite_update) {
msg.v("sqlite update processing...");
SQLiteHubBuildTablesAndPopulate!()(doc_abstraction, doc_matters);
msg.vv("sqlite update done");
diff --git a/src/sdp/output/sqlite.d b/src/sdp/output/sqlite.d
index 0221264..82484e5 100644
--- a/src/sdp/output/sqlite.d
+++ b/src/sdp/output/sqlite.d
@@ -35,7 +35,7 @@ template SQLiteHubBuildTablesAndPopulate() {
_db_statement ~= SQLiteDeleteDocument!()(doc_matters);
SQLiteDbRun!()(db, _db_statement, doc_matters.opt.action, "DELETE Document");
}
- if (doc_matters.opt.action.sqlite_insert || doc_matters.opt.action.sqlite_update) { // sqlite_update is .opt.action sqlite_delete & sqlite_insert (set in sdp)
+ if (doc_matters.opt.action.sqlite_update) { // sqlite_update is .opt.action sqlite_delete & sqlite_insert (set in sdp)
_db_statement ~= SQLiteDeleteDocument!()(doc_matters);
SQLiteDbRun!()(db, _db_statement, doc_matters.opt.action, "DELETE Document");
_db_statement ~= SQLiteInsertMetadata!()(doc_matters);