#include <ruby/ruby.h>
#include "rb_call.h"
#include "rb_byte_buffer.h"
#include "rb_call_credentials.h"
#include "rb_completion_queue.h"
#include "rb_grpc.h"
#include "rb_grpc_imports.generated.h"
#include <grpc/grpc.h>
#include <grpc/impl/codegen/compression_types.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>

Include dependency graph for rb_call.c:

Classes
struct	grpc_rb_call

struct	run_batch_stack

Typedefs
typedef struct grpc_rb_call	grpc_rb_call

typedef struct run_batch_stack	run_batch_stack

Functions
static void	destroy_call (grpc_rb_call *call)

const char *	grpc_call_error_detail_of (grpc_call_error err)

static VALUE	grpc_rb_call_cancel (VALUE self)

static VALUE	grpc_rb_call_cancel_with_status (VALUE self, VALUE status_code, VALUE details)

static int	grpc_rb_call_check_op_keys_hash_cb (VALUE key, VALUE val, VALUE ops_ary)

static VALUE	grpc_rb_call_close (VALUE self)

static void	grpc_rb_call_destroy (void *p)

static VALUE	grpc_rb_call_get_metadata (VALUE self)

static VALUE	grpc_rb_call_get_peer (VALUE self)

static VALUE	grpc_rb_call_get_peer_cert (VALUE self)

static VALUE	grpc_rb_call_get_status (VALUE self)

static VALUE	grpc_rb_call_get_trailing_metadata (VALUE self)

static VALUE	grpc_rb_call_get_write_flag (VALUE self)

static VALUE	grpc_rb_call_run_batch (VALUE self, VALUE ops_hash)

static VALUE	grpc_rb_call_set_credentials (VALUE self, VALUE credentials)

static VALUE	grpc_rb_call_set_metadata (VALUE self, VALUE metadata)

static VALUE	grpc_rb_call_set_status (VALUE self, VALUE status)

static VALUE	grpc_rb_call_set_trailing_metadata (VALUE self, VALUE metadata)

static VALUE	grpc_rb_call_set_write_flag (VALUE self, VALUE write_flag)

grpc_call *	grpc_rb_get_wrapped_call (VALUE v)

static int	grpc_rb_md_ary_capacity_hash_cb (VALUE key, VALUE val, VALUE md_ary_obj)

void	grpc_rb_md_ary_convert (VALUE md_ary_hash, grpc_metadata_array *md_ary)

static int	grpc_rb_md_ary_fill_hash_cb (VALUE key, VALUE val, VALUE md_ary_obj)

VALUE	grpc_rb_md_ary_to_h (grpc_metadata_array *md_ary)

void	grpc_rb_metadata_array_destroy_including_entries (grpc_metadata_array *array)

static void	grpc_rb_op_update_status_from_server (grpc_op op, grpc_metadata_array md_ary, grpc_slice *send_status_details, VALUE status)

VALUE	grpc_rb_wrap_call (grpc_call c, grpc_completion_queue q)

static VALUE	grpc_run_batch_stack_build_result (run_batch_stack *st)

static void	grpc_run_batch_stack_cleanup (run_batch_stack *st)

static void	grpc_run_batch_stack_fill_ops (run_batch_stack *st, VALUE ops_hash)

static void	grpc_run_batch_stack_init (run_batch_stack *st, unsigned write_flag)

void	Init_grpc_call ()

static void	Init_grpc_error_codes ()

static void	Init_grpc_metadata_keys ()

static void	Init_grpc_op_codes ()

static void	Init_grpc_write_flags ()

Variables
static const rb_data_type_t	grpc_call_data_type

static VALUE	grpc_rb_cCall

VALUE	grpc_rb_cMdAry

VALUE	grpc_rb_eCallError = Qnil

static VALUE	grpc_rb_eOutOfTime = Qnil

const rb_data_type_t	grpc_rb_md_ary_data_type

static VALUE	grpc_rb_sBatchResult

static ID	id_credentials

static ID	id_metadata

static ID	id_status

static ID	id_trailing_metadata

static ID	id_write_flag

VALUE	rb_error_code_details

static VALUE	sym_cancelled

static VALUE	sym_message

static VALUE	sym_send_close

