Compare commits

...

2 Commits

Author SHA1 Message Date
1f0e086b7a
fixes and tweaks 2023-01-16 15:45:54 +01:00
78069a8032
finish request strategy (for now) 2023-01-16 15:29:49 +01:00
8 changed files with 29 additions and 10 deletions

View File

@ -794,7 +794,7 @@ inline DWORD int64_low(int64_t n) noexcept
return n & 0xffffffff;
}
std::wstring s_2_ws(const std::string& s)
inline std::wstring s_2_ws(const std::string& s)
{
if (s.empty())
return{};

@ -1 +1 @@
Subproject commit c9479153892ff3aee0e65d33cc61aff8df6aa7bc
Subproject commit fc13d93d42d6e4e0a4a5b7be3ff18672e68e4600

@ -1 +1 @@
Subproject commit 04befb21be0327996eb3597cb91d5bdd00066974
Subproject commit a4497390508cab73ac62a8d36aac3d018f10df49

View File

@ -127,7 +127,8 @@ target_include_directories(toxcore PRIVATE "${TOX_DIR}toxcore")
target_include_directories(toxcore PUBLIC "${TOX_DIR}")
target_compile_definitions(toxcore PUBLIC USE_IPV6=1)
target_compile_definitions(toxcore PUBLIC MIN_LOGGER_LEVEL=LOGGER_LEVEL_DEBUG)
#target_compile_definitions(toxcore PUBLIC MIN_LOGGER_LEVEL=LOGGER_LEVEL_DEBUG)
target_compile_definitions(toxcore PUBLIC MIN_LOGGER_LEVEL=LOGGER_LEVEL_INFO)
find_package(unofficial-sodium CONFIG QUIET)
find_package(sodium QUIET)

View File

@ -27,7 +27,7 @@ SendStartSHA1::SendStartSHA1(ToxClient& tcl, const CommandLine& cl) : StateI(tcl
assert(!_file_map.empty());
// build info
_sha1_info.file_name = std::filesystem::path(cl.send_path).filename();
_sha1_info.file_name = std::filesystem::path(cl.send_path).filename().string();
_sha1_info.file_size = _file_map.length();
{ // build chunks

View File

@ -82,11 +82,24 @@ bool SHA1::iterate(float delta) {
// if we have not heard for 10sec, timeout
if (time_since_remove_activity >= 10.f) {
std::cerr << "SHA1 receiving chunk tansfer timed out " << std::get<0>(*it) << ":" << std::get<1>(*it) << "." << int(std::get<2>(*it)) << "\n";
_chunk_want_queue.push_back(std::get<4>(*it)); // put it back
it = _transfers_receiving_chunk.erase(it);
} else {
it++;
}
}
// sent requests
for (auto it = _chunks_requested.begin(); it != _chunks_requested.end();) {
it->second += delta;
// if we have not heard for 15sec, timeout
if (it->second >= 15.f) {
_chunk_want_queue.push_back(it->first); // put it back
it = _chunks_requested.erase(it);
} else {
it++;
}
}
}
// if we have not reached the total cap for transfers
@ -142,7 +155,7 @@ bool SHA1::iterate(float delta) {
}
}
if (!_have_all && !_chunk_want_queue.empty() && _transfers_receiving_chunk.size() < _max_concurrent_in) {
if (!_have_all && !_chunk_want_queue.empty() && _chunks_requested.size() + _transfers_receiving_chunk.size() < _max_concurrent_in) {
// send out request, no burst tho
std::vector<std::pair<uint32_t, uint32_t>> target_peers;
_tcl.forEachGroup([&target_peers, this](uint32_t group_number) {
@ -162,7 +175,7 @@ bool SHA1::iterate(float delta) {
auto [group_number, peer_number] = target_peers.at(target_index);
size_t chunk_index = _chunk_want_queue.front();
_chunks_requested.emplace(chunk_index);
_chunks_requested[chunk_index] = 0.f;
_chunk_want_queue.pop_front();
_tcl.sendFT1RequestPrivate(group_number, peer_number, NGC_FT1_file_kind::HASH_SHA1_CHUNK, _sha1_info.chunks[chunk_index].data.data(), 20);
@ -301,6 +314,9 @@ bool SHA1::onFT1ReceiveInitSHA1Chunk(uint32_t group_number, uint32_t peer_number
)
);
// remove form requests
_chunks_requested.erase(chunk_index);
return true;
}

View File

@ -7,7 +7,7 @@
#include <mio/mio.hpp>
#include <unordered_map>
#include <set>
#include <map>
#include <vector>
#include <deque>
#include <random>
@ -66,10 +66,11 @@ struct SHA1 final : public StateI {
bool _have_all {false};
size_t _have_count {0};
std::deque<size_t> _chunk_want_queue;
std::set<size_t> _chunks_requested;
// chunk_index -> time since request
std::map<size_t, float> _chunks_requested;
const size_t _max_concurrent_out {4};
const size_t _max_concurrent_in {4};
const size_t _max_concurrent_in {16};
std::minstd_rand _rng {1337};
std::uniform_int_distribution<size_t> _distrib;

View File

@ -253,6 +253,7 @@ void ToxClient::onToxGroupPeerExit(uint32_t group_number, uint32_t peer_id, Tox_
void ToxClient::onToxGroupSelfJoin(uint32_t group_number) {
std::cout << "TCL group self join " << group_number << "\n";
// ???
// can be triggered after other peers allready joined o.o
_tox_profile_dirty = true;
}