#include <grpc/support/port_platform.h>
#include <stdint.h>
#include <grpc/impl/codegen/grpc_types.h>
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/gprpp/manual_constructor.h"
#include "src/core/lib/gprpp/mpscq.h"
#include "src/core/lib/iomgr/error.h"
#include "src/core/lib/iomgr/pollset.h"

Include dependency graph for src/core/lib/surface/completion_queue.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	grpc_cq_completion

Macros
#define	GRPC_CQ_INTERNAL_REF(cq, reason) grpc_cq_internal_ref(cq, reason, __FILE__, __LINE__)

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

Typedefs
typedef struct grpc_cq_completion	grpc_cq_completion

Functions
grpc_completion_queue *	grpc_completion_queue_create_internal (grpc_cq_completion_type completion_type, grpc_cq_polling_type polling_type, grpc_completion_queue_functor *shutdown_callback)

bool	grpc_cq_begin_op (grpc_completion_queue cq, void tag)

bool	grpc_cq_can_listen (grpc_completion_queue *cq)

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

void	grpc_cq_global_init ()

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

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

grpc_pollset *	grpc_cq_pollset (grpc_completion_queue *cq)

grpc_cq_completion_type	grpc_get_cq_completion_type (grpc_completion_queue *cq)

int	grpc_get_cq_poll_num (grpc_completion_queue *cq)

Variables
grpc_core::TraceFlag	grpc_cq_pluck_trace

grpc_core::DebugOnlyTraceFlag	grpc_trace_cq_refcount

grpc_core::TraceFlag	grpc_trace_operation_failures

grpc_core::DebugOnlyTraceFlag	grpc_trace_pending_tags

Macro Definition Documentation

◆ GRPC_CQ_INTERNAL_REF

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

Definition at line 63 of file src/core/lib/surface/completion_queue.h.

◆ GRPC_CQ_INTERNAL_UNREF

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

Definition at line 65 of file src/core/lib/surface/completion_queue.h.

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_completion_queue_functor *	shutdown_callback
	)

Definition at line 514 of file completion_queue.cc.

◆ grpc_cq_begin_op()

bool grpc_cq_begin_op	(	grpc_completion_queue *	cq,
		void *	tag
	)

Definition at line 672 of file completion_queue.cc.

◆ grpc_cq_can_listen()

bool grpc_cq_can_listen ( grpc_completion_queue * cq )

Definition at line 1437 of file completion_queue.cc.

◆ grpc_cq_end_op()

void grpc_cq_end_op	(	grpc_completion_queue *	cq,
		void *	tag,
		grpc_error_handle	error,
		void()(void done_arg, grpc_cq_completion *storage)	done,
		void *	done_arg,
		grpc_cq_completion *	storage,
		bool	internal = `false`
	)

Definition at line 894 of file completion_queue.cc.

◆ grpc_cq_global_init()

void grpc_cq_global_init ( )

Definition at line 450 of file completion_queue.cc.

◆ grpc_cq_internal_ref()

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

Definition at line 594 of file completion_queue.cc.

◆ grpc_cq_internal_unref()

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

Definition at line 611 of file completion_queue.cc.

◆ grpc_cq_pollset()

grpc_pollset* grpc_cq_pollset ( grpc_completion_queue * cq )

Definition at line 1433 of file completion_queue.cc.

◆ grpc_get_cq_completion_type()

grpc_cq_completion_type grpc_get_cq_completion_type ( grpc_completion_queue * cq )

Definition at line 581 of file completion_queue.cc.

◆ grpc_get_cq_poll_num()

int grpc_get_cq_poll_num ( grpc_completion_queue * cq )

Definition at line 585 of file completion_queue.cc.

Variable Documentation

◆ grpc_cq_pluck_trace

grpc_core::TraceFlag grpc_cq_pluck_trace

◆ grpc_trace_cq_refcount

grpc_core::DebugOnlyTraceFlag grpc_trace_cq_refcount

◆ grpc_trace_operation_failures

grpc_core::TraceFlag grpc_trace_operation_failures

◆ grpc_trace_pending_tags

grpc_core::DebugOnlyTraceFlag grpc_trace_pending_tags

Classes

Macros

Typedefs

Functions

Variables