|
|
@ -399,7 +399,7 @@ module GRPC |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
# Sends UNIMPLEMENTED if the method is not implemented by this server |
|
|
|
# Sends UNIMPLEMENTED if the method is not implemented by this server |
|
|
|
def found?(an_rpc) |
|
|
|
def implemented?(an_rpc) |
|
|
|
mth = an_rpc.method.to_sym |
|
|
|
mth = an_rpc.method.to_sym |
|
|
|
return an_rpc if rpc_descs.key?(mth) |
|
|
|
return an_rpc if rpc_descs.key?(mth) |
|
|
|
GRPC.logger.warn("UNIMPLEMENTED: #{an_rpc}") |
|
|
|
GRPC.logger.warn("UNIMPLEMENTED: #{an_rpc}") |
|
|
@ -446,7 +446,7 @@ module GRPC |
|
|
|
an_rpc.call.run_batch(@cq, handle_call_tag, INFINITE_FUTURE, |
|
|
|
an_rpc.call.run_batch(@cq, handle_call_tag, INFINITE_FUTURE, |
|
|
|
SEND_INITIAL_METADATA => connect_md) |
|
|
|
SEND_INITIAL_METADATA => connect_md) |
|
|
|
return nil unless available?(an_rpc) |
|
|
|
return nil unless available?(an_rpc) |
|
|
|
return nil unless found?(an_rpc) |
|
|
|
return nil unless implemented?(an_rpc) |
|
|
|
|
|
|
|
|
|
|
|
# Create the ActiveCall |
|
|
|
# Create the ActiveCall |
|
|
|
GRPC.logger.info("deadline is #{an_rpc.deadline}; (now=#{Time.now})") |
|
|
|
GRPC.logger.info("deadline is #{an_rpc.deadline}; (now=#{Time.now})") |
|
|
|