Classes | Enumerations | Functions | Variables
test/core/fling/server.cc File Reference
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <grpc/grpc.h>
#include <grpc/grpc_security.h>
#include <unistd.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/time.h>
#include "src/core/lib/gprpp/host_port.h"
#include "src/core/lib/profiling/timers.h"
#include "test/core/end2end/data/ssl_test_data.h"
#include "test/core/util/cmdline.h"
#include "test/core/util/grpc_profiler.h"
#include "test/core/util/port.h"
#include "test/core/util/test_config.h"
Include dependency graph for test/core/fling/server.cc:

Go to the source code of this file.

Classes

struct  call_state
 

Enumerations

enum  fling_server_tags {
  FLING_SERVER_NEW_REQUEST = 1, FLING_SERVER_READ_FOR_UNARY, FLING_SERVER_BATCH_OPS_FOR_UNARY, FLING_SERVER_SEND_INIT_METADATA_FOR_STREAMING,
  FLING_SERVER_READ_FOR_STREAMING, FLING_SERVER_WRITE_FOR_STREAMING, FLING_SERVER_SEND_STATUS_FOR_STREAMING, FLING_SERVER_NEW_REQUEST = 1,
  FLING_SERVER_SEND_INIT_METADATA, FLING_SERVER_WAIT_FOR_DESTROY, FLING_SERVER_SEND_STATUS_FLING_CALL, FLING_SERVER_SEND_STATUS_SNAPSHOT,
  FLING_SERVER_BATCH_SEND_STATUS_FLING_CALL
}
 

Functions

static void handle_unary_method (void)
 
int main (int argc, char **argv)
 
static void request_call (void)
 
static void send_initial_metadata (void)
 
static void sigint_handler (int)
 
static void start_read_op (int t)
 
static void start_send_status (void)
 
static void start_write_op (void)
 
static void * tag (intptr_t t)
 

Variables

static grpc_callcall
 
static grpc_call_details call_details
 
static grpc_completion_queuecq
 
static int got_sigint = 0
 
static grpc_metadata_array initial_metadata_send
 
static grpc_op metadata_send_op
 
static grpc_byte_bufferpayload_buffer = nullptr
 
static grpc_op read_op
 
static grpc_metadata_array request_metadata_recv
 
static grpc_serverserver
 
static grpc_op status_op [2]
 
static grpc_byte_bufferterminal_buffer = nullptr
 
static grpc_op unary_ops [6]
 
static int was_cancelled = 2
 
static grpc_op write_op
 

Enumeration Type Documentation

◆ fling_server_tags

Enumerator
FLING_SERVER_NEW_REQUEST 
FLING_SERVER_READ_FOR_UNARY 
FLING_SERVER_BATCH_OPS_FOR_UNARY 
FLING_SERVER_SEND_INIT_METADATA_FOR_STREAMING 
FLING_SERVER_READ_FOR_STREAMING 
FLING_SERVER_WRITE_FOR_STREAMING 
FLING_SERVER_SEND_STATUS_FOR_STREAMING 
FLING_SERVER_NEW_REQUEST 
FLING_SERVER_SEND_INIT_METADATA 
FLING_SERVER_WAIT_FOR_DESTROY 
FLING_SERVER_SEND_STATUS_FLING_CALL 
FLING_SERVER_SEND_STATUS_SNAPSHOT 
FLING_SERVER_BATCH_SEND_STATUS_FLING_CALL 

Definition at line 64 of file test/core/fling/server.cc.

Function Documentation

◆ handle_unary_method()

static void handle_unary_method ( void  )
static

Definition at line 87 of file test/core/fling/server.cc.

◆ main()

int main ( int  argc,
char **  argv 
)

Definition at line 172 of file test/core/fling/server.cc.

◆ request_call()

static void request_call ( void  )
static

Definition at line 79 of file test/core/fling/server.cc.

◆ send_initial_metadata()

static void send_initial_metadata ( void  )
static

Definition at line 121 of file test/core/fling/server.cc.

◆ sigint_handler()

static void sigint_handler ( int  )
static

Definition at line 170 of file test/core/fling/server.cc.

◆ start_read_op()

static void start_read_op ( int  t)
static

Definition at line 132 of file test/core/fling/server.cc.

◆ start_send_status()

static void start_send_status ( void  )
static

Definition at line 154 of file test/core/fling/server.cc.

◆ start_write_op()

static void start_write_op ( void  )
static

Definition at line 141 of file test/core/fling/server.cc.

◆ tag()

static void* tag ( intptr_t  t)
static

Definition at line 62 of file test/core/fling/server.cc.

Variable Documentation

◆ call

grpc_call* call
static

Definition at line 46 of file test/core/fling/server.cc.

◆ call_details

grpc_call_details call_details
static

Definition at line 47 of file test/core/fling/server.cc.

◆ cq

Definition at line 44 of file test/core/fling/server.cc.

◆ got_sigint

int got_sigint = 0
static

Definition at line 60 of file test/core/fling/server.cc.

◆ initial_metadata_send

grpc_metadata_array initial_metadata_send
static

Definition at line 49 of file test/core/fling/server.cc.

◆ metadata_send_op

grpc_op metadata_send_op
static

Definition at line 55 of file test/core/fling/server.cc.

◆ payload_buffer

grpc_byte_buffer* payload_buffer = nullptr
static

Definition at line 50 of file test/core/fling/server.cc.

◆ read_op

grpc_op read_op
static

Definition at line 54 of file test/core/fling/server.cc.

◆ request_metadata_recv

grpc_metadata_array request_metadata_recv
static

Definition at line 48 of file test/core/fling/server.cc.

◆ server

grpc_server* server
static

Definition at line 45 of file test/core/fling/server.cc.

◆ status_op

grpc_op status_op[2]
static

Definition at line 57 of file test/core/fling/server.cc.

◆ terminal_buffer

grpc_byte_buffer* terminal_buffer = nullptr
static

Definition at line 52 of file test/core/fling/server.cc.

◆ unary_ops

grpc_op unary_ops[6]
static

Definition at line 59 of file test/core/fling/server.cc.

◆ was_cancelled

int was_cancelled = 2
static

Definition at line 58 of file test/core/fling/server.cc.

◆ write_op

grpc_op write_op
static

Definition at line 56 of file test/core/fling/server.cc.



grpc
Author(s):
autogenerated on Fri May 16 2025 03:01:30