static VALUE	sym_send_message

static VALUE	sym_send_metadata

static VALUE	sym_send_status

static VALUE	sym_status

Typedef Documentation

◆ grpc_rb_call

typedef struct grpc_rb_call grpc_rb_call

◆ run_batch_stack

typedef struct run_batch_stack run_batch_stack

Function Documentation

◆ destroy_call()

static void destroy_call ( grpc_rb_call * call )

static

Definition at line 87 of file rb_call.c.

◆ grpc_call_error_detail_of()

const char* grpc_call_error_detail_of ( grpc_call_error err )

Definition at line 141 of file rb_call.c.

◆ grpc_rb_call_cancel()

static VALUE grpc_rb_call_cancel ( VALUE self )

static

Definition at line 152 of file rb_call.c.

◆ grpc_rb_call_cancel_with_status()

static VALUE grpc_rb_call_cancel_with_status	(	VALUE	self,
		VALUE	status_code,
		VALUE	details
	)

static

Definition at line 175 of file rb_call.c.

◆ grpc_rb_call_check_op_keys_hash_cb()

static int grpc_rb_call_check_op_keys_hash_cb	(	VALUE	key,
		VALUE	val,
		VALUE	ops_ary
	)

static

Definition at line 547 of file rb_call.c.

◆ grpc_rb_call_close()

static VALUE grpc_rb_call_close ( VALUE self )

static

Definition at line 206 of file rb_call.c.

◆ grpc_rb_call_destroy()

static void grpc_rb_call_destroy ( void * p )

static

Definition at line 98 of file rb_call.c.

◆ grpc_rb_call_get_metadata()

static VALUE grpc_rb_call_get_metadata ( VALUE self )

static

Definition at line 296 of file rb_call.c.

◆ grpc_rb_call_get_peer()

static VALUE grpc_rb_call_get_peer ( VALUE self )

static

Definition at line 218 of file rb_call.c.

◆ grpc_rb_call_get_peer_cert()

static VALUE grpc_rb_call_get_peer_cert ( VALUE self )

static

Definition at line 235 of file rb_call.c.

◆ grpc_rb_call_get_status()

static VALUE grpc_rb_call_get_status ( VALUE self )

static

Definition at line 272 of file rb_call.c.

◆ grpc_rb_call_get_trailing_metadata()

static VALUE grpc_rb_call_get_trailing_metadata ( VALUE self )

static

Definition at line 320 of file rb_call.c.

◆ grpc_rb_call_get_write_flag()

static VALUE grpc_rb_call_get_write_flag ( VALUE self )

static

Definition at line 344 of file rb_call.c.

◆ grpc_rb_call_run_batch()

static VALUE grpc_rb_call_run_batch	(	VALUE	self,
		VALUE	ops_hash
	)

static

Definition at line 821 of file rb_call.c.

◆ grpc_rb_call_set_credentials()

static VALUE grpc_rb_call_set_credentials	(	VALUE	self,
		VALUE	credentials
	)

static

Definition at line 368 of file rb_call.c.

◆ grpc_rb_call_set_metadata()

static VALUE grpc_rb_call_set_metadata	(	VALUE	self,
		VALUE	metadata
	)

static

Definition at line 305 of file rb_call.c.

◆ grpc_rb_call_set_status()

static VALUE grpc_rb_call_set_status	(	VALUE	self,
		VALUE	status
	)

static

Definition at line 281 of file rb_call.c.

◆ grpc_rb_call_set_trailing_metadata()

static VALUE grpc_rb_call_set_trailing_metadata	(	VALUE	self,
		VALUE	metadata
	)

static

Definition at line 329 of file rb_call.c.

◆ grpc_rb_call_set_write_flag()

static VALUE grpc_rb_call_set_write_flag	(	VALUE	self,
		VALUE	write_flag
	)

static

Definition at line 353 of file rb_call.c.

◆ grpc_rb_get_wrapped_call()

grpc_call* grpc_rb_get_wrapped_call ( VALUE v )

Definition at line 1035 of file rb_call.c.

◆ grpc_rb_md_ary_capacity_hash_cb()

static int grpc_rb_md_ary_capacity_hash_cb	(	VALUE	key,
		VALUE	val,
		VALUE	md_ary_obj
	)

