Green-Sky/tox_ngc_ft1
1
0
Fork 0
mirror of https://github.com/Green-Sky/tox_ngc_ft1.git synced 2024-12-23 02:53:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: Green-Sky:5bb4349e27fda14a9e99fe17d6f59de66a00d410
Branches Tags
Green-Sky:master
..
compare: Green-Sky:04befb21be0327996eb3597cb91d5bdd00066974
Branches Tags
Green-Sky:master

No commits in common. "5bb4349e27fda14a9e99fe17d6f59de66a00d410" and "04befb21be0327996eb3597cb91d5bdd00066974" have entirely different histories.
5bb4349e27 ... 04befb21be

1 changed files with 4 additions and 10 deletions
Show Stats Expand all files Collapse all files

14
ngc_ft1.cpp
View File

@ -10,7 +10,6 @@
#include <map>
#include <optional>
#include <cassert>
#include <cstdio>
struct SendSequenceBuffer {
struct SSBEntry {
@ -225,7 +224,7 @@ void NGC_FT1_iterate(Tox *tox, NGC_FT1* ngc_ft1_ctx) {
switch (tf.state) {
using State = NGC_FT1::Group::Peer::SendTransfer::State;
case State::INIT_SENT:
if (tf.time_since_activity >= 10.f) {
if (tf.time_since_activity >= 20.f) {
if (tf.inits_sent >= 3) {
// delete, timed out 3 times
fprintf(stderr, "FT: warning, ft init timed out, deleting\n");
@ -259,12 +258,11 @@ void NGC_FT1_iterate(Tox *tox, NGC_FT1* ngc_ft1_ctx) {
assert(ngc_ft1_ctx->cb_send_data.count(tf.file_kind));
// if chunks in flight < window size (2)
static const size_t window_size {2}; // TODO: expose
while (tf.ssb.size() < window_size) {
// if chunks in flight < window size (1 lol)
while (tf.ssb.size() < 1) {
std::vector<uint8_t> new_data;
size_t chunk_size = std::min<size_t>(450u, tf.file_size - tf.file_size_current);
size_t chunk_size = std::min<size_t>(400u, tf.file_size - tf.file_size_current);
if (chunk_size == 0) {
// TODO: set to finishing?
break; // we done
@ -283,9 +281,7 @@ void NGC_FT1_iterate(Tox *tox, NGC_FT1* ngc_ft1_ctx) {
uint16_t seq_id = tf.ssb.add(std::move(new_data));
_send_pkg_FT1_DATA(tox, group_number, peer_number, idx, seq_id, tf.ssb.entries.at(seq_id).data.data(), tf.ssb.entries.at(seq_id).data.size());
#if defined(EXTRA_LOGGING) && EXTRA_LOGGING == 1
fprintf(stderr, "FT: sent data size: %ld (seq %d)\n", chunk_size, seq_id);
#endif
tf.file_size_current += chunk_size;
}
@ -627,9 +623,7 @@ static void _handle_FT1_INIT(
if (accept_ft) {
_send_pkg_FT1_INIT_ACK(tox, group_number, peer_number, transfer_id);
#if defined(EXTRA_LOGGING) && EXTRA_LOGGING == 1
fprintf(stderr, "FT: accepted init\n");
#endif
auto& peer = ngc_ft1_ctx->groups[group_number].peers[peer_number];
if (peer.recv_transfers[transfer_id].has_value()) {
fprintf(stderr, "FT: overwriting existing recv_transfer %d\n", transfer_id);