diff options
| author | hcpp <hcpp@ydb.tech> | 2022-07-29 15:58:14 +0300 |
|---|---|---|
| committer | hcpp <hcpp@ydb.tech> | 2022-07-29 15:58:14 +0300 |
| commit | 3608508401ee84efd4f8f44c6ca8fe423c6fecd6 (patch) | |
| tree | 69f5feac8157f924763f79f5b0a8a899b197271d | |
| parent | 831210a6f3a348d8059aaa223c39931c51528ecc (diff) | |
| download | ydb-3608508401ee84efd4f8f44c6ca8fe423c6fecd6.tar.gz | |
test connection has been fixed
| -rw-r--r-- | ydb/core/yq/libs/test_connection/test_monitoring.cpp | 16 | ||||
| -rw-r--r-- | ydb/core/yq/libs/test_connection/test_object_storage.cpp | 6 |
2 files changed, 15 insertions, 7 deletions
diff --git a/ydb/core/yq/libs/test_connection/test_monitoring.cpp b/ydb/core/yq/libs/test_connection/test_monitoring.cpp index cd5b4d4f852..400e85cabe8 100644 --- a/ydb/core/yq/libs/test_connection/test_monitoring.cpp +++ b/ydb/core/yq/libs/test_connection/test_monitoring.cpp @@ -63,12 +63,16 @@ public: TC_LOG_D(Scope << " " << User << " " << NKikimr::MaskTicket(Token) << " Starting test monitoring connection actor. Actor id: " << SelfId()); Become(&TTestMonitoringConnectionActor::StateFunc); - HttpProxyId = Register(NHttp::CreateHttpProxy(NMonitoring::TMetricRegistry::SharedInstance())); - const NHttp::THttpOutgoingRequestPtr httpRequest = BuildSolomonRequest(); - auto retryPolicy = NYql::NDq::THttpSenderRetryPolicy::GetNoRetryPolicy(); - const TActorId httpSenderId = Register(NYql::NDq::CreateHttpSenderActor(SelfId(), HttpProxyId, retryPolicy)); - Send(httpSenderId, new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest(httpRequest), /*flags=*/0, Cookie); - TC_LOG_T(Scope << " " << User << " " << NKikimr::MaskTicket(Token) << " send request " << httpRequest->Method << " " << httpRequest->Protocol << " " << httpRequest->Host << " " << httpRequest->URL << " " << httpRequest->Body); + try { + HttpProxyId = Register(NHttp::CreateHttpProxy(NMonitoring::TMetricRegistry::SharedInstance())); + const NHttp::THttpOutgoingRequestPtr httpRequest = BuildSolomonRequest(); + auto retryPolicy = NYql::NDq::THttpSenderRetryPolicy::GetNoRetryPolicy(); + const TActorId httpSenderId = Register(NYql::NDq::CreateHttpSenderActor(SelfId(), HttpProxyId, retryPolicy)); + Send(httpSenderId, new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest(httpRequest), /*flags=*/0, Cookie); + TC_LOG_T(Scope << " " << User << " " << NKikimr::MaskTicket(Token) << " send request " << httpRequest->Method << " " << httpRequest->Protocol << " " << httpRequest->Host << " " << httpRequest->URL << " " << httpRequest->Body); + } catch (...) { + ReplyError(CurrentExceptionMessage()); + } } void FillAuth(NHttp::THttpOutgoingRequestPtr& httpRequest) { diff --git a/ydb/core/yq/libs/test_connection/test_object_storage.cpp b/ydb/core/yq/libs/test_connection/test_object_storage.cpp index 80832654cf4..00585993f55 100644 --- a/ydb/core/yq/libs/test_connection/test_object_storage.cpp +++ b/ydb/core/yq/libs/test_connection/test_object_storage.cpp @@ -94,7 +94,11 @@ public: void Bootstrap() { Become(&TTestObjectStorageConnectionActor::StateFunc); TC_LOG_D(Scope << " " << User << " " << NKikimr::MaskTicket(Token) << " Starting test object storage connection actor. Actor id: " << SelfId()); - SendDiscover(); + try { + SendDiscover(); + } catch (...) { + ReplyError(CurrentExceptionMessage()); + } } STRICT_STFUNC(StateFunc, |