|
|
@ -153,9 +153,7 @@ static void shutdown_and_destroy(grpc_completion_queue* cc) { |
|
|
|
// Tag completion queue iterate times
|
|
|
|
// Tag completion queue iterate times
|
|
|
|
class TagCallback : public grpc_experimental_completion_queue_functor { |
|
|
|
class TagCallback : public grpc_experimental_completion_queue_functor { |
|
|
|
public: |
|
|
|
public: |
|
|
|
TagCallback(int* iter) : iter_ (iter) { |
|
|
|
TagCallback(int* iter) : iter_(iter) { functor_run = &TagCallback::Run; } |
|
|
|
functor_run = &TagCallback::Run; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
~TagCallback() {} |
|
|
|
~TagCallback() {} |
|
|
|
static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { |
|
|
|
static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { |
|
|
|
GPR_ASSERT(static_cast<bool>(ok)); |
|
|
|
GPR_ASSERT(static_cast<bool>(ok)); |
|
|
|