35 static VALUE grpc_rb_cCall;
39 VALUE grpc_rb_eCallError = Qnil;
43 static VALUE grpc_rb_eOutOfTime = Qnil;
47 static VALUE grpc_rb_sBatchResult;
51 static VALUE grpc_rb_cMdAry;
74 static VALUE sym_send_message;
75 static VALUE sym_send_metadata;
76 static VALUE sym_send_close;
77 static VALUE sym_send_status;
78 static VALUE sym_message;
79 static VALUE sym_status;
80 static VALUE sym_cancelled;
138 VALUE rb_error_code_details;
142   VALUE detail_ref = rb_hash_aref(rb_error_code_details, UINT2NUM(err));  in grpc_call_error_detail_of()
152 static VALUE grpc_rb_call_cancel(VALUE self) {  in grpc_rb_call_cancel()
175 static VALUE grpc_rb_call_cancel_with_status(VALUE self, VALUE status_code,  in grpc_rb_call_cancel_with_status()
176                                              VALUE details) {  in grpc_rb_call_cancel_with_status()
206 static VALUE grpc_rb_call_close(VALUE self) {  in grpc_rb_call_close()
218 static VALUE grpc_rb_call_get_peer(VALUE self) {  in grpc_rb_call_get_peer()
219   VALUE res = Qnil;  in grpc_rb_call_get_peer()
235 static VALUE grpc_rb_call_get_peer_cert(VALUE self) {  in grpc_rb_call_get_peer_cert()
237   VALUE res = Qnil;  in grpc_rb_call_get_peer_cert()
272 static VALUE grpc_rb_call_get_status(VALUE self) {  in grpc_rb_call_get_status()
281 static VALUE grpc_rb_call_set_status(VALUE self, VALUE status) {  in grpc_rb_call_set_status()
296 static VALUE grpc_rb_call_get_metadata(VALUE self) {  in grpc_rb_call_get_metadata()
305 static VALUE grpc_rb_call_set_metadata(VALUE self, VALUE metadata) {  in grpc_rb_call_set_metadata()
320 static VALUE grpc_rb_call_get_trailing_metadata(VALUE self) {  in grpc_rb_call_get_trailing_metadata()
329 static VALUE grpc_rb_call_set_trailing_metadata(VALUE self, VALUE metadata) {  in grpc_rb_call_set_trailing_metadata()
344 static VALUE grpc_rb_call_get_write_flag(VALUE self) {  in grpc_rb_call_get_write_flag()
353 static VALUE grpc_rb_call_set_write_flag(VALUE self, VALUE write_flag) {  in grpc_rb_call_set_write_flag()
368 static VALUE grpc_rb_call_set_credentials(VALUE self, VALUE credentials) {  in grpc_rb_call_set_credentials()
396 static int grpc_rb_md_ary_fill_hash_cb(VALUE key, VALUE val, VALUE md_ary_obj) {  in grpc_rb_md_ary_fill_hash_cb()
470 static int grpc_rb_md_ary_capacity_hash_cb(VALUE key, VALUE val,  in grpc_rb_md_ary_capacity_hash_cb()
471                                            VALUE md_ary_obj) {  in grpc_rb_md_ary_capacity_hash_cb()
493 void grpc_rb_md_ary_convert(VALUE md_ary_hash, grpc_metadata_array* md_ary) {  in grpc_rb_md_ary_convert()
494   VALUE md_ary_obj = Qnil;  in grpc_rb_md_ary_convert()
514 VALUE grpc_rb_md_ary_to_h(grpc_metadata_array* md_ary) {  in grpc_rb_md_ary_to_h()
515   VALUE key = Qnil;  in grpc_rb_md_ary_to_h()
516   VALUE new_ary = Qnil;  in grpc_rb_md_ary_to_h()
517   VALUE value = Qnil;  in grpc_rb_md_ary_to_h()
518   VALUE result = rb_hash_new();  in grpc_rb_md_ary_to_h()
546 static int grpc_rb_call_check_op_keys_hash_cb(VALUE key, VALUE val,  in grpc_rb_call_check_op_keys_hash_cb()
547                                               VALUE ops_ary) {  in grpc_rb_call_check_op_keys_hash_cb()
578     VALUE status) {  in grpc_rb_op_update_status_from_server()
579   VALUE code = rb_struct_aref(status, sym_code);  in grpc_rb_op_update_status_from_server()
580   VALUE details = rb_struct_aref(status, sym_details);  in grpc_rb_op_update_status_from_server()
581   VALUE metadata_hash = rb_struct_aref(status, sym_metadata);  in grpc_rb_op_update_status_from_server()
683 static void grpc_run_batch_stack_fill_ops(run_batch_stack* st, VALUE ops_hash) {  in grpc_run_batch_stack_fill_ops()
684   VALUE this_op = Qnil;  in grpc_run_batch_stack_fill_ops()
685   VALUE this_value = Qnil;  in grpc_run_batch_stack_fill_ops()
686   VALUE ops_ary = rb_ary_new();  in grpc_run_batch_stack_fill_ops()
750 static VALUE grpc_run_batch_stack_build_result(run_batch_stack* st) {  in grpc_run_batch_stack_build_result()
752   VALUE result = rb_struct_new(grpc_rb_sBatchResult, Qnil, Qnil, Qnil, Qnil,  in grpc_run_batch_stack_build_result()
812 static VALUE grpc_rb_call_run_batch(VALUE self, VALUE ops_hash) {  in grpc_rb_call_run_batch()
817   VALUE result = Qnil;  in grpc_rb_call_run_batch()
818   VALUE rb_write_flag = rb_ivar_get(self, id_write_flag);  in grpc_rb_call_run_batch()
867   VALUE grpc_rb_mWriteFlags =  in Init_grpc_write_flags()
877   VALUE grpc_rb_mRpcErrors =  in Init_grpc_error_codes()
932   VALUE grpc_rb_mCallOps = rb_define_module_under(grpc_rb_mGrpcCore, "CallOps");  in Init_grpc_op_codes()
952   VALUE grpc_rb_mMetadataKeys =  in Init_grpc_metadata_keys()
1026 grpc_call* grpc_rb_get_wrapped_call(VALUE v) {  in grpc_rb_get_wrapped_call()
1033 VALUE grpc_rb_wrap_call(grpc_call* c, grpc_completion_queue* q) {  in grpc_rb_wrap_call()