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

update quic-streamer to 1.16

This commit is contained in:
GroovieGermanikus 2023-09-04 15:24:36 +02:00
parent 6cfaa77a99
commit 3485be5594
1 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
quic-forward-proxy-integration-test/tests/quic_proxy_tpu_integrationtest.rs
View File

@ -210,19 +210,18 @@ fn wireup_and_send_txs_via_channel(test_case_params: TestCaseParams) {
runtime_quic1.block_on(async {
// setup solana Quic streamer
// see log "Start quic server on UdpSocket { addr: 127.0.0.1:xxxxx, fd: 10 }"
let staked_nodes = StakedNodes {
total_stake: 100,
max_stake: 40,
min_stake: 0,
ip_stake_map: Default::default(),
pubkey_stake_map: if test_case_params.stake_connection {
let stakes_map = Arc::new(
if test_case_params.stake_connection {
let mut map = HashMap::new();
map.insert(literpc_validator_identity.pubkey(), 30);
map
} else {
HashMap::default()
},
};
});
let staked_nodes = StakedNodes::new(
stakes_map,
Default::default()
);
let _solana_quic_streamer = SolanaQuicStreamer::new_start_listening(
udp_listen_socket,
@ -424,8 +423,8 @@ async fn solana_quic_streamer_start() {
let keypair = Keypair::new();
// gossip_host is used in the server certificate
let gossip_host = "127.0.0.1".parse().unwrap();
let stats = Arc::new(StreamStats::default());
let (_, t) = solana_streamer::nonblocking::quic::spawn_server(
let (_, stats, t) = solana_streamer::nonblocking::quic::spawn_server(
"test-quic-server",
sock.try_clone().unwrap(),
&keypair,
gossip_host,
@ -435,8 +434,8 @@ async fn solana_quic_streamer_start() {
staked_nodes,
10,
10,
stats.clone(),
1000,
Duration::from_millis(1000),
Duration::from_millis(1000),
)
.unwrap();
@ -449,7 +448,7 @@ async fn solana_quic_streamer_start() {
exit.store(true, Ordering::Relaxed);
t.await.unwrap();
stats.report();
stats.report("test-quic-streamer");
}
// no quic proxy
@ -705,8 +704,8 @@ impl SolanaQuicStreamer {
let keypair = Keypair::new();
// gossip_host is used in the server certificate
let gossip_host = "127.0.0.1".parse().unwrap();
let stats = Arc::new(StreamStats::default());
let (_, jh) = solana_streamer::nonblocking::quic::spawn_server(
let (_, stats, jh) = solana_streamer::nonblocking::quic::spawn_server(
"test-quic-server",
udp_socket.try_clone().unwrap(),
&keypair,
gossip_host,
@ -716,8 +715,8 @@ impl SolanaQuicStreamer {
staked_nodes,
10,
10,
stats.clone(),
1000,
Duration::from_millis(1000),
Duration::from_millis(1000),
)
.unwrap();