static

Definition at line 470 of file rb_call.c.

◆ grpc_rb_md_ary_convert()

void grpc_rb_md_ary_convert	(	VALUE	md_ary_hash,
		grpc_metadata_array *	md_ary
	)

Definition at line 494 of file rb_call.c.

◆ grpc_rb_md_ary_fill_hash_cb()

static int grpc_rb_md_ary_fill_hash_cb	(	VALUE	key,
		VALUE	val,
		VALUE	md_ary_obj
	)

static

Definition at line 396 of file rb_call.c.

◆ grpc_rb_md_ary_to_h()

VALUE grpc_rb_md_ary_to_h ( grpc_metadata_array * md_ary )

Definition at line 515 of file rb_call.c.

◆ grpc_rb_metadata_array_destroy_including_entries()

void grpc_rb_metadata_array_destroy_including_entries ( grpc_metadata_array * array )

Definition at line 642 of file rb_call.c.

◆ grpc_rb_op_update_status_from_server()

static void grpc_rb_op_update_status_from_server	(	grpc_op *	op,
		grpc_metadata_array *	md_ary,
		grpc_slice *	send_status_details,
		VALUE	status
	)

static

Definition at line 577 of file rb_call.c.

◆ grpc_rb_wrap_call()

VALUE grpc_rb_wrap_call	(	grpc_call *	c,
		grpc_completion_queue *	q
	)

Definition at line 1042 of file rb_call.c.

◆ grpc_run_batch_stack_build_result()

static VALUE grpc_run_batch_stack_build_result ( run_batch_stack * st )

static

Definition at line 754 of file rb_call.c.

◆ grpc_run_batch_stack_cleanup()

static void grpc_run_batch_stack_cleanup ( run_batch_stack * st )

static

Definition at line 656 of file rb_call.c.

◆ grpc_run_batch_stack_fill_ops()

static void grpc_run_batch_stack_fill_ops	(	run_batch_stack *	st,
		VALUE	ops_hash
	)

static

Definition at line 685 of file rb_call.c.

◆ grpc_run_batch_stack_init()

static void grpc_run_batch_stack_init	(	run_batch_stack *	st,
		unsigned	write_flag
	)

static

Definition at line 631 of file rb_call.c.

◆ Init_grpc_call()

void Init_grpc_call ( )

Definition at line 967 of file rb_call.c.

◆ Init_grpc_error_codes()

static void Init_grpc_error_codes ( )

static

Definition at line 884 of file rb_call.c.

◆ Init_grpc_metadata_keys()

static void Init_grpc_metadata_keys ( )

static

Definition at line 960 of file rb_call.c.

◆ Init_grpc_op_codes()

static void Init_grpc_op_codes ( )

static

Definition at line 939 of file rb_call.c.

◆ Init_grpc_write_flags()

static void Init_grpc_write_flags ( )

static

Definition at line 874 of file rb_call.c.

Variable Documentation

◆ grpc_call_data_type

const rb_data_type_t grpc_call_data_type

static

Initial value:

= {"grpc_call",
                                                   {GRPC_RB_GC_NOT_MARKED,
                                                    grpc_rb_call_destroy,
                                                    GRPC_RB_MEMSIZE_UNAVAILABLE,
                                                    {NULL, NULL}},
                                                   NULL,
                                                   NULL,
 
 
 
}

Definition at line 125 of file rb_call.c.

◆ grpc_rb_cCall

VALUE grpc_rb_cCall

static

Definition at line 35 of file rb_call.c.

◆ grpc_rb_cMdAry

VALUE grpc_rb_cMdAry

Definition at line 51 of file rb_call.c.

◆ grpc_rb_eCallError

VALUE grpc_rb_eCallError = Qnil

Definition at line 39 of file rb_call.c.

◆ grpc_rb_eOutOfTime

VALUE grpc_rb_eOutOfTime = Qnil

static

Definition at line 43 of file rb_call.c.

◆ grpc_rb_md_ary_data_type

const rb_data_type_t grpc_rb_md_ary_data_type

Initial value:

