concurrent_connectivity_test.cc File Reference

#include <memory.h>
#include <stdio.h>
#include <atomic>
#include <string>
#include "absl/strings/str_cat.h"
#include <grpc/grpc.h>
#include <grpc/grpc_security.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include "src/core/lib/address_utils/sockaddr_utils.h"
#include "src/core/lib/gprpp/thd.h"
#include "src/core/lib/gprpp/time.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/iomgr/sockaddr.h"
#include "src/core/lib/iomgr/tcp_server.h"
#include "src/core/lib/resource_quota/api.h"
#include "test/core/util/port.h"
#include "test/core/util/test_config.h"

Include dependency graph for concurrent_connectivity_test.cc:

Go to the source code of this file.

Classes
struct	ServerThreadArgs

Macros
#define	DELAY_MILLIS   10
#define	DELAY_MILLIS_SHORT_TIMEOUTS   1
#define	NUM_INNER_LOOPS   10
#define	NUM_INNER_LOOPS_SHORT_TIMEOUTS   100
#define	NUM_OUTER_LOOPS   10
#define	NUM_OUTER_LOOPS_SHORT_TIMEOUTS   10
#define	NUM_THREADS   100
#define	POLL_MILLIS   15000
#define	POLL_MILLIS_SHORT_TIMEOUTS   30000
#define	SERVER_SHUTDOWN_TIMEOUT   30000

Functions
void	bad_server_thread (void *vargs)
void	create_loop_destroy (void *addr)
static void	done_pollset_shutdown (void *pollset, grpc_error_handle)
int	main (int argc, char **argv)
static void	on_connect (void *vargs, grpc_endpoint *tcp, grpc_pollset *, grpc_tcp_server_acceptor *acceptor)
int	run_concurrent_connectivity_test ()
int	run_concurrent_watches_with_short_timeouts_test ()
void	server_thread (void *vargs)
static void *	tag (int n)
void	watches_with_short_timeouts (void *addr)

Macro Definition Documentation

DELAY_MILLIS

#define DELAY_MILLIS   10

Definition at line 54 of file concurrent_connectivity_test.cc.

DELAY_MILLIS_SHORT_TIMEOUTS

#define DELAY_MILLIS_SHORT_TIMEOUTS   1

Definition at line 59 of file concurrent_connectivity_test.cc.

NUM_INNER_LOOPS

#define NUM_INNER_LOOPS   10

Definition at line 53 of file concurrent_connectivity_test.cc.

NUM_INNER_LOOPS_SHORT_TIMEOUTS

#define NUM_INNER_LOOPS_SHORT_TIMEOUTS   100

Definition at line 58 of file concurrent_connectivity_test.cc.

NUM_OUTER_LOOPS

#define NUM_OUTER_LOOPS   10

Definition at line 52 of file concurrent_connectivity_test.cc.

NUM_OUTER_LOOPS_SHORT_TIMEOUTS

#define NUM_OUTER_LOOPS_SHORT_TIMEOUTS   10

Definition at line 57 of file concurrent_connectivity_test.cc.

NUM_THREADS

#define NUM_THREADS   100

Definition at line 49 of file concurrent_connectivity_test.cc.

POLL_MILLIS

#define POLL_MILLIS   15000

Definition at line 55 of file concurrent_connectivity_test.cc.

POLL_MILLIS_SHORT_TIMEOUTS

#define POLL_MILLIS_SHORT_TIMEOUTS   30000

Definition at line 62 of file concurrent_connectivity_test.cc.

SERVER_SHUTDOWN_TIMEOUT

#define SERVER_SHUTDOWN_TIMEOUT   30000

Definition at line 64 of file concurrent_connectivity_test.cc.

Function Documentation

bad_server_thread()

void bad_server_thread

(

void *

vargs

)

Definition at line 131 of file concurrent_connectivity_test.cc.

create_loop_destroy()

void create_loop_destroy

(

void *

addr

)

Definition at line 68 of file concurrent_connectivity_test.cc.

done_pollset_shutdown()

static void done_pollset_shutdown ( void *  pollset, grpc_error_handle    )

static

Definition at line 176 of file concurrent_connectivity_test.cc.

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 319 of file concurrent_connectivity_test.cc.

on_connect()

static void on_connect ( void *  vargs, grpc_endpoint *  tcp, grpc_pollset *  , grpc_tcp_server_acceptor *  acceptor  )

static

Definition at line 117 of file concurrent_connectivity_test.cc.

run_concurrent_connectivity_test()

int run_concurrent_connectivity_test

(

)

Definition at line 181 of file concurrent_connectivity_test.cc.

run_concurrent_watches_with_short_timeouts_test()

int run_concurrent_watches_with_short_timeouts_test

(

)

Definition at line 301 of file concurrent_connectivity_test.cc.

server_thread()

void server_thread

(

void *

vargs

)

Definition at line 107 of file concurrent_connectivity_test.cc.

tag()

static void* tag ( int  n )

static

Definition at line 66 of file concurrent_connectivity_test.cc.

watches_with_short_timeouts()

void watches_with_short_timeouts

(

void *

addr

)

Definition at line 269 of file concurrent_connectivity_test.cc.