make timeout equal, other stuff
This commit is contained in:
@@ -6,7 +6,6 @@ struct CUBIC : public FlowOnly {
|
|||||||
public: // config
|
public: // config
|
||||||
static constexpr float BETA {0.8f};
|
static constexpr float BETA {0.8f};
|
||||||
static constexpr float SCALING_CONSTANT {0.4f};
|
static constexpr float SCALING_CONSTANT {0.4f};
|
||||||
static constexpr float RTT_EMA_ALPHA = 0.1f; // 0.1 is very smooth, might need more
|
|
||||||
|
|
||||||
private:
|
private:
|
||||||
// window size before last reduciton
|
// window size before last reduciton
|
||||||
|
|||||||
@@ -62,7 +62,7 @@ void NGCFT1::updateSendTransfer(float time_delta, uint32_t group_number, uint32_
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
if (tf.time_since_activity >= sending_give_up_after) {
|
if (tf.time_since_activity >= (sending_give_up_after * peer.active_send_transfers)) {
|
||||||
// no ack after 30sec, close ft
|
// no ack after 30sec, close ft
|
||||||
std::cerr << "NGCFT1 warning: sending ft finishing timed out, deleting\n";
|
std::cerr << "NGCFT1 warning: sending ft finishing timed out, deleting\n";
|
||||||
dispatch(
|
dispatch(
|
||||||
|
|||||||
Reference in New Issue
Block a user