Git-Mirrors/mollyim-monero-wallet-sdk
1
0
Fork 0
mirror of https://github.com/mollyim/monero-wallet-sdk.git synced 2025-01-13 08:29:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

lib: debounce blockchain height updates

Browse Source
This commit is contained in:
Oscar Mira 2023-02-24 21:33:48 +01:00
parent 90909a9816
commit 47efd85fd6
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
lib/android/src/main/cpp/wallet.cc
View File

@ -1,6 +1,7 @@
#include "wallet.h" #include "wallet.h"
#include <cstring> #include <cstring>
#include <chrono>
#include <boost/iostreams/device/file_descriptor.hpp> #include <boost/iostreams/device/file_descriptor.hpp>
#include <boost/iostreams/stream.hpp> #include <boost/iostreams/stream.hpp>
@ -14,6 +15,8 @@ namespace io = boost::iostreams;
namespace monero { namespace monero {
using namespace std::chrono_literals;
static_assert(COIN == 1e12, "Monero atomic unit must be 1e-12 XMR"); static_assert(COIN == 1e12, "Monero atomic unit must be 1e-12 XMR");
static_assert(CRYPTONOTE_MAX_BLOCK_NUMBER == 500000000, static_assert(CRYPTONOTE_MAX_BLOCK_NUMBER == 500000000,
"Min timestamp must be higher than max block height"); "Min timestamp must be higher than max block height");
@ -133,8 +136,13 @@ void Wallet::handleBalanceChanged(uint64_t at_block_height) {
void Wallet::handleNewBlock(uint64_t height) { void Wallet::handleNewBlock(uint64_t height) {
m_blockchain_height = height; m_blockchain_height = height;
JNIEnv* env = getJniEnv(); // Notify blockchain height every one second.
m_callback.callVoidMethod(env, Wallet_onRefresh, height, false); static std::chrono::steady_clock::time_point last_time;
auto now = std::chrono::steady_clock::now();
if (now - last_time >= 1.s) {
last_time = now;
m_callback.callVoidMethod(getJniEnv(), Wallet_onRefresh, height, false);
}
} }
Wallet::Status Wallet::refreshLoopUntilSynced(bool skip_coinbase) { Wallet::Status Wallet::refreshLoopUntilSynced(bool skip_coinbase) {
@ -162,6 +170,8 @@ Wallet::Status Wallet::refreshLoopUntilSynced(bool skip_coinbase) {
m_refresh_cond.wait(lock); m_refresh_cond.wait(lock);
} }
lock.unlock(); lock.unlock();
// Always notify the last block height.
m_callback.callVoidMethod(getJniEnv(), Wallet_onRefresh, m_blockchain_height, false);
return ret; return ret;
} }