procxx
/
kepka
mirror of https://github.com/procxx/kepka.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Optimize unixtime refresh.

This commit is contained in:
John Preston 2019-10-02 11:14:38 +03:00
parent 9bf8b619fe
commit 2cb7d76417
2 changed files with 30 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
Telegram/SourceFiles/mtproto/config_loader.cpp
View File

@ -129,7 +129,11 @@ void ConfigLoader::createSpecialLoader() {
const std::string &ip,
int port,
bytes::const_span secret) {
addSpecialEndpoint(dcId, ip, port, secret);
if (ip.empty()) {
_specialLoader = nullptr;
} else {
addSpecialEndpoint(dcId, ip, port, secret);
}
}, _phone);
}

40
Telegram/SourceFiles/mtproto/special_config_request.cpp
View File

@ -374,19 +374,22 @@ SpecialConfigRequest::SpecialConfigRequest(
while (!domains.empty()) {
_attempts.push_back({ Type::Google, takeDomain(), "dns" });
}
_attempts.push_back({ Type::Realtime, "firebaseio.com" });
_attempts.push_back({ Type::FireStore, "firestore" });
for (const auto &domain : DnsDomains()) {
_attempts.push_back({ Type::FireStore, domain, "firestore" });
if (!_timeDoneCallback) {
_attempts.push_back({ Type::Realtime, "firebaseio.com" });
_attempts.push_back({ Type::FireStore, "firestore" });
for (const auto &domain : DnsDomains()) {
_attempts.push_back({ Type::FireStore, domain, "firestore" });
}
}
shuffle(0, 2);
shuffle(2, 4);
shuffle(
_attempts.size() - (2 + domainsCount),
_attempts.size() - domainsCount);
shuffle(_attempts.size() - domainsCount, _attempts.size());
if (!_timeDoneCallback) {
shuffle(
_attempts.size() - (2 + domainsCount),
_attempts.size() - domainsCount);
shuffle(_attempts.size() - domainsCount, _attempts.size());
}
ranges::reverse(_attempts); // We go from last to first.
sendNextRequest();
@ -666,20 +669,27 @@ void SpecialConfigRequest::handleResponse(const QByteArray &bytes) {
switch (address.type()) {
case mtpc_ipPort: {
const auto &fields = address.c_ipPort();
_callback(dcId, parseIp(fields.vipv4()), fields.vport().v, {});
const auto ip = parseIp(fields.vipv4());
if (!ip.empty()) {
_callback(dcId, ip, fields.vport().v, {});
}
} break;
case mtpc_ipPortSecret: {
const auto &fields = address.c_ipPortSecret();
_callback(
dcId,
parseIp(fields.vipv4()),
fields.vport().v,
bytes::make_span(fields.vsecret().v));
const auto ip = parseIp(fields.vipv4());
if (!ip.empty()) {
_callback(
dcId,
ip,
fields.vport().v,
bytes::make_span(fields.vsecret().v));
}
} break;
default: Unexpected("Type in simpleConfig ips.");
}
}
}
_callback(0, std::string(), 0, {});
}
DomainResolver::DomainResolver(Fn<void(