ruby-dev

はじめまして、山本円と申します。

socketを使っているとBUGが起こることがあるようです。

ハッキリしないのですが、
socketすでに切断され、Bad file descriptorな状態
になっているときsocket.writeをしようとすると、
たまに例外でなくBUGが起こることがあるという感じです。
スレッドも絡んでいるような気がします。

BUGのメッセージは以下のとおりです。


testserver.rb:19: [BUG] Segmentation fault
ruby 1.8.0 (2003-06-14) [i686-linux]


rubyは1.6.8でも起こるようです。
OSはredhat7.3、同8、同9で確認しました。

僕では原因は特定できませんので、
再現スクリプトを添付します。
以下のプログラムだと、サーバー側のプログラムでBUGが起きます。
サーバーとクライアントは別PCのがいいようです。

■testserver.rb
 サーバー側プログラム(port 1100決め打ち)

使い方
ruby testserver.rb

■clientloop.rb
 testclient.rbを作っては殺し作っては殺すプログラム

使い方
clientloop.rb 192.168.1.1 1100

■testclient.rb
 clientloop.rbから使われるクライアント側プログラム socketをやたらに作る

Attachments (3)

testclient.rb (429 Bytes, text/x-ruby)

require 'socket'
require 'timeout'

if ARGV.size != 2
  p "ARGV.size != 2"
  exit
end

host = ARGV[0]
port = ARGV[1]

`echo '#{Process.pid}' > sb.pid`

1000000.times{
  (1 .. 110).each{|i|
    Thread.start{
      sock = nil

      sock = TCPSocket.open(host, port.to_i)
      (1 .. 50).each do
        sock.print("012345\n")
        timeout(time_out){
          line = sock.gets
        }
      end

      sock.close
    }
  }
}

clientloop.rb (228 Bytes, text/x-ruby)

if ARGV.size != 2
  p "ARGV.size != 2"
  exit
end

host = ARGV[0]
port = ARGV[1]


1000000.times{
  Thread.start{
    `ruby testclient.rb #{host} #{port}`
  }
  sleep(0.3)
  p  pid = `cat sb.pid`
  pid.chomp!
  `kill #{pid}`
}

testserver.rb (1.34 KB, text/x-ruby)

$DEBUG = true

require 'socket'

class SockWrapper
  @replyQueue
  @socket
  @recieveThread

  def initialize(host, port, socket)
    @socket = socket
    @replyQueue = []

    recieveThread()
  end


  def push(str)
    @socket.write(str + "\n")
  end

  def shift()
    return @replyQueue.shift
  end

  def close()
    @socket.close
  end

  def alive?
    return @socket.closed? == false
  end

  def recieveThread()
    @recieveThread = Thread.start{
      begin
        while str = @socket.gets 
          @replyQueue.push(str)
        end
      rescue Exception
      ensure
        close
      end
    }
  end
end


class TestServer
  def initialize
    makeServerConnect()
    while true
      threadLoop()
    end
  end
  
  def port
    1100
  end

  def makeServerConnect()
    @gs = TCPServer.open(port)

    addr = @gs.addr
    addr.shift
    printf("server is on %s\n", addr.join(":"))
  end
  :private

  def threadLoop()
    Thread.start(@gs.accept) do |socket|       # save to dynamic variable
#      print(socket, " is accepted\n")
      
      @conn = SockWrapper.new(nil, nil, socket)

      while @conn.alive?
        getStr = @conn.shift

        next unless getStr
        begin
          @conn.push("1234")
        rescue Exception
        end
      end

#      print(socket, " is gone\n")
    end
  end
end

if $0 == __FILE__
  TestServer.new
end

Thread

Prev Next

In This Thread

Prev Next

[#20315] Re: [Oniguruma] intersection of char class — kkosako@...

[#20316] Re: local variable and local variable in block behave differently — nobu.nakada@...

[#20317] Re: [Oniguruma] possessive quantifier — kkosako@...

[#20318] make test failed — nobu.nakada@...

[#20320] Apollo.exeでsingleton_method_addedが効かない — Kazuhiro Yoshida <moriq@...>

[#20326] Re: Forward: RCR: Enhancing matrix.rb — keiju@... (石塚圭樹)

[#20328] cannot commit to cvs — "U.Nakamura" <usa@...>

[#20330] Re: [Oniguruma] intersection of char class — kkosako@...

[#20335] 1.8 gsub — "H.Suzuki" <hsuzux@...>

[#20339] rb_fix2int->rb_fix2uint? — akira yamada <akira@...>

[#20341] Re: irb warning(create Proc object without a block) (PR#492) — nobu.nakada@...

[#20343] Re: [Oniguruma] intersection of char class — kkosako@...

[#20347] 1.8.0 preview3 schedule — matz@... (Yukihiro Matsumoto)

[#20348] lib/optparse/date.rb — Tadayoshi Funaba <tadf@...5.so-net.ne.jp>

[#20350] How to create Proc from C extension — nobu.nakada@...

[#20351] socket.writeでBUG — "so" <dan@...2.so-net.ne.jp>

[#20361] [PATCH] lambda + def — Minero Aoki <aamine@...>

[#20362] [Oniguruma] quoting substring — kkosako@...

[#20366] forwadable.rb on ftp.ruby-lang.org — keiju@... (Keiju ISHITSUKA)

[#20370] [PATCH] 1.8 range.c: [][0..-1] => [] — "NAKAMURA, Hiroshi" <nakahiro@...>

[#20374] case sensitivity of the names of environment variables — "U.Nakamura" <usa@...>

[#20379] locale and Marshal — Masao Mutoh <mutoh@...>

[#20390] Re: [Oniguruma] quoting substring — kkosako@...

[#20392] [BigDecimal] proposal to change specification — "Tadashi Saito" <shiba@...2.accsnet.ne.jp>

[#20393] [Oniguruma] Version 1.9.0 — kkosako@...

[#20412] Re: In 1.8.0 nil.to_s is not the same as "" — nobu.nakada@...

[#20416] ruby 1.8.0 preview3 — matz@... (Yukihiro Matsumoto)

[#20434] [PATCH] config.guess returns invalid value on Linux/Alpha — Minero Aoki <aamine@...>

[#20441] [New Block] 悪いのは誰？ — Shin-ichiro HARA <sinara@...>

[#20445] Re: *.soの autoload(PR#504) — nobu.nakada@...

[#20447] [BigDecimal] renaming proposal — "Tadashi Saito" <shiba@...2.accsnet.ne.jp>

[#20462] 原因不明のSEGV — "yamamoto madoka" <dan@...2.so-net.ne.jp>

[#20466] Ruby OpenSSL and MS_CALLBACK cpp(1) macro. — Takahiro Kambe <taca@...>

[ruby-dev:20351] socket.writeでBUG

Attachments (3)

Thread

In This Thread

[#20362] [Oniguruma]　quoting substring — kkosako@...

[#20390] Re: [Oniguruma]　quoting substring — kkosako@...