Skip to content

Commit b62e178

Browse files
committed
fix(network): fix the value of the seq variable in cloudsync_payload_get when the last db_version is not related to a local change
1 parent 1670e47 commit b62e178

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

src/cloudsync.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2446,8 +2446,8 @@ int cloudsync_payload_get (cloudsync_context *data, char **blob, int *blob_size,
24462446

24472447
// retrieve BLOB
24482448
char sql[1024];
2449-
snprintf(sql, sizeof(sql), "WITH max_db_version AS (SELECT MAX(db_version) AS max_db_version FROM cloudsync_changes) "
2450-
"SELECT * FROM (SELECT cloudsync_payload_encode(tbl, pk, col_name, col_value, col_version, db_version, site_id, cl, seq) AS payload, max_db_version AS max_db_version, MAX(IIF(db_version = max_db_version, seq, NULL)) FROM cloudsync_changes, max_db_version WHERE site_id=cloudsync_siteid() AND (db_version>%d OR (db_version=%d AND seq>%d))) WHERE payload IS NOT NULL", *db_version, *db_version, *seq);
2449+
snprintf(sql, sizeof(sql), "WITH max_db_version AS (SELECT MAX(db_version) AS max_db_version FROM cloudsync_changes WHERE site_id=cloudsync_siteid()) "
2450+
"SELECT * FROM (SELECT cloudsync_payload_encode(tbl, pk, col_name, col_value, col_version, db_version, site_id, cl, seq) AS payload, max_db_version AS max_db_version, MAX(IIF(db_version = max_db_version, seq, 0)) FROM cloudsync_changes, max_db_version WHERE site_id=cloudsync_siteid() AND (db_version>%d OR (db_version=%d AND seq>%d))) WHERE payload IS NOT NULL", *db_version, *db_version, *seq);
24512451

24522452
int64_t len = 0;
24532453
int rc = database_select_blob_2int(data, sql, blob, &len, new_db_version, new_seq);

0 commit comments

Comments
 (0)