Browse Source

prevent explosion of status checks. this traffic has increased a lot since we fixed tracker issues.

miguelfreitas
Miguel Freitas 11 years ago
parent
commit
4e701dd7a4
  1. 18
      src/twister.cpp

18
src/twister.cpp

@ -508,7 +508,7 @@ void ThreadMaintainDHTNodes()
void ThreadSessionAlerts() void ThreadSessionAlerts()
{ {
static map<sha1_hash, bool> neighborCheck; static map<sha1_hash, bool> neighborCheck;
static map<sha1_hash, bool> statusCheck; static map<sha1_hash, int64_t> statusCheck;
while(!ses) { while(!ses) {
MilliSleep(200); MilliSleep(200);
@ -600,11 +600,16 @@ void ThreadSessionAlerts()
neighborCheck[ih] = false; neighborCheck[ih] = false;
ses->dht_getData(n->string(), r->string(), t->string() == "m"); ses->dht_getData(n->string(), r->string(), t->string() == "m");
} else if( neighborCheck[ih] ) { } else if( neighborCheck[ih] ) {
printf("known neighbor. starting a new dhtget check of [%s,%s,%s]\n",
n->string().c_str(), "status", "s");
sha1_hash ihStatus = dhtTargetHash(n->string(), "status", "s"); sha1_hash ihStatus = dhtTargetHash(n->string(), "status", "s");
statusCheck[ihStatus] = false;
ses->dht_getData(n->string(), "status", false); if( !statusCheck.count(ihStatus) ||
statusCheck[ihStatus] + 3600 < GetTime() ) {
printf("known neighbor. starting a new dhtget check of [%s,%s,%s]\n",
n->string().c_str(), "status", "s");
statusCheck[ihStatus] = GetTime();
ses->dht_getData(n->string(), "status", false);
}
} }
} }
} }
@ -640,12 +645,11 @@ void ThreadSessionAlerts()
printf("is neighbor. starting a new dhtget check of [%s,%s,%s]\n", printf("is neighbor. starting a new dhtget check of [%s,%s,%s]\n",
dd->m_username.c_str(), "status", "s"); dd->m_username.c_str(), "status", "s");
sha1_hash ihStatus = dhtTargetHash(dd->m_username, "status", "s"); sha1_hash ihStatus = dhtTargetHash(dd->m_username, "status", "s");
statusCheck[ihStatus] = false; statusCheck[ihStatus] = GetTime();
ses->dht_getData(dd->m_username, "status", false); ses->dht_getData(dd->m_username, "status", false);
} }
} }
if( statusCheck.count(ih) ) { if( statusCheck.count(ih) ) {
statusCheck[ih] = dd->m_got_data;
if( dd->m_got_data ) { if( dd->m_got_data ) {
startTorrentUser(dd->m_username, false); startTorrentUser(dd->m_username, false);
} }

Loading…
Cancel
Save