diff options
| author | Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com> | 2022-07-18 19:38:47 +0300 |
|---|---|---|
| committer | Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com> | 2022-07-18 19:38:47 +0300 |
| commit | d3ebf28706b3f1b4c35101a8b698407030ea88de (patch) | |
| tree | 18f22bf2326c595fa1be8ed68b4cd645597b6808 | |
| parent | 13d89943eeac5ae497dbf3ed4560b7af227e101b (diff) | |
Mark entries for charts and dimensions as submitted to the cloud 3600 seconds after their creation
Mark entries for charts and dimensions as updated (confirmed by the cloud) 1800 seconds after their submission
| -rw-r--r-- | database/sqlite/sqlite_aclk.c | 11 | ||||
| -rw-r--r-- | database/sqlite/sqlite_aclk.h | 2 |
2 files changed, 13 insertions, 0 deletions
diff --git a/database/sqlite/sqlite_aclk.c b/database/sqlite/sqlite_aclk.c index 4f415e9dbc..588d5ab384 100644 --- a/database/sqlite/sqlite_aclk.c +++ b/database/sqlite/sqlite_aclk.c @@ -803,6 +803,17 @@ void sql_maint_aclk_sync_database(struct aclk_database_worker_config *wc, struct buffer_sprintf(sql,"DELETE FROM aclk_alert_%s WHERE date_submitted IS NOT NULL AND " "date_cloud_ack < unixepoch()-%d;", wc->uuid_str, ACLK_DELETE_ACK_ALERTS_INTERNAL); db_execute(buffer_tostring(sql)); + buffer_flush(sql); + + buffer_sprintf(sql,"UPDATE aclk_chart_%s SET status = NULL, date_submitted=unixepoch() WHERE " + "date_submitted IS NULL AND date_created < unixepoch()-%d;", wc->uuid_str, ACLK_AUTO_MARK_SUBMIT_INTERVAL); + db_execute(buffer_tostring(sql)); + buffer_flush(sql); + + buffer_sprintf(sql,"UPDATE aclk_chart_%s SET date_updated = unixepoch() WHERE date_updated IS NULL" + " AND date_submitted IS NOT NULL AND date_submitted < unixepoch()-%d;", + wc->uuid_str, ACLK_AUTO_MARK_UPDATED_INTERVAL); + db_execute(buffer_tostring(sql)); buffer_free(sql); return; diff --git a/database/sqlite/sqlite_aclk.h b/database/sqlite/sqlite_aclk.h index e80d896542..b73f422e16 100644 --- a/database/sqlite/sqlite_aclk.h +++ b/database/sqlite/sqlite_aclk.h @@ -22,6 +22,8 @@ #define ACLK_DATABASE_ROTATION_INTERVAL (3600) #define ACLK_DELETE_ACK_INTERNAL (600) #define ACLK_DELETE_ACK_ALERTS_INTERNAL (86400) +#define ACLK_AUTO_MARK_SUBMIT_INTERVAL (3600) +#define ACLK_AUTO_MARK_UPDATED_INTERVAL (1800) #define ACLK_SYNC_QUERY_SIZE 512 struct aclk_completion { |