From 3620d271af36a210af9c83fd6b49d13940710055 Mon Sep 17 00:00:00 2001
From: Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>
Date: Mon, 25 Jun 2012 21:37:55 +0900
Subject: [PATCH] Process as many messages as possible in recv buffer

---
 src/DHTInteractionCommand.cc | 2 +-
 src/DefaultBtInteractive.cc  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/DHTInteractionCommand.cc b/src/DHTInteractionCommand.cc
index ff17a8a6f..f98e4699c 100644
--- a/src/DHTInteractionCommand.cc
+++ b/src/DHTInteractionCommand.cc
@@ -83,7 +83,7 @@ bool DHTInteractionCommand::execute()
 
   taskQueue_->executeTask();
 
-  for(size_t i = 0; i < 20; ++i) {
+  while(1) {
     SharedHandle<DHTMessage> m = receiver_->receiveMessage();
     if(!m) {
       break;
diff --git a/src/DefaultBtInteractive.cc b/src/DefaultBtInteractive.cc
index b70bb330d..cb2530e88 100644
--- a/src/DefaultBtInteractive.cc
+++ b/src/DefaultBtInteractive.cc
@@ -274,7 +274,7 @@ void DefaultBtInteractive::sendKeepAlive() {
 size_t DefaultBtInteractive::receiveMessages() {
   size_t countOldOutstandingRequest = dispatcher_->countOutstandingRequest();
   size_t msgcount = 0;
-  for(int i = 0; i < UB_MAX_OUTSTANDING_REQUEST+50; ++i) {
+  while(1) {
     if(requestGroupMan_->doesOverallDownloadSpeedExceed() ||
        downloadContext_->getOwnerRequestGroup()->doesDownloadSpeedExceed()) {
       break;