diff --git a/src/core/lib/surface/completion_queue.c b/src/core/lib/surface/completion_queue.c index 172354c6188..b0a4b1fbcca 100644 --- a/src/core/lib/surface/completion_queue.c +++ b/src/core/lib/surface/completion_queue.c @@ -837,23 +837,15 @@ static grpc_event cq_next(grpc_completion_queue *cc, gpr_timespec deadline, dump_pending_tags(cc); break; } -<<<<<<< HEAD /* The main polling work happens in grpc_pollset_work */ gpr_mu_lock(cqd->mu); cqd->num_polls++; -======= - cc->num_polls++; ->>>>>>> 21322dec78b4c8db45a4bcd2919b4961b7d31a5c grpc_error *err = cc->poller_vtable->work(&exec_ctx, POLLSET_FROM_CQ(cc), NULL, now, iteration_deadline); gpr_mu_unlock(cqd->mu); if (err != GRPC_ERROR_NONE) { -<<<<<<< HEAD -======= - gpr_mu_unlock(cc->mu); ->>>>>>> 21322dec78b4c8db45a4bcd2919b4961b7d31a5c const char *msg = grpc_error_string(err); gpr_log(GPR_ERROR, "Completion queue next failed: %s", msg); @@ -1033,25 +1025,15 @@ static grpc_event cq_pluck(grpc_completion_queue *cc, void *tag, dump_pending_tags(cc); break; } -<<<<<<< HEAD cqd->num_polls++; -======= - cc->num_polls++; ->>>>>>> 21322dec78b4c8db45a4bcd2919b4961b7d31a5c grpc_error *err = cc->poller_vtable->work(&exec_ctx, POLLSET_FROM_CQ(cc), &worker, now, deadline); if (err != GRPC_ERROR_NONE) { del_plucker(cc, tag, &worker); -<<<<<<< HEAD gpr_mu_unlock(cqd->mu); const char *msg = grpc_error_string(err); gpr_log(GPR_ERROR, "Completion queue pluck failed: %s", msg); -======= - gpr_mu_unlock(cc->mu); - const char *msg = grpc_error_string(err); - gpr_log(GPR_ERROR, "Completion queue next failed: %s", msg); ->>>>>>> 21322dec78b4c8db45a4bcd2919b4961b7d31a5c GRPC_ERROR_UNREF(err); memset(&ret, 0, sizeof(ret));