Green-Sky/tox_delay_tests
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

timeout and tox2

Browse Source
This commit is contained in:
Green Sky 2022-06-25 21:40:51 +02:00
parent 044a640c13
commit 0f35249df1
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/test1_common.hpp
View File

@ -102,7 +102,8 @@ class ToxService {
DHT_node nodes[] = DHT_node nodes[] =
{ {
// own bootsrap node, to reduce load // own bootsrap node, to reduce load
{"tox.plastiras.org", 33445, "8E8B63299B3D520FB377FE5100E65E3322F7AE5B20A0ACED2981769FC5B43725", {}}, // 14 //{"tox.plastiras.org", 33445, "8E8B63299B3D520FB377FE5100E65E3322F7AE5B20A0ACED2981769FC5B43725", {}}, // 14
{"tox2.plastiras.org", 33445, "B6626D386BE7E3ACA107B46F48A5C4D522D29281750D44A0CBA6A2721E79C951", {}}, // 14
}; };
for (size_t i = 0; i < sizeof(nodes)/sizeof(DHT_node); i ++) { for (size_t i = 0; i < sizeof(nodes)/sizeof(DHT_node); i ++) {

14
src/test1_sender.cpp
View File

@ -62,6 +62,20 @@ class ToxServiceSender : public ToxService {
continue; continue;
} }
{ // do timeout
const uint32_t timeout {1000000}; // 1sec
auto time_stamp_now = get_microseconds();
for (auto it = _pkg_info.begin(); it != _pkg_info.end();) {
if (time_stamp_now - it->second.time_stamp >= timeout) {
std::cout << "pkg " << it->first << " timed out!\n";
it = _pkg_info.erase(it);
} else {
it++;
}
}
}
if (_window > _pkg_info.size()) { // can send if (_window > _pkg_info.size()) { // can send
// 192-254 for lossy // 192-254 for lossy
const size_t max_pkg_size = 1024 + 1; const size_t max_pkg_size = 1024 + 1;