class GRPC::Core::Server
Private Class Methods
server = Server.new({'arg1': 'value1'})
click to toggle source
Initializes server instances.
static VALUE grpc_rb_server_init(VALUE self, VALUE channel_args) { grpc_completion_queue* cq = NULL; grpc_rb_server* wrapper = NULL; grpc_server* srv = NULL; grpc_channel_args args; MEMZERO(&args, grpc_channel_args, 1); cq = grpc_completion_queue_create_for_pluck(NULL); TypedData_Get_Struct(self, grpc_rb_server, &grpc_rb_server_data_type, wrapper); grpc_rb_hash_convert_to_channel_args(channel_args, &args); srv = grpc_server_create(&args, NULL); grpc_rb_channel_args_destroy(&args); if (srv == NULL) { rb_raise(rb_eRuntimeError, "could not create a gRPC server, not sure why"); } grpc_server_register_completion_queue(srv, cq, NULL); wrapper->wrapped = srv; wrapper->queue = cq; return self; }
Private Instance Methods
// insecure port
click to toggle source
insecure_server = Server.new(cq, {'arg1': 'value1'})
add_http2_port('mydomain:50051', :this_port_is_insecure)
// secure port server_creds = … secure_server = Server.new
(cq, {'arg1': 'value1'}) secure_server.add_http_port('mydomain:50051', server_creds)
Adds a http2 port to server
static VALUE grpc_rb_server_add_http2_port(VALUE self, VALUE port, VALUE rb_creds) { grpc_rb_server* s = NULL; grpc_server_credentials* creds = NULL; int recvd_port = 0; TypedData_Get_Struct(self, grpc_rb_server, &grpc_rb_server_data_type, s); if (s->wrapped == NULL) { rb_raise(rb_eRuntimeError, "destroyed!"); return Qnil; } else if (TYPE(rb_creds) == T_SYMBOL) { if (id_insecure_server != SYM2ID(rb_creds)) { rb_raise(rb_eTypeError, "bad creds symbol, want :this_port_is_insecure"); return Qnil; } grpc_server_credentials* insecure_creds = grpc_insecure_server_credentials_create(); recvd_port = grpc_server_add_http2_port(s->wrapped, StringValueCStr(port), insecure_creds); grpc_server_credentials_release(insecure_creds); if (recvd_port == 0) { rb_raise(rb_eRuntimeError, "could not add port %s to server, not sure why", StringValueCStr(port)); } } else { // TODO: create a common parent class for all server-side credentials, // then we can have a single method to retrieve the underlying // grpc_server_credentials object, and avoid the need for this reflection if (grpc_rb_is_server_credentials(rb_creds)) { creds = grpc_rb_get_wrapped_server_credentials(rb_creds); } else if (grpc_rb_is_xds_server_credentials(rb_creds)) { creds = grpc_rb_get_wrapped_xds_server_credentials(rb_creds); } else { rb_raise(rb_eTypeError, "failed to create server because credentials parameter has an " "invalid type, want ServerCredentials or XdsServerCredentials"); } recvd_port = grpc_server_add_http2_port(s->wrapped, StringValueCStr(port), creds); if (recvd_port == 0) { rb_raise(rb_eRuntimeError, "could not add secure port %s to server, not sure why", StringValueCStr(port)); } } return INT2NUM(recvd_port); }
server = Server.new({'arg1': 'value1'})
click to toggle source
... // do stuff with server
...
... // initiate server shutdown
shutdown_and_notify(timeout)
... // to shutdown the server
destroy()
Destroys server instances.
static VALUE grpc_rb_server_destroy(VALUE self) { grpc_rb_server* s = NULL; TypedData_Get_Struct(self, grpc_rb_server, &grpc_rb_server_data_type, s); grpc_rb_server_maybe_destroy(s); return Qnil; }
Also aliased as: close
request_call
click to toggle source
Requests notification of a new call on a server.
static VALUE grpc_rb_server_request_call(VALUE self) { grpc_rb_server* s; TypedData_Get_Struct(self, grpc_rb_server, &grpc_rb_server_data_type, s); grpc_ruby_fork_guard(); if (s->wrapped == NULL) { rb_raise(rb_eRuntimeError, "destroyed!"); } struct server_request_call_args args = {.server = s, .call_queue = NULL}; return rb_ensure(grpc_rb_server_request_call_try, (VALUE)&args, grpc_rb_server_request_call_ensure, (VALUE)&args); }
shutdown_and_notify(p1)
click to toggle source
static VALUE grpc_rb_server_shutdown_and_notify(VALUE self, VALUE timeout) { gpr_timespec deadline; grpc_rb_server* s = NULL; TypedData_Get_Struct(self, grpc_rb_server, &grpc_rb_server_data_type, s); if (TYPE(timeout) == T_NIL) { deadline = gpr_inf_future(GPR_CLOCK_REALTIME); } else { deadline = grpc_rb_time_timeval(timeout, /* absolute time*/ 0); } grpc_rb_server_maybe_shutdown_and_notify(s, deadline); return Qnil; }
start()
click to toggle source
static VALUE grpc_rb_server_start(VALUE self) { grpc_rb_server* s = NULL; TypedData_Get_Struct(self, grpc_rb_server, &grpc_rb_server_data_type, s); grpc_ruby_fork_guard(); if (s->wrapped == NULL) { rb_raise(rb_eRuntimeError, "destroyed!"); } else { grpc_server_start(s->wrapped); } return Qnil; }