Increase STUN RTOs

webrtc/base/thread.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 474 matching lines @@
       *smsg.ready = true;
       smsg.thread->socketserver()->WakeUp();
       continue;
     }
     ++iter;
   }
 
   MessageQueue::Clear(phandler, id, removed);
 }
 
-bool Thread::ProcessMessages(int cmsLoop) {
+bool Thread::ProcessMessages(int cmsLoop, int messages_limit) {
   int64_t msEnd = (kForever == cmsLoop) ? 0 : TimeAfter(cmsLoop);
   int cmsNext = cmsLoop;
+  int messages_processed = 0;
 
   while (true) {
 #if __has_feature(objc_arc)
     @autoreleasepool
 #elif defined(WEBRTC_MAC)
     // see: http://developer.apple.com/library/mac/#documentation/Cocoa/Reference/Foundation/Classes/NSAutoreleasePool_Class/Reference/Reference.html
     // Each thread is supposed to have an autorelease pool. Also for event loops
     // like this, autorelease pool needs to be created and drained/released
     // for each cycle.
     ScopedAutoreleasePool pool;
 #endif
     {
       Message msg;
       if (!Get(&msg, cmsNext))
         return !IsQuitting();
       Dispatch(&msg);
+      if (messages_limit > 0) {
+        ++messages_processed;
+        if (messages_processed > messages_limit) {
+          return true;
+        }
+      }
 
       if (cmsLoop != kForever) {
         cmsNext = static_cast<int>(TimeUntil(msEnd));
         if (cmsNext < 0)
           return true;
       }
     }
   }
 }
 
@@ skipping 43 matching lines @@
   if (SUCCEEDED(hr)) {
     Thread::Run();
     CoUninitialize();
   } else {
     LOG(LS_ERROR) << "CoInitialize failed, hr=" << hr;
   }
 }
 #endif
 
 }  // namespace rtc