@@ -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))
@@ -1163,8 +1163,6 @@ class THttpMonAuthorizedActorRequest : public TActorBootstrapped<THttpMonAuthori
1163
1163
Event->Get ()->UserToken = result->UserToken ->GetSerializedToken ();
1164
1164
}
1165
1165
Send (new IEventHandle (Fields.Handler , SelfId (), Event->ReleaseBase ().Release (), IEventHandle::FlagTrackDelivery, Event->Cookie ));
1166
-
1167
- PassAway ();
1168
1166
}
1169
1167
1170
1168
void Cancelled () {
@@ -1180,7 +1178,7 @@ class THttpMonAuthorizedActorRequest : public TActorBootstrapped<THttpMonAuthori
1180
1178
}
1181
1179
NHttp::THttpIncomingRequestPtr request = Event->Get ()->Request ;
1182
1180
ReplyWith (request->CreateResponseServiceUnavailable (
1183
- TStringBuilder () << " Auth actor is not available" ));
1181
+ TStringBuilder () << " Actor is not available" ));
1184
1182
PassAway ();
1185
1183
}
1186
1184
@@ -1223,18 +1221,14 @@ class THttpMonAuthorizedActorRequest : public TActorBootstrapped<THttpMonAuthori
1223
1221
CancelSubscriber = std::move (ev);
1224
1222
}
1225
1223
1226
- void Handle (NHttp::TEvHttpProxy::TEvRequestCancelled::TPtr& /* ev */ ) {
1227
- Cancelled ();
1228
- }
1229
-
1230
1224
STATEFN (StateWork) {
1231
1225
switch (ev->GetTypeRewrite ()) {
1232
1226
hFunc (TEvents::TEvUndelivered, HandleUndelivered);
1233
1227
hFunc (NKikimr::NGRpcService::TEvRequestAuthAndCheckResult, Handle);
1234
1228
hFunc (NHttp::TEvHttpProxy::TEvHttpOutgoingResponse, Handle);
1235
1229
hFunc (NHttp::TEvHttpProxy::TEvHttpOutgoingDataChunk, Handle);
1236
1230
hFunc (NHttp::TEvHttpProxy::TEvSubscribeForCancel, Handle);
1237
- hFunc (NHttp::TEvHttpProxy::TEvRequestCancelled, Handle );
1231
+ cFunc (NHttp::TEvHttpProxy::EvRequestCancelled, Cancelled );
1238
1232
}
1239
1233
}
1240
1234
};
0 commit comments