solana-svm 2.1.2

Solana SVM
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
64
65
66
67
68
69
70
71
72
73
74
75
76

#![allow(clippy::arithmetic_side_effects)]

use {
    clap::{value_t_or_exit, App, Arg},
    std::{
        net::{IpAddr, Ipv4Addr, SocketAddr},
        path::PathBuf,
        sync::{
            atomic::{AtomicBool, Ordering},
            Arc,
        },
        thread,
        time::Duration,
    },
};

pub mod rpc_process;
pub mod rpc_service;
pub mod svm_bridge;

fn main() {
    env_logger::init();
    let matches = App::new("solana-json-rpc")
        .version("0.1.0")
        .author("Agave Team <hello@anza.xyz>")
        .about("JSON-RPC Simulation server")
        .arg(
            Arg::with_name("accounts_path")
                .short("a")
                .long("accounts")
                .value_name("FILE")
                .takes_value(true)
                .required(true)
                .default_value("accounts.json")
                .help("Use FILE as location of accounts.json"),
        )
        .arg(
            Arg::with_name("ledger_path")
                .short("l")
                .long("ledger")
                .value_name("DIR")
                .takes_value(true)
                .required(true)
                .default_value("test-ledger")
                .help("Use DIR as ledger location"),
        )
        .get_matches();

    let accounts_path = PathBuf::from(value_t_or_exit!(matches, "accounts_path", String));
    let ledger_path = PathBuf::from(value_t_or_exit!(matches, "ledger_path", String));
    let rpc_addr = IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1));
    let rpc_port = 8899u16;
    let rpc_addr = SocketAddr::new(rpc_addr, rpc_port);

    let config = rpc_process::JsonRpcConfig {
        accounts_path,
        ledger_path,
        rpc_threads: 1,
        rpc_niceness_adj: 0,
        max_request_body_size: Some(8192),
    };

    let exit = Arc::new(AtomicBool::new(false));
    let validator_exit = rpc_process::create_exit(exit.clone());

    let _rpc_service =
        rpc_service::JsonRpcService::new(rpc_addr, config, validator_exit, exit.clone());

    let refresh_interval = Duration::from_millis(250);
    for _i in 0.. {
        if exit.load(Ordering::Relaxed) {
            break;
        }
        thread::sleep(refresh_interval);
    }
}