Skip to content

Commit 5e27150

Browse files
qyryqGazizonoki
authored andcommitted
Moved "ydb_topic: Create TClientMessage only if there's a new token" commit from ydb repo
1 parent 2f1f994 commit 5e27150

File tree

1 file changed

+10
-7
lines changed

1 file changed

+10
-7
lines changed

src/client/topic/impl/write_session_impl.cpp

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1289,19 +1289,22 @@ void TWriteSessionImpl::UpdateTokenIfNeededImpl() {
12891289

12901290
LOG_LAZY(DbDriverState->Log, TLOG_DEBUG, LogPrefix() << "Write session: try to update token");
12911291

1292-
if (!DbDriverState->CredentialsProvider || UpdateTokenInProgress || !SessionEstablished)
1292+
if (!DbDriverState->CredentialsProvider || UpdateTokenInProgress || !SessionEstablished) {
12931293
return;
1294-
TClientMessage clientMessage;
1295-
auto* updateRequest = clientMessage.mutable_update_token_request();
1294+
}
1295+
12961296
auto token = DbDriverState->CredentialsProvider->GetAuthInfo();
1297-
if (token == PrevToken)
1297+
if (token == PrevToken) {
12981298
return;
1299-
UpdateTokenInProgress = true;
1300-
updateRequest->set_token(token);
1301-
PrevToken = token;
1299+
}
13021300

13031301
LOG_LAZY(DbDriverState->Log, TLOG_DEBUG, LogPrefix() << "Write session: updating token");
13041302

1303+
UpdateTokenInProgress = true;
1304+
PrevToken = token;
1305+
1306+
TClientMessage clientMessage;
1307+
clientMessage.mutable_update_token_request()->set_token(token);
13051308
Processor->Write(std::move(clientMessage));
13061309
}
13071310

0 commit comments

Comments
 (0)