Skip to content

Commit dc12e79

Browse files
committed
Related to issue 676
- remove sync and use refresh_offer_maxsize_cache
1 parent a709efa commit dc12e79

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

src/maker/server.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -383,8 +383,10 @@ fn check_swap_liquidity(maker: &Maker) -> Result<(), MakerError> {
383383
.write()?
384384
.get_next_external_address(AddressType::P2WPKH)?;
385385
while !maker.shutdown.load(Relaxed) {
386-
log::info!("Sync at:----check_swap_liquidity----");
387-
maker.get_wallet().write()?.sync_and_save()?;
386+
log::info!("----check_swap_liquidity----");
387+
let mut maker_write = maker.get_wallet().write()?;
388+
maker_write.refresh_offer_maxsize_cache()?;
389+
maker_write.save_to_disk()?;
388390
let offer_max_size = maker.get_wallet().read()?.store.offer_maxsize;
389391

390392
let min_required = maker.config.min_swap_amount;

src/maker/server2.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -411,6 +411,7 @@ fn check_swap_liquidity_taproot(maker: &Maker) -> Result<(), MakerError> {
411411
let balances = wallet_read.get_balances()?;
412412

413413
let swap_balance = balances.spendable;
414+
let offer_max_size = wallet_read.store.offer_maxsize;
414415
let ongoing_swaps_count = maker.ongoing_swap_state.lock()?.len();
415416

416417
if swap_balance == Amount::ZERO {
@@ -422,7 +423,7 @@ fn check_swap_liquidity_taproot(maker: &Maker) -> Result<(), MakerError> {
422423
log::info!(
423424
"[{}] Taproot swap liquidity: {} sats, {} ongoing swaps",
424425
maker.config.network_port,
425-
swap_balance.to_sat(),
426+
offer_max_size,
426427
ongoing_swaps_count
427428
);
428429
}

0 commit comments

Comments
 (0)