mirror of
https://github.com/mikedilger/chorus.git
synced 2026-04-03 06:41:16 +00:00
Bring back logging of the errors that cause CLOSED
This commit is contained in:
parent
9b2d6365f0
commit
95614fad55
@ -79,6 +79,7 @@ impl WebSocketService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if let Err(e) = self.req_inner(&subid, filters).await {
|
if let Err(e) = self.req_inner(&subid, filters).await {
|
||||||
|
log::error!("{}: {e}", self.peer);
|
||||||
let reply = match e.inner {
|
let reply = match e.inner {
|
||||||
ChorusError::TooManySubscriptions => {
|
ChorusError::TooManySubscriptions => {
|
||||||
let max_subscriptions = GLOBALS.config.get().unwrap().max_subscriptions;
|
let max_subscriptions = GLOBALS.config.get().unwrap().max_subscriptions;
|
||||||
@ -156,7 +157,7 @@ impl WebSocketService {
|
|||||||
self.subscriptions.insert(subid.to_owned(), filters);
|
self.subscriptions.insert(subid.to_owned(), filters);
|
||||||
|
|
||||||
log::debug!(
|
log::debug!(
|
||||||
"{}, new subscription \"{subid}\", {} total",
|
"{}: new subscription \"{subid}\", {} total",
|
||||||
self.peer,
|
self.peer,
|
||||||
self.subscriptions.len()
|
self.subscriptions.len()
|
||||||
);
|
);
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user