Index: webrtc/p2p/base/stunrequest.cc |
diff --git a/webrtc/p2p/base/stunrequest.cc b/webrtc/p2p/base/stunrequest.cc |
index df5614d3cc12a93771ca7c4c0b03d0f1ca334675..0a0b1a8997291d5d3c2c84ea191f8e6c812c355b 100644 |
--- a/webrtc/p2p/base/stunrequest.cc |
+++ b/webrtc/p2p/base/stunrequest.cc |
@@ -53,6 +53,14 @@ void StunRequestManager::SendDelayed(StunRequest* request, int delay) { |
} |
} |
+void StunRequestManager::Flush() { |
+ for (const auto kv : requests_) { |
+ StunRequest* request = kv.second; |
+ thread_->Clear(request, MSG_STUN_SEND); |
+ thread_->Send(request, MSG_STUN_SEND, NULL); |
+ } |
+} |
+ |
void StunRequestManager::Remove(StunRequest* request) { |
ASSERT(request->manager() == this); |
RequestMap::iterator iter = requests_.find(request->id()); |