= {
    "grpc_metadata_array",
    {GRPC_RB_GC_NOT_MARKED,
     GRPC_RB_GC_DONT_FREE,
     GRPC_RB_MEMSIZE_UNAVAILABLE,
     {NULL, NULL}},
    NULL,
    NULL,
 
}

Definition at line 106 of file rb_call.c.

◆ grpc_rb_sBatchResult

VALUE grpc_rb_sBatchResult

static

Definition at line 47 of file rb_call.c.

◆ id_credentials

ID id_credentials

static

Definition at line 55 of file rb_call.c.

◆ id_metadata

ID id_metadata

static

Definition at line 59 of file rb_call.c.

◆ id_status

ID id_status

static

Definition at line 67 of file rb_call.c.

◆ id_trailing_metadata

ID id_trailing_metadata

static

Definition at line 63 of file rb_call.c.

◆ id_write_flag

ID id_write_flag

static

Definition at line 71 of file rb_call.c.

◆ rb_error_code_details

VALUE rb_error_code_details

Definition at line 138 of file rb_call.c.

◆ sym_cancelled

VALUE sym_cancelled

static

Definition at line 80 of file rb_call.c.

◆ sym_message

VALUE sym_message

static

Definition at line 78 of file rb_call.c.

◆ sym_send_close

VALUE sym_send_close

static

Definition at line 76 of file rb_call.c.

◆ sym_send_message

VALUE sym_send_message

static

Definition at line 74 of file rb_call.c.

◆ sym_send_metadata

VALUE sym_send_metadata

static

Definition at line 75 of file rb_call.c.

◆ sym_send_status

VALUE sym_send_status

static

Definition at line 77 of file rb_call.c.

◆ sym_status

VALUE sym_status

static

Definition at line 79 of file rb_call.c.

Classes

Typedefs

Functions

Variables

Typedef Documentation

◆ grpc_rb_call

◆ run_batch_stack

Function Documentation

◆ destroy_call()

◆ grpc_call_error_detail_of()

◆ grpc_rb_call_cancel()

◆ grpc_rb_call_cancel_with_status()

◆ grpc_rb_call_check_op_keys_hash_cb()

◆ grpc_rb_call_close()

◆ grpc_rb_call_destroy()

◆ grpc_rb_call_get_metadata()

◆ grpc_rb_call_get_peer()

◆ grpc_rb_call_get_peer_cert()

◆ grpc_rb_call_get_status()

◆ grpc_rb_call_get_trailing_metadata()

◆ grpc_rb_call_get_write_flag()

◆ grpc_rb_call_run_batch()

◆ grpc_rb_call_set_credentials()

◆ grpc_rb_call_set_metadata()

◆ grpc_rb_call_set_status()

◆ grpc_rb_call_set_trailing_metadata()

◆ grpc_rb_call_set_write_flag()

◆ grpc_rb_get_wrapped_call()

◆ grpc_rb_md_ary_capacity_hash_cb()

◆ grpc_rb_md_ary_convert()

◆ grpc_rb_md_ary_fill_hash_cb()

◆ grpc_rb_md_ary_to_h()

◆ grpc_rb_metadata_array_destroy_including_entries()

◆ grpc_rb_op_update_status_from_server()

◆ grpc_rb_wrap_call()

◆ grpc_run_batch_stack_build_result()

◆ grpc_run_batch_stack_cleanup()

◆ grpc_run_batch_stack_fill_ops()

◆ grpc_run_batch_stack_init()

◆ Init_grpc_call()

◆ Init_grpc_error_codes()

◆ Init_grpc_metadata_keys()

◆ Init_grpc_op_codes()

◆ Init_grpc_write_flags()

Variable Documentation

◆ grpc_call_data_type

◆ grpc_rb_cCall

◆ grpc_rb_cMdAry

◆ grpc_rb_eCallError

◆ grpc_rb_eOutOfTime

◆ grpc_rb_md_ary_data_type

◆ grpc_rb_sBatchResult

◆ id_credentials

◆ id_metadata

◆ id_status

◆ id_trailing_metadata

◆ id_write_flag

◆ rb_error_code_details

◆ sym_cancelled

◆ sym_message

◆ sym_send_close

◆ sym_send_message

◆ sym_send_metadata

◆ sym_send_status

◆ sym_status