tdlight-team/tdlight
tdlight-team/tdlight
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Calculate rtt in new Ping

Browse Source 
GitOrigin-RevId: 9d4ef780ac99ea6c1331dc4e93014657a27f7848
This commit is contained in:
Arseny Smirnov 2019-05-09 20:13:40 +02:00
parent ef4f719563
commit 3f4b29bfaf
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
td/mtproto/PingConnection.cpp
View File

@ -83,7 +83,8 @@ class PingConnectionPingPong
private: private:
unique_ptr<mtproto::AuthData> auth_data_; unique_ptr<mtproto::AuthData> auth_data_;
unique_ptr<mtproto::SessionConnection> connection_; unique_ptr<mtproto::SessionConnection> connection_;
bool was_pong_{false}; int pong_cnt_{0};
double rtt_;
bool is_closed_{false}; bool is_closed_{false};
Status status_; Status status_;
void on_connected() override { void on_connected() override {
@ -113,7 +114,13 @@ class PingConnectionPingPong
void on_container_sent(uint64 container_id, vector<uint64> msgs_id) override { void on_container_sent(uint64 container_id, vector<uint64> msgs_id) override {
} }
Status on_pong() override { Status on_pong() override {
was_pong_ = true; pong_cnt_++;
if (pong_cnt_ == 1) {
rtt_ = Time::now();
connection_->set_online(false, false);
} else if (pong_cnt_ == 2) {
rtt_ = Time::now() - rtt_;
}
return Status::OK(); return Status::OK();
} }
@ -141,7 +148,7 @@ class PingConnectionPingPong
return connection_->move_as_raw_connection(); return connection_->move_as_raw_connection();
} }
Status flush() override { Status flush() override {
if (was_pong_) { if (was_pong()) {
return Status::OK(); return Status::OK();
} }
connection_->flush(this); connection_->flush(this);
@ -151,10 +158,10 @@ class PingConnectionPingPong
return Status::OK(); return Status::OK();
} }
bool was_pong() const override { bool was_pong() const override {
return was_pong_; return pong_cnt_ >= 2;
} }
double rtt() const override { double rtt() const override {
return 1; return rtt_;
} }
}; };