You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
80 lines
2.2 KiB
80 lines
2.2 KiB
13 years ago
|
require 'optparse'
|
||
13 years ago
|
require 'socket'
|
||
|
|
||
13 years ago
|
def main(args = ARGV)
|
||
|
options = {
|
||
|
:type => :write,
|
||
|
:sleep_interval => 1.0,
|
||
|
:name => 'sally',
|
||
|
:port => 22000
|
||
|
}
|
||
|
|
||
|
OptionParser.new do |opts|
|
||
|
opts.banner = "Usage: ruby #{File.basename($0)} [options]"
|
||
|
opts.on('-t [TYPE]', '--type [TYPE]', [:read, :write],
|
||
|
"Client type (read/write), default=#{options[:type].to_s}") do |t|
|
||
|
options[:type] = t
|
||
|
end
|
||
|
opts.on('-n [NAME]', '--name [NAME]',
|
||
|
"Client (player) name, default='#{options[:name]}'") do |n|
|
||
|
options[:name] = n
|
||
|
end
|
||
|
opts.on('-s [SLEEP_INTERVAL]', '--sleep [SLEEP_INTERVAL]',
|
||
|
"Sleep interval between requests, " <<
|
||
|
"default=#{options[:sleep_interval]}") do |s|
|
||
|
options[:sleep_interval] = s.to_f
|
||
|
end
|
||
|
opts.on('-p [PORT]', '--port [PORT]', Integer,
|
||
|
"Server port, default=#{options[:port]}") do |p|
|
||
|
options[:port] = p
|
||
|
end
|
||
|
end.parse!(args)
|
||
|
|
||
|
run_client(options)
|
||
|
end
|
||
|
|
||
|
def run_client(options)
|
||
|
client_type = options.fetch(:type, :read)
|
||
|
client_name = options.fetch(:name, 'sally')
|
||
|
sleep_interval = options.fetch(:sleep_interval, 1.0)
|
||
|
port = options.fetch(:port, 22000)
|
||
|
|
||
|
puts "Starting #{client_type} client for '#{client_name}', " <<
|
||
|
"interval=#{sleep_interval}, port=#{port}"
|
||
13 years ago
|
|
||
|
successes = 0
|
||
|
backoff = 0.5
|
||
|
nextloc = [rand(0..99), rand(0..99)]
|
||
|
loop do
|
||
|
begin
|
||
13 years ago
|
TCPSocket.open('127.0.0.1', port) do |sock|
|
||
13 years ago
|
case client_type
|
||
13 years ago
|
when :read
|
||
|
sock.send("marco #{client_name}\n", 0)
|
||
13 years ago
|
location = sock.recv(100).to_s.split[2,4].map(&:to_i)
|
||
13 years ago
|
puts "marco #{client_name} -> #{location.first} #{location.last}"
|
||
13 years ago
|
when :write
|
||
|
sock.send("polo #{client_name} #{nextloc.first} #{nextloc.last}\n", 0)
|
||
13 years ago
|
recv_loc = sock.recv(100).to_s.split.map(&:to_i)
|
||
|
puts "polo #{client_name} #{nextloc.first} #{nextloc.last} " <<
|
||
|
"-> #{recv_loc.first} #{recv_loc.last}"
|
||
|
nextloc = recv_loc
|
||
13 years ago
|
end
|
||
|
sock.close
|
||
|
end
|
||
|
successes += 1
|
||
|
backoff = 0.5
|
||
|
sleep sleep_interval
|
||
|
rescue
|
||
|
puts "made it #{successes} times. sleeping #{backoff} secs"
|
||
|
successes = 0
|
||
|
sleep backoff
|
||
|
backoff *= 2
|
||
13 years ago
|
end
|
||
13 years ago
|
end
|
||
|
end
|
||
13 years ago
|
|
||
|
if $0 == __FILE__
|
||
|
main
|
||
|
end
|