completion_queue_factory.cc File Reference

#include <grpc/support/port_platform.h>
#include "src/core/lib/surface/completion_queue_factory.h"
#include <grpc/grpc.h>
#include <grpc/support/log.h>
#include "src/core/lib/surface/completion_queue.h"

Include dependency graph for completion_queue_factory.cc:

Go to the source code of this file.

Functions
static grpc_completion_queue *	default_create (const grpc_completion_queue_factory *, const grpc_completion_queue_attributes *attr)
grpc_completion_queue *	grpc_completion_queue_create (const grpc_completion_queue_factory *factory, const grpc_completion_queue_attributes *attr, void *reserved)
grpc_completion_queue *	grpc_completion_queue_create_for_callback (grpc_completion_queue_functor *shutdown_callback, void *reserved)
grpc_completion_queue *	grpc_completion_queue_create_for_next (void *reserved)
grpc_completion_queue *	grpc_completion_queue_create_for_pluck (void *reserved)
const grpc_completion_queue_factory *	grpc_completion_queue_factory_lookup (const grpc_completion_queue_attributes *attributes)

Variables
static grpc_completion_queue_factory_vtable	default_vtable = {default_create}
static const grpc_completion_queue_factory	g_default_cq_factory

Function Documentation

default_create()

static grpc_completion_queue* default_create ( const grpc_completion_queue_factory *  , const grpc_completion_queue_attributes *  attr  )

static

Definition at line 32 of file completion_queue_factory.cc.

grpc_completion_queue_create()

grpc_completion_queue* grpc_completion_queue_create	(	const grpc_completion_queue_factory *	factory,
		const grpc_completion_queue_attributes *	attributes,
		void *	reserved
	)

Create a completion queue

Definition at line 84 of file completion_queue_factory.cc.

grpc_completion_queue_create_for_callback()

grpc_completion_queue* grpc_completion_queue_create_for_callback	(	grpc_completion_queue_functor *	shutdown_callback,
		void *	reserved
	)

Helper function to create a completion queue with grpc_cq_completion_type of GRPC_CQ_CALLBACK and grpc_cq_polling_type of GRPC_CQ_DEFAULT_POLLING. This function is experimental.

Definition at line 76 of file completion_queue_factory.cc.

grpc_completion_queue_create_for_next()

grpc_completion_queue* grpc_completion_queue_create_for_next

(

void *

reserved

)

Helper function to create a completion queue with grpc_cq_completion_type of GRPC_CQ_NEXT and grpc_cq_polling_type of GRPC_CQ_DEFAULT_POLLING

Definition at line 62 of file completion_queue_factory.cc.

grpc_completion_queue_create_for_pluck()

grpc_completion_queue* grpc_completion_queue_create_for_pluck

(

void *

reserved

)

Helper function to create a completion queue with grpc_cq_completion_type of GRPC_CQ_PLUCK and grpc_cq_polling_type of GRPC_CQ_DEFAULT_POLLING

Definition at line 69 of file completion_queue_factory.cc.

grpc_completion_queue_factory_lookup()

const grpc_completion_queue_factory* grpc_completion_queue_factory_lookup

(

const grpc_completion_queue_attributes *

attributes

)

Returns the completion queue factory based on the attributes. MAY return a NULL if no factory can be found

Definition at line 48 of file completion_queue_factory.cc.

Variable Documentation

default_vtable

grpc_completion_queue_factory_vtable default_vtable = {default_create}

static

Definition at line 39 of file completion_queue_factory.cc.

g_default_cq_factory

const grpc_completion_queue_factory g_default_cq_factory

static

Initial value:

= {
    "Default Factory", nullptr, &default_vtable}

Definition at line 41 of file completion_queue_factory.cc.