@@ -1026,11 +1026,11 @@ class THttpMonInitializator : public TActorBootstrapped<THttpMonInitializator> {
1026
1026
class THttpMonAuthorizedActorRequest : public TActorBootstrapped <THttpMonAuthorizedActorRequest> {
1027
1027
public:
1028
1028
NHttp::TEvHttpProxy::TEvHttpIncomingRequest::TPtr Event;
1029
- TMon::TRegisterHandlerFields& Fields;
1029
+ TMon::TRegisterHandlerFields Fields;
1030
1030
TMon::TRequestAuthorizer Authorizer;
1031
1031
NHttp::TEvHttpProxy::TEvSubscribeForCancel::TPtr CancelSubscriber;
1032
1032
1033
- THttpMonAuthorizedActorRequest (NHttp::TEvHttpProxy::TEvHttpIncomingRequest::TPtr event, TMon::TRegisterHandlerFields& fields, TMon::TRequestAuthorizer authorizer)
1033
+ THttpMonAuthorizedActorRequest (NHttp::TEvHttpProxy::TEvHttpIncomingRequest::TPtr event, const TMon::TRegisterHandlerFields& fields, TMon::TRequestAuthorizer authorizer)
1034
1034
: Event(std::move(event))
1035
1035
, Fields(fields)
1036
1036
, Authorizer(std::move(authorizer))
@@ -1180,7 +1180,7 @@ class THttpMonAuthorizedActorRequest : public TActorBootstrapped<THttpMonAuthori
1180
1180
}
1181
1181
NHttp::THttpIncomingRequestPtr request = Event->Get ()->Request ;
1182
1182
ReplyWith (request->CreateResponseServiceUnavailable (
1183
- TStringBuilder () << " Auth actor is not available" ));
1183
+ TStringBuilder () << " Actor is not available" ));
1184
1184
PassAway ();
1185
1185
}
1186
1186
@@ -1223,18 +1223,14 @@ class THttpMonAuthorizedActorRequest : public TActorBootstrapped<THttpMonAuthori
1223
1223
CancelSubscriber = std::move (ev);
1224
1224
}
1225
1225
1226
- void Handle (NHttp::TEvHttpProxy::TEvRequestCancelled::TPtr& /* ev */ ) {
1227
- Cancelled ();
1228
- }
1229
-
1230
1226
STATEFN (StateWork) {
1231
1227
switch (ev->GetTypeRewrite ()) {
1232
1228
hFunc (TEvents::TEvUndelivered, HandleUndelivered);
1233
1229
hFunc (NKikimr::NGRpcService::TEvRequestAuthAndCheckResult, Handle);
1234
1230
hFunc (NHttp::TEvHttpProxy::TEvHttpOutgoingResponse, Handle);
1235
1231
hFunc (NHttp::TEvHttpProxy::TEvHttpOutgoingDataChunk, Handle);
1236
1232
hFunc (NHttp::TEvHttpProxy::TEvSubscribeForCancel, Handle);
1237
- hFunc (NHttp::TEvHttpProxy::TEvRequestCancelled, Handle );
1233
+ cFunc (NHttp::TEvHttpProxy::EvRequestCancelled, Cancelled );
1238
1234
}
1239
1235
}
1240
1236
};
0 commit comments