Classes | Enumerations | Functions | Variables
test/core/memory_usage/server.cc File Reference
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <string>
#include "absl/flags/flag.h"
#include "absl/flags/parse.h"
#include <grpc/grpc.h>
#include <grpc/grpc_security.h>
#include "test/core/memory_usage/memstats.h"
#include <unistd.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/time.h>
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/gprpp/host_port.h"
#include "test/core/end2end/data/ssl_test_data.h"
#include "test/core/util/port.h"
#include "test/core/util/test_config.h"
Include dependency graph for test/core/memory_usage/server.cc:

Go to the source code of this file.

Classes

struct  fling_call
 

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

 ABSL_FLAG (bool, minstack, false, "Use minimal stack")
 
 ABSL_FLAG (bool, secure, false, "Use security")
 
 ABSL_FLAG (std::string, bind, "", "Bind host:port")
 
int main (int argc, char **argv)
 
static void request_call_unary (int call_idx)
 
static void send_initial_metadata_unary (void *tag)
 
static void send_snapshot (void *tag, MemStats *snapshot)
 
static void send_status (void *tag)
 
static void sigint_handler (int)
 
static void * tag (intptr_t t)
 

Variables

static fling_call calls [1000006]
 
static grpc_completion_queuecq
 
static int got_sigint = 0
 
static grpc_op metadata_ops [2]
 
static grpc_byte_bufferpayload_buffer = nullptr
 
static grpc_serverserver
 
static grpc_op snapshot_ops [5]
 
static grpc_op status_op
 
static grpc_byte_bufferterminal_buffer = nullptr
 
static int was_cancelled = 2
 

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 62 of file test/core/memory_usage/server.cc.

Function Documentation

◆ ABSL_FLAG() [1/3]

ABSL_FLAG ( bool  ,
minstack  ,
false  ,
"Use minimal stack  
)

◆ ABSL_FLAG() [2/3]

ABSL_FLAG ( bool  ,
secure  ,
false  ,
"Use security"   
)

◆ ABSL_FLAG() [3/3]

ABSL_FLAG ( std::string  ,
bind  ,
""  ,
"Bind host:port"   
)

◆ main()

int main ( int  argc,
char **  argv 
)

Definition at line 160 of file test/core/memory_usage/server.cc.

◆ request_call_unary()

static void request_call_unary ( int  call_idx)
static

Definition at line 82 of file test/core/memory_usage/server.cc.

◆ send_initial_metadata_unary()

static void send_initial_metadata_unary ( void *  tag)
static

Definition at line 93 of file test/core/memory_usage/server.cc.

◆ send_snapshot()

static void send_snapshot ( void *  tag,
MemStats snapshot 
)
static

Definition at line 116 of file test/core/memory_usage/server.cc.

◆ send_status()

static void send_status ( void *  tag)
static

Definition at line 104 of file test/core/memory_usage/server.cc.

◆ sigint_handler()

static void sigint_handler ( int  )
static

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

◆ tag()

static void* tag ( intptr_t  t)
static

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

Variable Documentation

◆ calls

fling_call calls[1000006]
static

Definition at line 80 of file test/core/memory_usage/server.cc.

◆ cq

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

◆ got_sigint

int got_sigint = 0
static

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

◆ metadata_ops

grpc_op metadata_ops[2]
static

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

◆ payload_buffer

grpc_byte_buffer* payload_buffer = nullptr
static

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

◆ server

grpc_server* server
static

Definition at line 51 of file test/core/memory_usage/server.cc.

◆ snapshot_ops

grpc_op snapshot_ops[5]
static

Definition at line 53 of file test/core/memory_usage/server.cc.

◆ status_op

grpc_op status_op
static

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

◆ terminal_buffer

grpc_byte_buffer* terminal_buffer = nullptr
static

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

◆ was_cancelled

int was_cancelled = 2
static

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



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