Sha256: 485698042836a616710b2150dccc798225354847c1062041e98f00467dbbd26a

Contents?: true

Size: 1.08 KB

Versions: 10

Compression:

Stored size: 1.08 KB

Contents

#!/usr/bin/env ruby
require 'test/unit'
require 'rubygems'; require 'require_relative'

# Unit test for io/tcpserver.rb
require_relative '../../io/tcpfns'
require_relative '../../io/tcpserver'

class TestTCPDbgServer < Test::Unit::TestCase

  include Trepanning::TCPPacking

  def test_basic
    server = Trepan::TCPDbgServer.new
    server.open({ :open => false,
                  :port => 1027,
                  :host => '127.0.0.1'
                })
    threads = []
    msgs = %w(one two three)
    Thread.new do
      msgs.each do |msg|
        begin
          line = server.read_msg.chomp
          assert_equal(msg, line)
        rescue EOFError
          puts 'Got EOF'
          break
        end
      end
    end
    threads << Thread.new do 
      t = TCPSocket.new('127.0.0.1', 1027)
      msgs.each do |msg|
        begin
          t.puts(pack_msg(msg))
        rescue EOFError
          puts "Got EOF"
          break
        rescue Exception => e
          puts "Got #{e}"
          break
        end
      end
      t.close
    end
    threads.each {|t| t.join }
    server.close
  end
end

Version data entries

10 entries across 10 versions & 2 rubygems

Version Path
rbx-trepanning-0.2.0-universal-rubinius-2.0 test/unit/test-io-tcpserver.rb
rbx-trepanning-0.1.0-universal-rubinius-1.2 test/unit/test-io-tcpserver.rb
rb8-trepanning-0.1.3 test/unit/test-io-tcpserver.rb
rb8-trepanning-0.1.3-universal-ruby-1.9.2 test/unit/test-io-tcpserver.rb
rb8-trepanning-0.1.3-universal-ruby-1.8.7 test/unit/test-io-tcpserver.rb
rbx-trepanning-0.0.8-universal-rubinius-1.2 test/unit/test-io-tcpserver.rb
rbx-trepanning-0.0.7-universal-rubinius-1.2 test/unit/test-io-tcpserver.rb
rbx-trepanning-0.0.6-universal-rubinius-1.2 test/unit/test-io-tcpserver.rb
rbx-trepanning-0.0.5-universal-rubinius-1.2.1 test/unit/test-io-tcpserver.rb
rbx-trepanning-0.0.4-universal-rubinius-1.2 test/unit/test-io-tcpserver.rb