4

バックグラウンドでmongodbサーバーを実行できる簡単なスクリプトを作成しようとしています。現在、Process.spawnメソッドを使用しています。動作しますが、プロセスが完全に機能するまでしばらく待つ必要がmongodあります (ブート プロセスが完了し、データベースが新しい接続を待機しています)。

  def run!
    return if running?

    FileUtils.mkdir_p(MONGODB_DBPATH)

    command = "mongod --port #{port} --dbpath #{MONGODB_DBPATH} --nojournal"
    log_file = File.open(File.expand_path("log/test_mongod.log"), "w+")
    @pid = Process.spawn(command, out: log_file)

    # TODO wait for the connection (waiting for connections on port xxxx)
    sleep 2

    yield port if block_given?
  end

このスクリプトの全文は次のとおりです: https://github.com/lucassus/mongo_browser/blob/master/spec/support/mongod.rb#L22

sleep 2この醜い恣意性をこのコードから削除することは何とか可能ですか?

私の最初の推測は、生成されたプロセスにパイプを接続し、「ポート xxxx で接続を待機しています」というメッセージがパイプに書き込まれるまで待つことです。しかし、私はそれを実装する方法がわかりません。

4

1 に答える 1

5

以下は、子プロセスからの出力を待機するパターンです。

def run_and_wait_for_this regexp_to_wait_for, *cmd
  rd, wr = IO.pipe
  pid = Process.spawn(*cmd, out: wr)
  pid_waiter = Thread.new { Process.wait(pid); wr.close }
  thr = Thread.new do
    buffer = ''
    until buffer =~ regexp_to_wait_for
      buffer << rd.readpartial(100)
    end
  end
  thr.join
rescue EOFError
ensure
  rd.close
end

run_and_wait_for_this( /waiting for connections on port xxxx/, 'mongo', '--port', port, '--dbpath', MONGODB_PATH, '--nojournal' )

プロセスが期待される出力をパイプにフラッシュするまでブロックします。

于 2012-11-19T15:11:27.057 に答える