blockworks-foundation
/
lite-rpc
mirror of https://github.com/blockworks-foundation/lite-rpc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

minor changes for socket addr

This commit is contained in:
Godmode Galactus 2022-12-11 21:05:19 +01:00
parent 72e52dff90
commit 6d14edd617
No known key found for this signature in database
GPG Key ID: A04142C71ABB0DEA
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main.rs
View File

@ -65,7 +65,7 @@ fn run(port: u16, subscription_port: u16, rpc_url: String, websocket_url: String
));
let subscription_port =
SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), subscription_port);
SocketAddr::new(IpAddr::V4(Ipv4Addr::new(0, 0, 0, 0)), subscription_port);
// start websocket server
let (_trigger, websocket_service) = LitePubSubService::new(
@ -116,7 +116,7 @@ fn run(port: u16, subscription_port: u16, rpc_url: String, websocket_url: String
);
let max_request_body_size: usize = 50 * (1 << 10);
let socket_addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), port);
let socket_addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(0, 0, 0, 0)), port);
{
let request_processor = request_processor.clone();
let server =

4
src/rpc.rs
View File

@ -168,10 +168,10 @@ impl LightRpcRequestProcessor {
Builder::new()
.name("thread working on confirmation block".to_string())
.spawn(move || {
let nonblocking_rpc_client =
let rpc_client =
Arc::new(RpcClient::new(json_rpc_url.to_string()));
let tpu_client = TpuClient::new_with_connection_cache(
nonblocking_rpc_client,
rpc_client,
websocket_url.as_str(),
TpuClientConfig::default(), // value for max fanout slots
connection_cache.clone(),