(cherry picked from commit 83a6c669a5
)
Co-authored-by: Tyera Eulberg <teulberg@gmail.com>
This commit is contained in:
@ -222,6 +222,8 @@ impl RpcSolPubSubImpl {
|
|||||||
debug!("Total existing subscriptions: {}", num_subscriptions);
|
debug!("Total existing subscriptions: {}", num_subscriptions);
|
||||||
if num_subscriptions >= self.max_active_subscriptions {
|
if num_subscriptions >= self.max_active_subscriptions {
|
||||||
info!("Node subscription limit reached");
|
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 {
|
Err(Error {
|
||||||
code: ErrorCode::InternalError,
|
code: ErrorCode::InternalError,
|
||||||
message: "Internal Error: Subscription refused. Node subscription limit reached"
|
message: "Internal Error: Subscription refused. Node subscription limit reached"
|
||||||
@ -229,6 +231,7 @@ impl RpcSolPubSubImpl {
|
|||||||
data: None,
|
data: None,
|
||||||
})
|
})
|
||||||
} else {
|
} else {
|
||||||
|
datapoint_info!("rpc-subscription", ("total", num_subscriptions + 1, i64));
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user