Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
yegorskii committed Feb 6, 2025
1 parent e1ff782 commit 51b3ffc
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
6 changes: 3 additions & 3 deletions cloud/storage/core/libs/hive_proxy/hive_proxy_actor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -237,11 +237,11 @@ void THiveProxyActor::HandleConnect(
auto error = MakeKikimrError(msg->Status, TStringBuilder()
<< "Connect to hive " << hive << " failed");
HandleConnectionError(ctx, error, hive, true);
} else if (HiveReconnectStartCycles)
{
} else if (HiveReconnectStartCycles) {
if (HiveReconnectTimeCounter) {
HiveReconnectTimeCounter->Add(
CyclesToDuration(GetCycleCount() - HiveReconnectStartCycles).MicroSeconds());
CyclesToDuration(
GetCycleCount() - HiveReconnectStartCycles).MicroSeconds());
}
HiveReconnectStartCycles = 0;
HiveDisconnected = false;
Expand Down
3 changes: 2 additions & 1 deletion cloud/storage/core/libs/hive_proxy/hive_proxy_ut.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -514,7 +514,8 @@ struct TTestEnv
};
HiveProxyActorId = Runtime.Register(
CreateHiveProxy(
std::move(config), Runtime.GetAppData(0).Counters).release());
std::move(config),
Runtime.GetAppData(0).Counters).release());
Runtime.EnableScheduleForActor(HiveProxyActorId);
Runtime.RegisterService(MakeHiveProxyServiceId(), HiveProxyActorId);
}
Expand Down

0 comments on commit 51b3ffc

Please sign in to comment.