Cease all future TURN requests when a TURN refresh request fails.

webrtc/p2p/base/stunrequest.cc

 /*
  *  Copyright 2004 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 35 matching lines @@
   request->set_origin(origin_);
   request->Construct();
   requests_[request->id()] = request;
   if (delay > 0) {
     thread_->PostDelayed(delay, request, MSG_STUN_SEND, NULL);
   } else {
     thread_->Send(request, MSG_STUN_SEND, NULL);
   }
 }
 
-void StunRequestManager::Flush() {
+void StunRequestManager::Flush(int msg_type) {
   for (const auto kv : requests_) {
     StunRequest* request = kv.second;
-    thread_->Clear(request, MSG_STUN_SEND);
-    thread_->Send(request, MSG_STUN_SEND, NULL);
+    if (msg_type == kAllRequests || msg_type == request->type()) {
+      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());
   if (iter != requests_.end()) {
     ASSERT(iter->second == request);
     requests_.erase(iter);
     thread_->Clear(request);
@@ skipping 145 matching lines @@
 }
 
 int StunRequest::resend_delay() {
   if (count_ == 0) {
     return 0;
   }
   return DELAY_UNIT * std::min(1 << (count_-1), DELAY_MAX_FACTOR);
 }
 
 }  // namespace cricket