diff options
Diffstat (limited to 'library/cpp/unified_agent_client/grpc_io.cpp')
| -rw-r--r-- | library/cpp/unified_agent_client/grpc_io.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/library/cpp/unified_agent_client/grpc_io.cpp b/library/cpp/unified_agent_client/grpc_io.cpp index 6d237d75ec..815f34f1cf 100644 --- a/library/cpp/unified_agent_client/grpc_io.cpp +++ b/library/cpp/unified_agent_client/grpc_io.cpp @@ -1,5 +1,6 @@ #include "grpc_io.h" +#include <contrib/libs/grpc/src/core/lib/iomgr/exec_ctx.h> #include <contrib/libs/grpc/src/core/lib/iomgr/executor.h> #include <contrib/libs/grpc/src/core/lib/surface/completion_queue.h> #include <contrib/libs/grpc/include/grpc/impl/codegen/log.h> @@ -36,7 +37,7 @@ namespace NUnifiedAgent { grpc_core::ExecCtx execCtx; IOCallback->Ref(); Y_VERIFY(grpc_cq_begin_op(CompletionQueue.cq(), this)); - grpc_cq_end_op(CompletionQueue.cq(), this, nullptr, + grpc_cq_end_op(CompletionQueue.cq(), this, GRPC_ERROR_NONE, [](void* self, grpc_cq_completion*) { Y_VERIFY(static_cast<TGrpcNotification*>(self)->InQueue.exchange(false)); }, |