diff --git a/core/src/rpc_pubsub.rs b/core/src/rpc_pubsub.rs index 7909379f10..b77b68de88 100644 --- a/core/src/rpc_pubsub.rs +++ b/core/src/rpc_pubsub.rs @@ -222,6 +222,8 @@ impl RpcSolPubSubImpl { debug!("Total existing subscriptions: {}", num_subscriptions); if num_subscriptions >= self.max_active_subscriptions { info!("Node subscription limit reached"); + datapoint_info!("rpc-subscription", ("total", num_subscriptions, i64)); + inc_new_counter_info!("rpc-subscription-refused-limit-reached", 1); Err(Error { code: ErrorCode::InternalError, message: "Internal Error: Subscription refused. Node subscription limit reached" @@ -229,6 +231,7 @@ impl RpcSolPubSubImpl { data: None, }) } else { + datapoint_info!("rpc-subscription", ("total", num_subscriptions + 1, i64)); Ok(()) } }