Compare commits
2 Commits
80288a4ade
...
07056d8c58
Author | SHA1 | Date |
---|---|---|
godmodegalactus | 07056d8c58 | |
godmodegalactus | 522866b508 |
|
@ -1793,7 +1793,7 @@ dependencies = [
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "geyser-grpc-connector"
|
name = "geyser-grpc-connector"
|
||||||
version = "0.10.6+yellowstone.1.13"
|
version = "0.10.6+yellowstone.1.13"
|
||||||
source = "git+https://github.com/blockworks-foundation/geyser-grpc-connector.git?tag=v0.10.6+yellowstone.1.13+solana.1.17.28#20f29c1e21e1682f124c0a3386cd4a85b1854f01"
|
source = "git+https://github.com/blockworks-foundation/geyser-grpc-connector.git?branch=release/solana-v0.17.31+yellowstone.1.13.0_compression#05f110c895bf26477d9b4d33c86a58a344eded0b"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"anyhow",
|
"anyhow",
|
||||||
"async-stream",
|
"async-stream",
|
||||||
|
@ -1807,6 +1807,7 @@ dependencies = [
|
||||||
"merge-streams",
|
"merge-streams",
|
||||||
"solana-sdk",
|
"solana-sdk",
|
||||||
"tokio",
|
"tokio",
|
||||||
|
"tonic",
|
||||||
"tonic-health",
|
"tonic-health",
|
||||||
"tracing",
|
"tracing",
|
||||||
"url",
|
"url",
|
||||||
|
@ -6814,9 +6815,8 @@ dependencies = [
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "yellowstone-grpc-client"
|
name = "yellowstone-grpc-client"
|
||||||
version = "1.14.0"
|
version = "1.14.0+solana.1.17.31"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "git+https://github.com/blockworks-foundation/yellowstone-grpc.git?branch=v1.13.0+solana.1.17.31#9010786cb5e95b679356fb8d2440d5ab86ef21ec"
|
||||||
checksum = "1f4f6d836d214cb8789002d039412da354049e9ffe983c643ec492c4d934698f"
|
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"bytes",
|
"bytes",
|
||||||
"futures",
|
"futures",
|
||||||
|
@ -6829,9 +6829,8 @@ dependencies = [
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "yellowstone-grpc-proto"
|
name = "yellowstone-grpc-proto"
|
||||||
version = "1.13.0"
|
version = "1.13.0+solana.1.17.31"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "git+https://github.com/blockworks-foundation/yellowstone-grpc.git?branch=v1.13.0+solana.1.17.31#9010786cb5e95b679356fb8d2440d5ab86ef21ec"
|
||||||
checksum = "9c00b66d40d85c405f14b420d7674e98c70d06f6b673f36c9e0285f81b9b797d"
|
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"anyhow",
|
"anyhow",
|
||||||
"bincode",
|
"bincode",
|
||||||
|
|
|
@ -87,9 +87,9 @@ solana-lite-rpc-accounts = {path = "accounts", version = "0.2.4"}
|
||||||
solana-lite-rpc-accounts-on-demand = {path = "accounts-on-demand", version = "0.2.4"}
|
solana-lite-rpc-accounts-on-demand = {path = "accounts-on-demand", version = "0.2.4"}
|
||||||
bench = { path = "bench", version="0.2.4" }
|
bench = { path = "bench", version="0.2.4" }
|
||||||
|
|
||||||
yellowstone-grpc-proto = "1.13.0"
|
yellowstone-grpc-proto = { git = "https://github.com/blockworks-foundation/yellowstone-grpc.git", branch = "v1.13.0+solana.1.17.31" }
|
||||||
#geyser-grpc-connector = { path = "../../geyser-grpc-connector" }
|
#geyser-grpc-connector = { path = "../../geyser-grpc-connector" }
|
||||||
geyser-grpc-connector = { tag = "v0.10.6+yellowstone.1.13+solana.1.17.28", git = "https://github.com/blockworks-foundation/geyser-grpc-connector.git" }
|
geyser-grpc-connector = { branch = "release/solana-v0.17.31+yellowstone.1.13.0_compression", git = "https://github.com/blockworks-foundation/geyser-grpc-connector.git" }
|
||||||
|
|
||||||
|
|
||||||
async-trait = "0.1.68"
|
async-trait = "0.1.68"
|
||||||
|
|
|
@ -414,7 +414,7 @@ impl AccountStorageInterface for InmemoryAccountStore {
|
||||||
}
|
}
|
||||||
None => {
|
None => {
|
||||||
if commitment == Commitment::Confirmed {
|
if commitment == Commitment::Confirmed {
|
||||||
log::warn!(
|
log::debug!(
|
||||||
"slot status not found for {} and commitment {}, confirmed lagging",
|
"slot status not found for {} and commitment {}, confirmed lagging",
|
||||||
slot,
|
slot,
|
||||||
commitment.into_commitment_level()
|
commitment.into_commitment_level()
|
||||||
|
|
|
@ -47,4 +47,4 @@ prometheus = { workspace = true }
|
||||||
lazy_static = { workspace = true }
|
lazy_static = { workspace = true }
|
||||||
tonic-health = { workspace = true }
|
tonic-health = { workspace = true }
|
||||||
tonic = {workspace = true}
|
tonic = {workspace = true}
|
||||||
yellowstone-grpc-client = "1.13.0"
|
yellowstone-grpc-client = { git = "https://github.com/blockworks-foundation/yellowstone-grpc.git", branch = "v1.13.0+solana.1.17.31" }
|
|
@ -42,6 +42,7 @@ fn create_grpc_multiplex_processed_block_task(
|
||||||
GeyserFilter(COMMITMENT_CONFIG).blocks_and_txs(),
|
GeyserFilter(COMMITMENT_CONFIG).blocks_and_txs(),
|
||||||
autoconnect_tx.clone(),
|
autoconnect_tx.clone(),
|
||||||
exit_notify.resubscribe(),
|
exit_notify.resubscribe(),
|
||||||
|
true,
|
||||||
);
|
);
|
||||||
tasks.push(task);
|
tasks.push(task);
|
||||||
}
|
}
|
||||||
|
@ -52,7 +53,7 @@ fn create_grpc_multiplex_processed_block_task(
|
||||||
'recv_loop: loop {
|
'recv_loop: loop {
|
||||||
// recv loop
|
// recv loop
|
||||||
if last_tick.elapsed() > Duration::from_millis(800) {
|
if last_tick.elapsed() > Duration::from_millis(800) {
|
||||||
warn!(
|
trace!(
|
||||||
"(soft_realtime) slow multiplex loop interation: {:?}",
|
"(soft_realtime) slow multiplex loop interation: {:?}",
|
||||||
last_tick.elapsed()
|
last_tick.elapsed()
|
||||||
);
|
);
|
||||||
|
@ -145,6 +146,7 @@ fn create_grpc_multiplex_block_info_task(
|
||||||
GeyserFilter(commitment_config).blocks_meta(),
|
GeyserFilter(commitment_config).blocks_meta(),
|
||||||
autoconnect_tx.clone(),
|
autoconnect_tx.clone(),
|
||||||
exit_notify.resubscribe(),
|
exit_notify.resubscribe(),
|
||||||
|
false,
|
||||||
);
|
);
|
||||||
tasks.push(task);
|
tasks.push(task);
|
||||||
}
|
}
|
||||||
|
@ -494,6 +496,7 @@ pub fn create_grpc_multiplex_processed_slots_subscription(
|
||||||
GeyserFilter(COMMITMENT_CONFIG).slots(),
|
GeyserFilter(COMMITMENT_CONFIG).slots(),
|
||||||
autoconnect_tx.clone(),
|
autoconnect_tx.clone(),
|
||||||
exit_notify.resubscribe(),
|
exit_notify.resubscribe(),
|
||||||
|
false,
|
||||||
)
|
)
|
||||||
})
|
})
|
||||||
.collect_vec();
|
.collect_vec();
|
||||||
|
|
|
@ -302,6 +302,7 @@ pub fn create_block_processing_task(
|
||||||
conn_window: Some(5242880),
|
conn_window: Some(5242880),
|
||||||
stream_window: Some(4194304),
|
stream_window: Some(4194304),
|
||||||
},
|
},
|
||||||
|
true,
|
||||||
)
|
)
|
||||||
.await?;
|
.await?;
|
||||||
let mut stream = tokio::select! {
|
let mut stream = tokio::select! {
|
||||||
|
|
Loading…
Reference in New Issue