392a39dd54
* Remove unused PohServiceConfig::Step * Clarify variable name * Poh::hash() now takes an iteration counter * man -> max * Inline functions with single call site * Move PohServiceConfig into GenesisBlock * Add plumbing to enable real PoH on testnets * Batch hashes to improve PoH hash rate * Ensure a constant hashes_per_tick * Remove PohEntry mixin field * Poh/PohEntry no longer maintains tick_height * Ensure a constant hashes_per_tick * ci/localnet-sanity.sh: Use real PoH * Rework Poh/PohService to keep PohRecorder unlocked as much as possible while hashing
83 lines
2.5 KiB
Rust
83 lines
2.5 KiB
Rust
use crate::client_error::ClientError;
|
|
use crate::generic_rpc_client_request::GenericRpcClientRequest;
|
|
use crate::rpc_request::{RpcError, RpcRequest};
|
|
use log::*;
|
|
use reqwest;
|
|
use reqwest::header::CONTENT_TYPE;
|
|
use solana_sdk::timing::{DEFAULT_NUM_TICKS_PER_SECOND, DEFAULT_TICKS_PER_SLOT};
|
|
use std::thread::sleep;
|
|
use std::time::Duration;
|
|
|
|
pub struct RpcClientRequest {
|
|
client: reqwest::Client,
|
|
url: String,
|
|
}
|
|
|
|
impl RpcClientRequest {
|
|
pub fn new(url: String) -> Self {
|
|
Self {
|
|
client: reqwest::Client::new(),
|
|
url,
|
|
}
|
|
}
|
|
|
|
pub fn new_with_timeout(url: String, timeout: Duration) -> Self {
|
|
let client = reqwest::Client::builder()
|
|
.timeout(timeout)
|
|
.build()
|
|
.expect("build rpc client");
|
|
|
|
Self { client, url }
|
|
}
|
|
}
|
|
|
|
impl GenericRpcClientRequest for RpcClientRequest {
|
|
fn send(
|
|
&self,
|
|
request: &RpcRequest,
|
|
params: Option<serde_json::Value>,
|
|
mut retries: usize,
|
|
) -> Result<serde_json::Value, ClientError> {
|
|
// Concurrent requests are not supported so reuse the same request id for all requests
|
|
let request_id = 1;
|
|
|
|
let request_json = request.build_request_json(request_id, params);
|
|
|
|
loop {
|
|
match self
|
|
.client
|
|
.post(&self.url)
|
|
.header(CONTENT_TYPE, "application/json")
|
|
.body(request_json.to_string())
|
|
.send()
|
|
{
|
|
Ok(mut response) => {
|
|
let json: serde_json::Value = serde_json::from_str(&response.text()?)?;
|
|
if json["error"].is_object() {
|
|
Err(RpcError::RpcRequestError(format!(
|
|
"RPC Error response: {}",
|
|
serde_json::to_string(&json["error"]).unwrap()
|
|
)))?
|
|
}
|
|
return Ok(json["result"].clone());
|
|
}
|
|
Err(e) => {
|
|
info!(
|
|
"make_rpc_request({:?}) failed, {} retries left: {:?}",
|
|
request, retries, e
|
|
);
|
|
if retries == 0 {
|
|
Err(e)?;
|
|
}
|
|
retries -= 1;
|
|
|
|
// Sleep for approximately half a slot
|
|
sleep(Duration::from_millis(
|
|
500 * DEFAULT_TICKS_PER_SLOT / DEFAULT_NUM_TICKS_PER_SECOND,
|
|
));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|