From 82b112c8b7b6a75a0d5179a137d6d6eac6bcd305 Mon Sep 17 00:00:00 2001
From: hai007 <hais@google.com>
Date: Tue, 18 May 2021 10:40:50 -0700
Subject: [PATCH] Internal change

PiperOrigin-RevId: 374453629
---
 cpp/core/internal/mediums/webrtc/webrtc_socket.cc | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/cpp/core/internal/mediums/webrtc/webrtc_socket.cc b/cpp/core/internal/mediums/webrtc/webrtc_socket.cc
index 71d80ce7..17d7b8c5 100644
--- a/cpp/core/internal/mediums/webrtc/webrtc_socket.cc
+++ b/cpp/core/internal/mediums/webrtc/webrtc_socket.cc
@@ -114,7 +114,7 @@ void WebRtcSocket::OnStateChange() {
       socket_listener_.socket_closed_cb(this);
 
       if (!closed_.Set(true)) {
-        ClosePipe();
+        OffloadFromSignalingThread([this] { ClosePipe(); });
       }
       break;
   }
@@ -161,6 +161,7 @@ void WebRtcSocket::ClosePipe() {
                        << ") this: " << this << " done";
 }
 
+// Must not be called on signalling thread.
 void WebRtcSocket::WakeUpWriter() {
   MutexLock lock(&backpressure_mutex_);
   buffer_variable_.Notify();