completion_queue_threading_test.cc File Reference

#include <grpc/grpc.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/time.h>
#include "src/core/lib/gpr/useful.h"
#include "src/core/lib/gprpp/thd.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/surface/completion_queue.h"
#include "test/core/util/test_config.h"

Include dependency graph for completion_queue_threading_test.cc:

Go to the source code of this file.

Classes
struct	test_thread_options
struct	thread_state

Macros
#define	LOG_TEST(x)   gpr_log(GPR_INFO, "%s", x)
#define	TEST_THREAD_EVENTS   10000

Typedefs
typedef struct test_thread_options	test_thread_options

Functions
static void	consumer_thread (void *arg)
static void *	create_test_tag (void)
static void	do_nothing_end_completion (void *, grpc_cq_completion *)
static void	free_completion (void *, grpc_cq_completion *completion)
int	main (int argc, char **argv)
static void	pluck_one (void *arg)
static void	producer_thread (void *arg)
static void	shutdown_and_destroy (grpc_completion_queue *cc)
gpr_timespec	ten_seconds_time (void)
static void	test_threading (size_t producers, size_t consumers)
static void	test_too_many_plucks (void)

Macro Definition Documentation

LOG_TEST

#define LOG_TEST

(

x

)

gpr_log(GPR_INFO, "%s", x)

Definition at line 30 of file completion_queue_threading_test.cc.

TEST_THREAD_EVENTS

#define TEST_THREAD_EVENTS   10000

Definition at line 123 of file completion_queue_threading_test.cc.

Typedef Documentation

test_thread_options

typedef struct test_thread_options test_thread_options

Function Documentation

consumer_thread()

static void consumer_thread ( void *  arg )

static

Definition at line 175 of file completion_queue_threading_test.cc.

create_test_tag()

static void* create_test_tag ( void  )

static

Definition at line 32 of file completion_queue_threading_test.cc.

do_nothing_end_completion()

static void do_nothing_end_completion ( void *  , grpc_cq_completion *    )

static

Definition at line 63 of file completion_queue_threading_test.cc.

free_completion()

static void free_completion ( void *  , grpc_cq_completion *  completion  )

static

Definition at line 140 of file completion_queue_threading_test.cc.

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 291 of file completion_queue_threading_test.cc.

pluck_one()

static void pluck_one ( void *  arg )

static

Definition at line 71 of file completion_queue_threading_test.cc.

producer_thread()

static void producer_thread ( void *  arg )

static

Definition at line 144 of file completion_queue_threading_test.cc.

shutdown_and_destroy()

static void shutdown_and_destroy ( grpc_completion_queue *  cc )

static

Definition at line 38 of file completion_queue_threading_test.cc.

ten_seconds_time()

gpr_timespec ten_seconds_time

(

void

)

Definition at line 136 of file completion_queue_threading_test.cc.

test_threading()

static void test_threading ( size_t  producers, size_t  consumers  )

static

Definition at line 209 of file completion_queue_threading_test.cc.

test_too_many_plucks()

static void test_too_many_plucks ( void  )

static

Definition at line 77 of file completion_queue_threading_test.cc.