GRPC C++  1.26.0
Data Structures | Macros | Typedefs | Functions | Variables
completion_queue.h File Reference
#include <grpc/support/port_platform.h>
#include <grpc/grpc.h>
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/gprpp/manual_constructor.h"
#include "src/core/lib/iomgr/pollset.h"

Go to the source code of this file.

Data Structures

struct  grpc_cq_completion
 

Macros

#define GRPC_CQ_INTERNAL_REF(cc, reason)    grpc_cq_internal_ref(cc, reason, __FILE__, __LINE__)
 
#define GRPC_CQ_INTERNAL_UNREF(cc, reason)    grpc_cq_internal_unref(cc, reason, __FILE__, __LINE__)
 

Typedefs

typedef struct grpc_cq_completion grpc_cq_completion
 

Functions

void grpc_cq_internal_ref (grpc_completion_queue *cc, const char *reason, const char *file, int line)
 
void grpc_cq_internal_unref (grpc_completion_queue *cc, const char *reason, const char *file, int line)
 
void grpc_cq_global_init ()
 
bool grpc_cq_begin_op (grpc_completion_queue *cc, void *tag)
 
void grpc_cq_end_op (grpc_completion_queue *cc, void *tag, grpc_error *error, void(*done)(void *done_arg, grpc_cq_completion *storage), void *done_arg, grpc_cq_completion *storage, bool internal=false)
 
grpc_pollsetgrpc_cq_pollset (grpc_completion_queue *cc)
 
bool grpc_cq_can_listen (grpc_completion_queue *cc)
 
grpc_cq_completion_type grpc_get_cq_completion_type (grpc_completion_queue *cc)
 
int grpc_get_cq_poll_num (grpc_completion_queue *cc)
 
grpc_completion_queuegrpc_completion_queue_create_internal (grpc_cq_completion_type completion_type, grpc_cq_polling_type polling_type, grpc_experimental_completion_queue_functor *shutdown_callback)
 

Variables

grpc_core::TraceFlag grpc_cq_pluck_trace
 
grpc_core::TraceFlag grpc_trace_operation_failures
 
grpc_core::DebugOnlyTraceFlag grpc_trace_pending_tags
 
grpc_core::DebugOnlyTraceFlag grpc_trace_cq_refcount
 

Macro Definition Documentation

◆ GRPC_CQ_INTERNAL_REF

#define GRPC_CQ_INTERNAL_REF (   cc,
  reason 
)     grpc_cq_internal_ref(cc, reason, __FILE__, __LINE__)

◆ GRPC_CQ_INTERNAL_UNREF

#define GRPC_CQ_INTERNAL_UNREF (   cc,
  reason 
)     grpc_cq_internal_unref(cc, reason, __FILE__, __LINE__)

Typedef Documentation

◆ grpc_cq_completion

Function Documentation

◆ grpc_completion_queue_create_internal()

grpc_completion_queue* grpc_completion_queue_create_internal ( grpc_cq_completion_type  completion_type,
grpc_cq_polling_type  polling_type,
grpc_experimental_completion_queue_functor shutdown_callback 
)

◆ grpc_cq_begin_op()

bool grpc_cq_begin_op ( grpc_completion_queue cc,
void *  tag 
)

◆ grpc_cq_can_listen()

bool grpc_cq_can_listen ( grpc_completion_queue cc)

◆ grpc_cq_end_op()

void grpc_cq_end_op ( grpc_completion_queue cc,
void *  tag,
grpc_error error,
void(*)(void *done_arg, grpc_cq_completion *storage)  done,
void *  done_arg,
grpc_cq_completion storage,
bool  internal = false 
)

◆ grpc_cq_global_init()

void grpc_cq_global_init ( )

◆ grpc_cq_internal_ref()

void grpc_cq_internal_ref ( grpc_completion_queue cc,
const char *  reason,
const char *  file,
int  line 
)

◆ grpc_cq_internal_unref()

void grpc_cq_internal_unref ( grpc_completion_queue cc,
const char *  reason,
const char *  file,
int  line 
)

◆ grpc_cq_pollset()

grpc_pollset* grpc_cq_pollset ( grpc_completion_queue cc)

◆ grpc_get_cq_completion_type()

grpc_cq_completion_type grpc_get_cq_completion_type ( grpc_completion_queue cc)

◆ grpc_get_cq_poll_num()

int grpc_get_cq_poll_num ( grpc_completion_queue cc)

Variable Documentation

◆ grpc_cq_pluck_trace

grpc_core::TraceFlag grpc_cq_pluck_trace
extern

◆ grpc_trace_cq_refcount

grpc_core::DebugOnlyTraceFlag grpc_trace_cq_refcount
extern

◆ grpc_trace_operation_failures

grpc_core::TraceFlag grpc_trace_operation_failures
extern

◆ grpc_trace_pending_tags

grpc_core::DebugOnlyTraceFlag grpc_trace_pending_tags
extern