// To the extent possible under law, the author(s) have dedicated all
// copyright and related and neighboring rights to this software to
// the public domain worldwide. This software is distributed without
// any warranty.
//
// You should have received a copy of the CC0 Public Domain Dedication
// along with this software.
// If not, see .
//
extern crate bellscoincore_rpc;
extern crate jsonrpc;
extern crate serde;
extern crate serde_json;
use bellscoincore_rpc::{Client, Error, Result, RpcApi};
pub struct RetryClient {
client: Client,
}
const INTERVAL: u64 = 1000;
const RETRY_ATTEMPTS: u8 = 10;
impl RpcApi for RetryClient {
fn call serde::de::Deserialize<'a>>(
&self,
cmd: &str,
args: &[serde_json::Value],
) -> Result {
for _ in 0..RETRY_ATTEMPTS {
match self.client.call(cmd, args) {
Ok(ret) => return Ok(ret),
Err(Error::JsonRpc(jsonrpc::error::Error::Rpc(ref rpcerr)))
if rpcerr.code == -28 =>
{
::std::thread::sleep(::std::time::Duration::from_millis(INTERVAL));
continue;
}
Err(e) => return Err(e),
}
}
self.client.call(cmd, args)
}
}
fn main() {}