Skip to content

Commit 5b8e16c

Browse files
committed
process NVMe devices in Idle state
1 parent ab87329 commit 5b8e16c

File tree

2 files changed

+27
-0
lines changed

2 files changed

+27
-0
lines changed

cloud/blockstore/libs/storage/disk_agent/disk_agent_actor.cpp

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -435,6 +435,18 @@ STFUNC(TDiskAgentActor::StateIdle)
435435

436436
BLOCKSTORE_HANDLE_REQUEST(WaitReady, TEvDiskAgent)
437437

438+
HFunc(
439+
TEvDiskAgentPrivate::TListNVMeDevicesRequest,
440+
HandleListNVMeDevicesRequest);
441+
442+
HFunc(
443+
TEvDiskAgentPrivate::TAcquireNVMeDeviceRequest,
444+
HandleAcquireNVMeDeviceRequest);
445+
446+
HFunc(
447+
TEvDiskAgentPrivate::TReleaseNVMeDeviceRequest,
448+
HandleReleaseNVMeDeviceRequest);
449+
438450
default:
439451
if (!RejectRequests(ev)) {
440452
auto ctx = ActorContext();

cloud/blockstore/libs/storage/service/service_actor_actions_local_nvme_devices.cpp

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,11 @@ void TLocalNVMeDeviceOpsActor::HandleListNVMeDevicesUndelivery(
130130
{
131131
Y_UNUSED(ev);
132132

133+
LOG_WARN(
134+
ctx,
135+
TBlockStoreComponents::SERVICE,
136+
"List NVMe devices request undelivered");
137+
133138
auto response = std::make_unique<TEvService::TEvExecuteActionResponse>(
134139
MakeError(E_PRECONDITION_FAILED, "Local Disk Agent not found"));
135140
NCloud::Reply(ctx, *RequestInfo, std::move(response));
@@ -156,6 +161,11 @@ void TLocalNVMeDeviceOpsActor::HandleAcquireNVMeDeviceUndelivery(
156161
{
157162
Y_UNUSED(ev);
158163

164+
LOG_WARN(
165+
ctx,
166+
TBlockStoreComponents::SERVICE,
167+
"Acquire NVMe device request undelivered");
168+
159169
auto response = std::make_unique<TEvService::TEvExecuteActionResponse>(
160170
MakeError(E_PRECONDITION_FAILED, "Local Disk Agent not found"));
161171
NCloud::Reply(ctx, *RequestInfo, std::move(response));
@@ -181,6 +191,11 @@ void TLocalNVMeDeviceOpsActor::HandleReleaseNVMeDeviceUndelivery(
181191
{
182192
Y_UNUSED(ev);
183193

194+
LOG_WARN(
195+
ctx,
196+
TBlockStoreComponents::SERVICE,
197+
"Release NVMe device request undelivered");
198+
184199
auto response = std::make_unique<TEvService::TEvExecuteActionResponse>(
185200
MakeError(E_PRECONDITION_FAILED, "Local Disk Agent not found"));
186201
NCloud::Reply(ctx, *RequestInfo, std::move(response));

0 commit comments

Comments
 (0)