diff options
| author | azevaykin <azevaykin@yandex-team.com> | 2023-06-26 19:15:45 +0300 |
|---|---|---|
| committer | azevaykin <azevaykin@yandex-team.com> | 2023-06-26 19:15:45 +0300 |
| commit | b90b4affbe58ed6d40eb861d8fcb1eff2801b016 (patch) | |
| tree | 346958ddf92d97530f444ef4197bc04ffba5d42e | |
| parent | 501684a88ec52f39cf7ba0f94ed07b9984069788 (diff) | |
| download | ydb-b90b4affbe58ed6d40eb861d8fcb1eff2801b016.tar.gz | |
Additional logs
| -rw-r--r-- | ydb/core/client/server/msgbus_server_persqueue.cpp | 7 | ||||
| -rw-r--r-- | ydb/core/testlib/test_pq_client.h | 4 | ||||
| -rw-r--r-- | ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/ut_utils/test_server.cpp | 1 |
3 files changed, 8 insertions, 4 deletions
diff --git a/ydb/core/client/server/msgbus_server_persqueue.cpp b/ydb/core/client/server/msgbus_server_persqueue.cpp index 4b50015800..bb6a280b04 100644 --- a/ydb/core/client/server/msgbus_server_persqueue.cpp +++ b/ydb/core/client/server/msgbus_server_persqueue.cpp @@ -190,10 +190,11 @@ void TPersQueueBaseRequestProcessor::AnswerAndDie(const TActorContext& ctx) { } void TPersQueueBaseRequestProcessor::Bootstrap(const TActorContext& ctx) { - LOG_INFO_S(ctx, NKikimrServices::PERSQUEUE, "proxy got request " << RequestId); - StartTimestamp = ctx.Now(); - ctx.Send(PqMetaCache, new NPqMetaCacheV2::TEvPqNewMetaCache::TEvDescribeAllTopicsRequest()); + + LOG_TRACE_S(ctx, NKikimrServices::PERSQUEUE, "Send to PqMetaCache TEvDescribeAllTopicsRequest"); + bool ret = ctx.Send(PqMetaCache, new NPqMetaCacheV2::TEvPqNewMetaCache::TEvDescribeAllTopicsRequest()); + LOG_TRACE_S(ctx, NKikimrServices::PERSQUEUE, "Send to PqMetaCache TEvDescribeAllTopicsRequest Result:" << ret); if (ListNodes) { const TActorId nameserviceId = GetNameserviceActorId(); diff --git a/ydb/core/testlib/test_pq_client.h b/ydb/core/testlib/test_pq_client.h index c742c8aede..a07f4c03c7 100644 --- a/ydb/core/testlib/test_pq_client.h +++ b/ydb/core/testlib/test_pq_client.h @@ -546,6 +546,8 @@ public: auto channel = grpc::CreateCustomChannel(endpoint, grpc::InsecureChannelCredentials(), args); Stub = NKikimrClient::TGRpcServer::NewStub(channel); + + Cerr << "PQClient connected to " << endpoint << Endl; } ~TFlatMsgBusPQClient() { @@ -811,7 +813,7 @@ public: } NKikimrClient::TResponse CallPersQueueGRPC(const NKikimrClient::TPersQueueRequest& request, ui64 maxPrintSize = 1000) { - Cerr << "CallPersQueueGRPC request to " << Client->GetConfig().Ip << ":" << Client->GetConfig().Port << "\n" + Cerr << "CallPersQueueGRPC request to localhost:" << GRpcPort << "\n" << PrintToString(request, maxPrintSize) << Endl; NKikimrClient::TResponse response; diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/ut_utils/test_server.cpp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/ut_utils/test_server.cpp index b2f89ed32e..673d564aae 100644 --- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/ut_utils/test_server.cpp +++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/ut_utils/test_server.cpp @@ -6,6 +6,7 @@ const TVector<NKikimrServices::EServiceKikimr> TTestServer::LOGGED_SERVICES = { NKikimrServices::PQ_READ_PROXY, NKikimrServices::PQ_WRITE_PROXY, NKikimrServices::PQ_MIRRORER, + NKikimrServices::PQ_METACACHE, NKikimrServices::PERSQUEUE }; |