diff options
| author | Emmanuel Vasilakis <mrzammler@mm.st> | 2022-09-28 20:35:01 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-28 20:35:01 +0300 |
| commit | 95cf9a870213c3561e88578c46528511ab691dbc (patch) | |
| tree | d749d51ee72c18bd6428659770a7e60b889957fa /database/sqlite/sqlite_aclk.c | |
| parent | 0190a1b556a78e50c5507bbfdbe34c63ebb56931 (diff) | |
Dont send NodeInfo during first database cleanup (#13740)
Diffstat (limited to 'database/sqlite/sqlite_aclk.c')
| -rw-r--r-- | database/sqlite/sqlite_aclk.c | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/database/sqlite/sqlite_aclk.c b/database/sqlite/sqlite_aclk.c index b913c14bcb..3e34f664cb 100644 --- a/database/sqlite/sqlite_aclk.c +++ b/database/sqlite/sqlite_aclk.c @@ -513,12 +513,16 @@ void aclk_database_worker(void *arg) // MAINTENANCE case ACLK_DATABASE_CLEANUP: debug(D_ACLK_SYNC, "Database cleanup for %s", wc->host_guid); + + if (wc->startup_time + ACLK_DATABASE_CLEANUP_FIRST + 2 < now_realtime_sec() && claimed() && aclk_connected) { + cmd.opcode = ACLK_DATABASE_NODE_INFO; + cmd.completion = NULL; + (void) aclk_database_enq_cmd_noblock(wc, &cmd); + } + sql_maint_aclk_sync_database(wc, cmd); if (wc->host == localhost) sql_check_aclk_table_list(wc); - cmd.opcode = ACLK_DATABASE_NODE_INFO; - cmd.completion = NULL; - (void) aclk_database_enq_cmd_noblock(wc, &cmd); break; case ACLK_DATABASE_DELETE_HOST: |