1#!/usr/bin/env ruby
2
3# Copyright 2015 gRPC authors.
4#
5# Licensed under the Apache License, Version 2.0 (the "License");
6# you may not use this file except in compliance with the License.
7# You may obtain a copy of the License at
8#
9#     http://www.apache.org/licenses/LICENSE-2.0
10#
11# Unless required by applicable law or agreed to in writing, software
12# distributed under the License is distributed on an "AS IS" BASIS,
13# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14# See the License for the specific language governing permissions and
15# limitations under the License.
16
17require_relative './end2end_common'
18
19# Start polling the channel state in both the main thread
20# and a child thread. Try to get the driver to send process-ending
21# interrupt while both a child thread and the main thread are in the
22# middle of a blocking connectivity_state call.
23def main
24  server_port = ''
25  OptionParser.new do |opts|
26    opts.on('--client_control_port=P', String) do
27      STDERR.puts 'client_control_port not used'
28    end
29    opts.on('--server_port=P', String) do |p|
30      server_port = p
31    end
32  end.parse!
33
34  trap('SIGINT') { exit 0 }
35
36  thd = Thread.new do
37    child_thread_channel = GRPC::Core::Channel.new("localhost:#{server_port}",
38                                                   {},
39                                                   :this_channel_is_insecure)
40    loop do
41      state = child_thread_channel.connectivity_state(false)
42      child_thread_channel.watch_connectivity_state(state, Time.now + 360)
43    end
44  end
45
46  main_channel = GRPC::Core::Channel.new("localhost:#{server_port}",
47                                         {},
48                                         :this_channel_is_insecure)
49  loop do
50    state = main_channel.connectivity_state(false)
51    main_channel.watch_connectivity_state(state, Time.now + 360)
52  end
53
54  thd.join
55end
56
57main
58