add panic handler to async client/channel writes

See #2113 for motivation
ergochat · Jan 5, 2024 · dfe2a21 · dfe2a21
1 parent 1d8bbde
commit dfe2a21
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/irc/channel.go b/irc/channel.go
@@ -222,6 +222,8 @@ func (channel *Channel) wakeWriter() {
 
 // equivalent of Socket.send()
 func (channel *Channel) writeLoop() {
+	defer channel.server.HandlePanic()
+
 	for {
 		// TODO(#357) check the error value of this and implement timed backoff
 		channel.performWrite(0)

diff --git a/irc/client.go b/irc/client.go
@@ -1773,6 +1773,8 @@ func (client *Client) wakeWriter() {
 }
 
 func (client *Client) writeLoop() {
+	defer client.server.HandlePanic()
+
 	for {
 		client.performWrite(0)
 		client.writebackLock.Unlock()