database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[enhancement](frontendservice) add retry when create connection to frontend service (#15635)

Browse Source
This commit is contained in:
Zhengguo Yang
2023-01-06 09:15:08 +08:00
committed by GitHub
parent 95f2f43c02
commit b41934864e
1 changed files with 16 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
be/src/runtime/client_cache.h
View File

@ -149,22 +149,25 @@ template <class T>
class ClientConnection {
public:
ClientConnection(ClientCache<T>* client_cache, const TNetworkAddress& address, Status* status)
: _client_cache(client_cache), _client(nullptr) {
*status = _client_cache->get_client(address, &_client, 0);
if (status->ok()) {
DCHECK(_client != nullptr);
}
}
: ClientConnection(client_cache, address, 0, status, 3) {}
ClientConnection(ClientCache<T>* client_cache, const TNetworkAddress& address, int timeout_ms,
Status* status)
Status* status, int max_retries = 3)
: _client_cache(client_cache), _client(nullptr) {
*status = _client_cache->get_client(address, &_client, timeout_ms);
if (status->ok()) {
DCHECK(_client != nullptr);
}
int num_retries = 0;
do {
*status = _client_cache->get_client(address, &_client, timeout_ms);
if (status->ok()) {
DCHECK(_client != nullptr);
break;
}
if (num_retries++ < max_retries) {
// exponential backoff retry with starting delay of 500ms
usleep(500000 * (1 << num_retries));
LOG(INFO) << "Failed to get client from cache: " << status->to_string()
<< ", retrying[" << num_retries << "]...";
}
} while (num_retries < max_retries);
}
~ClientConnection() {