|
|
@ -42,8 +42,6 @@ |
|
|
|
#include <grpc++/impl/codegen/service_type.h> |
|
|
|
#include <grpc++/impl/codegen/service_type.h> |
|
|
|
#include <grpc++/impl/codegen/status.h> |
|
|
|
#include <grpc++/impl/codegen/status.h> |
|
|
|
|
|
|
|
|
|
|
|
extern "C" void* grpc_call_arena_alloc(grpc_call* call, size_t size); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
namespace grpc { |
|
|
|
namespace grpc { |
|
|
|
|
|
|
|
|
|
|
|
class CompletionQueue; |
|
|
|
class CompletionQueue; |
|
|
@ -69,7 +67,8 @@ class ClientAsyncResponseReader final |
|
|
|
const W& request) { |
|
|
|
const W& request) { |
|
|
|
Call call = channel->CreateCall(method, context, cq); |
|
|
|
Call call = channel->CreateCall(method, context, cq); |
|
|
|
ClientAsyncResponseReader* reader = |
|
|
|
ClientAsyncResponseReader* reader = |
|
|
|
new (grpc_call_arena_alloc(call.call(), sizeof(*reader))) |
|
|
|
new (g_core_codegen_interface->grpc_call_arena_alloc(call.call(), |
|
|
|
|
|
|
|
sizeof(*reader))) |
|
|
|
ClientAsyncResponseReader(call, context); |
|
|
|
ClientAsyncResponseReader(call, context); |
|
|
|
|
|
|
|
|
|
|
|
reader->init_buf_.SendInitialMetadata(context->send_initial_metadata_, |
|
|
|
reader->init_buf_.SendInitialMetadata(context->send_initial_metadata_, |
|
|
|