database/sqlite
1
0
Fork 0
mirror of https://github.com/sqlite/sqlite.git synced 2025-08-08 14:02:16 +03:00
Code Activity

Addition summary results output when using -vvv on sqlite3_rsync.

Browse Source 
FossilOrigin-Name: c702999cfac37fdcae64d261408e58d1f49fee65434fe346db6a2a6c7f8ac54e
This commit is contained in:
drh
2025-05-03 10:49:39 +00:00
parent d7b83224bb
commit e618674714
3 changed files with 17 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
tool/sqlite3_rsync.c
View File

@@ -40,6 +40,7 @@ static const char zUsage[] =
;
typedef unsigned char u8;
typedef sqlite3_uint64 u64;
/* Context for the run */
typedef struct SQLiteRsync SQLiteRsync;
@@ -66,7 +67,8 @@ struct SQLiteRsync {
sqlite3_uint64 nIn; /* Bytes received */
unsigned int nPage; /* Total number of pages in the database */
unsigned int szPage; /* Database page size */
unsigned int nHashSent; /* Hashes sent (replica to origin) */
u64 nHashSent; /* Hashes sent (replica to origin) */
unsigned int nRound; /* Number of hash batches (replica to origin) */
unsigned int nPageSent; /* Page contents sent (origin to replica) */
};
@@ -1466,6 +1468,7 @@ static void originSide(SQLiteRsync *p){
if( p->zDebugFile ){
debugMessage(p, "<- REPLICA_READY\n");
}
p->nRound++;
pStmt = prepareStmt(p,"SELECT pgno, sz FROM badHash WHERE sz>1");
if( pStmt==0 ) break;
while( sqlite3_step(pStmt)==SQLITE_ROW ){
@@ -1603,6 +1606,7 @@ static void sendHashMessages(
runSql(p, "DELETE FROM sendHash");
writeByte(p, REPLICA_READY);
fflush(p->pOut);
p->nRound++;
if( p->zDebugFile ) debugMessage(p, "-> REPLICA_READY\n", iHash);
}
@@ -2299,6 +2303,11 @@ int main(int argc, char const * const *argv){
printf("%s\n", zMsg);
sqlite3_free(zMsg);
}
if( ctx.eVerbose>=3 ){
printf("hashes: %lld hash-rounds: %d"
" page updates: %d protocol: %d\n",
ctx.nHashSent, ctx.nRound, ctx.nPageSent, ctx.iProtocol);
}
}
sqlite3_free(zCmd);
if( pIn!=0 && pOut!=0 ){