mirror of
https://github.com/aljazceru/turso.git
synced 2026-02-23 08:55:40 +01:00
fix compilation
This commit is contained in:
@@ -187,7 +187,7 @@ impl SyncServer for TestSyncServer {
|
||||
let frame = &frames[offset..offset + FRAME_SIZE];
|
||||
match session.conn.wal_insert_frame(frame_no as u32, frame) {
|
||||
Ok(info) => {
|
||||
if info.is_commit {
|
||||
if info.is_commit_frame() {
|
||||
if session.in_txn {
|
||||
session.conn.wal_insert_end()?;
|
||||
session.in_txn = false;
|
||||
|
||||
@@ -17,8 +17,8 @@ path = "integration/mod.rs"
|
||||
[dependencies]
|
||||
anyhow.workspace = true
|
||||
env_logger = "0.10.1"
|
||||
turso_core = { path = "../core" }
|
||||
turso = { path = "../bindings/rust" }
|
||||
turso_core = { path = "../core", features = ["conn_raw_api"] }
|
||||
turso = { path = "../bindings/rust", features = ["conn_raw_api"] }
|
||||
tokio = { version = "1.47", features = ["full"] }
|
||||
rusqlite = { version = "0.34", features = ["bundled"] }
|
||||
tempfile = "3.0.7"
|
||||
|
||||
@@ -140,7 +140,7 @@ fn test_wal_frame_transfer_schema_changes() {
|
||||
for frame_id in 1..=conn1.wal_frame_count().unwrap() as u32 {
|
||||
conn1.wal_get_frame(frame_id, &mut frame).unwrap();
|
||||
let info = conn2.wal_insert_frame(frame_id, &frame).unwrap();
|
||||
if info.is_commit {
|
||||
if info.is_commit_frame() {
|
||||
commits += 1;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user