mirror of https://github.com/grpc/grpc.git
parent
dfc95159a6
commit
bae00e08cc
3 changed files with 81 additions and 0 deletions
@ -0,0 +1,44 @@ |
||||
#!/usr/bin/env ruby |
||||
|
||||
# Copyright 2018 gRPC authors. |
||||
# |
||||
# Licensed under the Apache License, Version 2.0 (the "License"); |
||||
# you may not use this file except in compliance with the License. |
||||
# You may obtain a copy of the License at |
||||
# |
||||
# http://www.apache.org/licenses/LICENSE-2.0 |
||||
# |
||||
# Unless required by applicable law or agreed to in writing, software |
||||
# distributed under the License is distributed on an "AS IS" BASIS, |
||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
# See the License for the specific language governing permissions and |
||||
# limitations under the License. |
||||
|
||||
require_relative './end2end_common' |
||||
require 'objspace' |
||||
|
||||
def main |
||||
server_port = '' |
||||
loop_count = 200 |
||||
|
||||
OptionParser.new do |opts| |
||||
opts.on('--client_control_port=P', String) do |
||||
STDERR.puts 'client_control_port ignored' |
||||
end |
||||
opts.on('--server_port=P', String) do |p| |
||||
server_port = p |
||||
end |
||||
end.parse! |
||||
|
||||
loop_count.times do |
||||
stub = Echo::EchoServer::Stub.new("localhost:#{server_port}", :this_channel_is_insecure) |
||||
stub.echo(Echo::EchoRequest.new(request: 'client/child')) |
||||
|
||||
# Get memory usage of all objects |
||||
ObjectSpace.memsize_of_all |
||||
end |
||||
|
||||
STDERR.puts "Succeeded in getting memory usage for #{loop_count} times" |
||||
end |
||||
|
||||
main |
@ -0,0 +1,36 @@ |
||||
#!/usr/bin/env ruby |
||||
|
||||
# Copyright 2018 gRPC authors. |
||||
# |
||||
# Licensed under the Apache License, Version 2.0 (the "License"); |
||||
# you may not use this file except in compliance with the License. |
||||
# You may obtain a copy of the License at |
||||
# |
||||
# http://www.apache.org/licenses/LICENSE-2.0 |
||||
# |
||||
# Unless required by applicable law or agreed to in writing, software |
||||
# distributed under the License is distributed on an "AS IS" BASIS, |
||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
# See the License for the specific language governing permissions and |
||||
# limitations under the License. |
||||
|
||||
require_relative './end2end_common' |
||||
|
||||
def main |
||||
STDERR.puts 'start server' |
||||
server_runner = ServerRunner.new(EchoServerImpl) |
||||
server_port = server_runner.run |
||||
STDERR.puts 'start client' |
||||
_, client_pid = start_client('client_memory_usage_client.rb', server_port) |
||||
|
||||
Process.wait(client_pid) |
||||
|
||||
client_exit_code = $CHILD_STATUS |
||||
if client_exit_code != 0 |
||||
raise "Getting memory usage was failed, exit code #{client_exit_code}" |
||||
end |
||||
ensure |
||||
server_runner.stop |
||||
end |
||||
|
||||
main |
Loading…
Reference in new issue