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