File tree Expand file tree Collapse file tree 1 file changed +3
-8
lines changed
libsql-server/tests/embedded_replica Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Original file line number Diff line number Diff line change @@ -1292,7 +1292,7 @@ fn replicated_return() {
1292
1292
1293
1293
drop ( fut) ;
1294
1294
1295
- tokio:: fs:: File :: create ( path. join ( ".sentinel" ) )
1295
+ tokio:: fs:: File :: create ( path. join ( "dbs" ) . join ( "default" ) . join ( " .sentinel") )
1296
1296
. await
1297
1297
. unwrap ( ) ;
1298
1298
@@ -1305,15 +1305,10 @@ fn replicated_return() {
1305
1305
} ) ;
1306
1306
1307
1307
sim. client ( "client" , async move {
1308
- let client = Client :: new ( ) ;
1309
- client
1310
- . post ( "http://primary:9090/v1/namespaces/foo/create" , json ! ( { } ) )
1311
- . await ?;
1312
-
1313
1308
let path = tmp_embedded_path. join ( "embedded" ) ;
1314
1309
let db = Database :: open_with_remote_sync_connector (
1315
1310
path. to_str ( ) . unwrap ( ) ,
1316
- "http://foo. primary:8080" ,
1311
+ "http://primary:8080" ,
1317
1312
"" ,
1318
1313
TurmoilConnector ,
1319
1314
false ,
@@ -1350,7 +1345,7 @@ fn replicated_return() {
1350
1345
1351
1346
let rep = db. sync ( ) . await . unwrap ( ) ;
1352
1347
assert_eq ! ( rep. frame_no( ) , Some ( 4 ) ) ;
1353
- assert_eq ! ( rep. start_frame_no( ) , Some ( 4 ) ) ;
1348
+ assert_eq ! ( rep. start_frame_no( ) , Some ( 1 ) ) ;
1354
1349
1355
1350
Ok ( ( ) )
1356
1351
} ) ;
You can’t perform that action at this time.
0 commit comments