chainseeker-server 3.0.1

chainseeker.info server-side implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

use criterion::{criterion_group, criterion_main, Criterion};
use tokio::runtime::Runtime;
use bitcoin::consensus::Decodable;
use bitcoin::Block;

use chainseeker_server::*;

const COIN: &str = "bench";
const BLOCK: &[u8] = include_bytes!("../fixtures/mainnet/block_500000.bin");

fn bench_synced_height_db(c: &mut Criterion) {
    let mut synced_height_db = SyncedHeightDB::new(COIN);
    const HEIGHT: u32 = 123456;
    synced_height_db.put(HEIGHT);
    c.bench_function("SyncedHeightDB.put()", |b| b.iter(|| {
        synced_height_db.put(HEIGHT);
    }));
    c.bench_function("SyncedHeightDB.get()", |b| b.iter(|| {
        assert_eq!(synced_height_db.get(), Some(HEIGHT));
    }));
}

fn bench_db(c: &mut Criterion) {
    let rt = Runtime::new().unwrap();
    let block = Block::consensus_decode(BLOCK).expect("Failed to decode block.");
    let mut utxo_db = UtxoDB::new(COIN, true);
    c.bench_function("UtxoDB", |b| b.iter(|| {
        utxo_db.process_block(&block, true);
    }));
    let utxos = utxo_db.process_block(&block, true);
    c.bench_function("UtxoServer", |b| b.iter(|| {
        rt.block_on(async {
            let mut utxo_server = UtxoServer::new(COIN);
            for utxo in utxos.iter() {
                utxo_server.push(&utxo).await;
            }
        });
    }));
    // Construct dummy data.
    let mut previous_utxos = Vec::new();
    for tx in block.txdata.iter() {
        for _vin in tx.input.iter() {
            previous_utxos.push(UtxoEntry {
                script_pubkey: block.txdata[0].output[0].script_pubkey.clone(),
                txid: tx.txid(),
                vout: 0,
                value: 12345678u64,
            });
        }
    }
    c.bench_function("RichList", |b| b.iter(|| {
        let mut rich_list = RichList::new();
        rich_list.process_block(&block, &previous_utxos);
        rich_list.finalize();
    }));
    let addr_index_db = AddressIndexDB::new(COIN, true);
    c.bench_function("AddressIndexDB", |b| b.iter(|| {
        addr_index_db.process_block(&block, &previous_utxos);
    }));
}

criterion_group!(benches, bench_synced_height_db, bench_db);
criterion_main!(benches);