@@ -147,6 +147,7 @@ func (c *Conn) logger() slog.Logger {
147147if ! valid {
148148return slog.Logger {}
149149}
150+
150151return log
151152}
152153
@@ -566,11 +567,14 @@ func (c *Conn) isClosed() bool {
566567func (c * Conn )CloseWithError (err error )error {
567568c .closeMutex .Lock ()
568569defer c .closeMutex .Unlock ()
570+
569571if c .isClosed () {
570572return c .closeError
571573}
572574
573- c .logger ().Debug (context .Background (),"closing conn with error" ,slog .Error (err ))
575+ logger := c .logger ()
576+
577+ logger .Debug (context .Background (),"closing conn with error" ,slog .Error (err ))
574578if err == nil {
575579c .closeError = ErrClosed
576580}else {
@@ -588,21 +592,23 @@ func (c *Conn) CloseWithError(err error) error {
588592// Waiting for pion/webrtc to report closed state on both of these
589593// ensures no goroutine leaks.
590594if c .rtc .ConnectionState ()!= webrtc .PeerConnectionStateNew {
591- c . logger () .Debug (context .Background (),"waiting for rtc connection close..." )
595+ logger .Debug (context .Background (),"waiting for rtc connection close..." )
592596<- c .closedRTC
593597}
594598if c .rtc .ICEConnectionState ()!= webrtc .ICEConnectionStateNew {
595- c . logger () .Debug (context .Background (),"waiting for ice connection close..." )
599+ logger .Debug (context .Background (),"waiting for ice connection close..." )
596600<- c .closedICE
597601}
598602
599603// Waits for all DataChannels to exit before officially labeling as closed.
600604// All logging, goroutines, and async functionality is cleaned up after this.
601605c .dcClosedWaitGroup .Wait ()
602606
603- c .logger ().Debug (context .Background (),"closed" )
604607// Disable logging!
605608c .loggerValue .Store (slog.Logger {})
609+ logger .Sync ()
610+
611+ logger .Debug (context .Background (),"closed" )
606612close (c .closed )
607613return err
608614}