OLD | NEW |
(Empty) | |
| 1 #!/usr/bin/env ruby |
| 2 |
| 3 # Copyright 2015, Google Inc. |
| 4 # All rights reserved. |
| 5 # |
| 6 # Redistribution and use in source and binary forms, with or without |
| 7 # modification, are permitted provided that the following conditions are |
| 8 # met: |
| 9 # |
| 10 # * Redistributions of source code must retain the above copyright |
| 11 # notice, this list of conditions and the following disclaimer. |
| 12 # * Redistributions in binary form must reproduce the above |
| 13 # copyright notice, this list of conditions and the following disclaimer |
| 14 # in the documentation and/or other materials provided with the |
| 15 # distribution. |
| 16 # * Neither the name of Google Inc. nor the names of its |
| 17 # contributors may be used to endorse or promote products derived from |
| 18 # this software without specific prior written permission. |
| 19 # |
| 20 # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
| 21 # "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
| 22 # LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
| 23 # A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
| 24 # OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| 25 # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
| 26 # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| 27 # DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| 28 # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| 29 # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| 30 # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| 31 |
| 32 # Sample gRPC Ruby server that implements the Math::Calc service and helps |
| 33 # validate GRPC::RpcServer as GRPC implementation using proto2 serialization. |
| 34 # |
| 35 # Usage: $ path/to/math_server.rb |
| 36 |
| 37 this_dir = File.expand_path(File.dirname(__FILE__)) |
| 38 lib_dir = File.join(File.dirname(this_dir), 'lib') |
| 39 $LOAD_PATH.unshift(lib_dir) unless $LOAD_PATH.include?(lib_dir) |
| 40 $LOAD_PATH.unshift(this_dir) unless $LOAD_PATH.include?(this_dir) |
| 41 |
| 42 require 'forwardable' |
| 43 require 'grpc' |
| 44 require 'logger' |
| 45 require 'math_services' |
| 46 require 'optparse' |
| 47 |
| 48 # RubyLogger defines a logger for gRPC based on the standard ruby logger. |
| 49 module RubyLogger |
| 50 def logger |
| 51 LOGGER |
| 52 end |
| 53 |
| 54 LOGGER = Logger.new(STDOUT) |
| 55 end |
| 56 |
| 57 # GRPC is the general RPC module |
| 58 module GRPC |
| 59 # Inject the noop #logger if no module-level logger method has been injected. |
| 60 extend RubyLogger |
| 61 end |
| 62 |
| 63 # Holds state for a fibonacci series |
| 64 class Fibber |
| 65 def initialize(limit) |
| 66 fail "bad limit: got #{limit}, want limit > 0" if limit < 1 |
| 67 @limit = limit |
| 68 end |
| 69 |
| 70 def generator |
| 71 return enum_for(:generator) unless block_given? |
| 72 idx, current, previous = 0, 1, 1 |
| 73 until idx == @limit |
| 74 if idx.zero? || idx == 1 |
| 75 yield Math::Num.new(num: 1) |
| 76 idx += 1 |
| 77 next |
| 78 end |
| 79 tmp = current |
| 80 current = previous + current |
| 81 previous = tmp |
| 82 yield Math::Num.new(num: current) |
| 83 idx += 1 |
| 84 end |
| 85 end |
| 86 end |
| 87 |
| 88 # A EnumeratorQueue wraps a Queue to yield the items added to it. |
| 89 class EnumeratorQueue |
| 90 extend Forwardable |
| 91 def_delegators :@q, :push |
| 92 |
| 93 def initialize(sentinel) |
| 94 @q = Queue.new |
| 95 @sentinel = sentinel |
| 96 end |
| 97 |
| 98 def each_item |
| 99 return enum_for(:each_item) unless block_given? |
| 100 loop do |
| 101 r = @q.pop |
| 102 break if r.equal?(@sentinel) |
| 103 fail r if r.is_a? Exception |
| 104 yield r |
| 105 end |
| 106 end |
| 107 end |
| 108 |
| 109 # The Math::Math:: module occurs because the service has the same name as its |
| 110 # package. That practice should be avoided by defining real services. |
| 111 class Calculator < Math::Math::Service |
| 112 def div(div_args, _call) |
| 113 if div_args.divisor.zero? |
| 114 # To send non-OK status handlers raise a StatusError with the code and |
| 115 # and detail they want sent as a Status. |
| 116 fail GRPC::StatusError.new(GRPC::Status::INVALID_ARGUMENT, |
| 117 'divisor cannot be 0') |
| 118 end |
| 119 |
| 120 Math::DivReply.new(quotient: div_args.dividend / div_args.divisor, |
| 121 remainder: div_args.dividend % div_args.divisor) |
| 122 end |
| 123 |
| 124 def sum(call) |
| 125 # the requests are accesible as the Enumerator call#each_request |
| 126 nums = call.each_remote_read.collect(&:num) |
| 127 sum = nums.inject { |s, x| s + x } |
| 128 Math::Num.new(num: sum) |
| 129 end |
| 130 |
| 131 def fib(fib_args, _call) |
| 132 if fib_args.limit < 1 |
| 133 fail StatusError.new(Status::INVALID_ARGUMENT, 'limit must be >= 0') |
| 134 end |
| 135 |
| 136 # return an Enumerator of Nums |
| 137 Fibber.new(fib_args.limit).generator |
| 138 # just return the generator, GRPC::GenericServer sends each actual response |
| 139 end |
| 140 |
| 141 def div_many(requests) |
| 142 # requests is an lazy Enumerator of the requests sent by the client. |
| 143 q = EnumeratorQueue.new(self) |
| 144 t = Thread.new do |
| 145 begin |
| 146 requests.each do |req| |
| 147 GRPC.logger.info("read #{req.inspect}") |
| 148 resp = Math::DivReply.new(quotient: req.dividend / req.divisor, |
| 149 remainder: req.dividend % req.divisor) |
| 150 q.push(resp) |
| 151 Thread.pass # let the internal Bidi threads run |
| 152 end |
| 153 GRPC.logger.info('finished reads') |
| 154 q.push(self) |
| 155 rescue StandardError => e |
| 156 q.push(e) # share the exception with the enumerator |
| 157 raise e |
| 158 end |
| 159 end |
| 160 t.priority = -2 # hint that the div_many thread should not be favoured |
| 161 q.each_item |
| 162 end |
| 163 end |
| 164 |
| 165 def load_test_certs |
| 166 this_dir = File.expand_path(File.dirname(__FILE__)) |
| 167 data_dir = File.join(File.dirname(this_dir), 'spec/testdata') |
| 168 files = ['ca.pem', 'server1.key', 'server1.pem'] |
| 169 files.map { |f| File.open(File.join(data_dir, f)).read } |
| 170 end |
| 171 |
| 172 def test_server_creds |
| 173 certs = load_test_certs |
| 174 GRPC::Core::ServerCredentials.new( |
| 175 nil, [{ private_key: certs[1], cert_chain: certs[2] }], false) |
| 176 end |
| 177 |
| 178 def main |
| 179 options = { |
| 180 'host' => 'localhost:7071', |
| 181 'secure' => false |
| 182 } |
| 183 OptionParser.new do |opts| |
| 184 opts.banner = 'Usage: [--host <hostname>:<port>] [--secure|-s]' |
| 185 opts.on('--host HOST', '<hostname>:<port>') do |v| |
| 186 options['host'] = v |
| 187 end |
| 188 opts.on('-s', '--secure', 'access using test creds') do |v| |
| 189 options['secure'] = v |
| 190 end |
| 191 end.parse! |
| 192 |
| 193 s = GRPC::RpcServer.new |
| 194 if options['secure'] |
| 195 s.add_http2_port(options['host'], test_server_creds) |
| 196 GRPC.logger.info("... running securely on #{options['host']}") |
| 197 else |
| 198 s.add_http2_port(options['host'], :this_port_is_insecure) |
| 199 GRPC.logger.info("... running insecurely on #{options['host']}") |
| 200 end |
| 201 |
| 202 s.handle(Calculator) |
| 203 s.run_till_terminated |
| 204 end |
| 205 |
| 206 main |
OLD | NEW |