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_pollset *	grpc_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_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)

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

typedef struct grpc_cq_completion 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