#include <grpcpp/completion_queue.h>

#include <memory>

#include <grpc/grpc.h>

#include <grpc/support/log.h>

#include <grpcpp/impl/grpc_library.h>

#include <grpcpp/support/time.h>

namespace grpc {

static internal::GrpcLibraryInitializer g_gli_initializer;

CompletionQueue::CompletionQueue(grpc_completion_queue* take)

: GrpcLibraryCodegen(false), cq_(take) {

InitialAvalanching();

}

void CompletionQueue::Shutdown() {

g_gli_initializer.summon();

CompleteAvalanching();

}

void CompletionQueue::CompleteAvalanching() {

}

CompletionQueue::NextStatus CompletionQueue::AsyncNextInternal(

}

CompletionQueue::CompletionQueueTLSCache::CompletionQueueTLSCache(

CompletionQueue* cq)

: cq_(cq), flushed_(false) {

grpc_completion_queue_thread_local_cache_init(cq_->cq_);

}

CompletionQueue::CompletionQueueTLSCache::~CompletionQueueTLSCache() {

GPR_ASSERT(flushed_);

}

bool CompletionQueue::CompletionQueueTLSCache::Flush(void** tag, bool* ok) {

int res = 0;

void* res_tag;

flushed_ = true;

if (grpc_completion_queue_thread_local_cache_flush(cq_->cq_, &res_tag,

&res)) {

auto cq_tag = static_cast<internal::CompletionQueueTag*>(res_tag);

*ok = res == 1;

if (cq_tag->FinalizeResult(tag, ok)) {

return true;

}

}

return false;

}

} // namespace grpc