diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2022-11-28 12:22:38 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-28 12:22:38 +0200 |
| commit | 53a13ab8e110923d097968353a6bc1e22399480f (patch) | |
| tree | a22fe110436844fcc0331073d37182adefbf0edc /database/sqlite/sqlite_functions.c | |
| parent | 1e9f2c7a2a866be27203c528067adecd283e0ceb (diff) | |
replication fixes No 7 (#14053)
* move global statistics workers to a separate thread; query statistics per query source; query statistics for ML, exporters, backfilling; reset replication point in time every 10 seconds, instead of every 1; fix compilation warnings; optimize the replication queries code; prevent long tail of replication requests (big sleeps); provide query statistics about replication ; optimize replication sender when most senders are full; optimize replication_request_get_first_available(); reset replication completion calculation;
* remove workers utilization from global statistics thread
Diffstat (limited to 'database/sqlite/sqlite_functions.c')
| -rw-r--r-- | database/sqlite/sqlite_functions.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/database/sqlite/sqlite_functions.c b/database/sqlite/sqlite_functions.c index 1f8d1c1d13..eeb3c38229 100644 --- a/database/sqlite/sqlite_functions.c +++ b/database/sqlite/sqlite_functions.c @@ -71,7 +71,7 @@ SQLITE_API int sqlite3_exec_monitored( char **errmsg /* Error msg written here */ ) { int rc = sqlite3_exec(db, sql, callback, data, errmsg); - sqlite3_query_completed(rc == SQLITE_OK, rc == SQLITE_BUSY, rc == SQLITE_LOCKED); + global_statistics_sqlite3_query_completed(rc == SQLITE_OK, rc == SQLITE_BUSY, rc == SQLITE_LOCKED); return rc; } @@ -83,14 +83,14 @@ SQLITE_API int sqlite3_step_monitored(sqlite3_stmt *stmt) { rc = sqlite3_step(stmt); switch (rc) { case SQLITE_DONE: - sqlite3_query_completed(1, 0, 0); + global_statistics_sqlite3_query_completed(1, 0, 0); break; case SQLITE_ROW: - sqlite3_row_completed(); + global_statistics_sqlite3_row_completed(); break; case SQLITE_BUSY: case SQLITE_LOCKED: - sqlite3_query_completed(rc == SQLITE_DONE, rc == SQLITE_BUSY, rc == SQLITE_LOCKED); + global_statistics_sqlite3_query_completed(rc == SQLITE_DONE, rc == SQLITE_BUSY, rc == SQLITE_LOCKED); usleep(SQLITE_INSERT_DELAY * USEC_PER_MS); continue; default: |