lib/noda/job_monitor.rb in noda-0.0.13 vs lib/noda/job_monitor.rb in noda-0.0.14
- old
+ new
@@ -1,10 +1,15 @@
module Noda
-#=概要
-# ジョブ状態を監視するWEBサーバーです。
-# DRBに接続して,キュー残数,共有ハッシュテーブル、キューの中身を見ることが出来ます.
+#=讎りヲ
+# 繧ク繝ァ繝也憾諷九r逶」隕悶☆繧妓EB繧オ繝シ繝舌シ縺ァ縺吶
+# DRB縺ォ謗・邯壹@縺ヲシ後く繝・繝シ谿区焚シ悟ア譛峨ワ繝繧キ繝・繝繝シ繝悶Ν縲√く繝・繝シ縺ョ荳ュ霄ォ繧定ヲ九k縺薙→縺悟コ譚・縺セ縺呻シ
+# == 菴ソ縺譁ケ
+# m=Noda::JobMonitor.new("#{ip}","10080","druby://#{ip}:10001")
+# m.start_monitor
+# ==繧ウ繝槭Φ繝峨〒襍キ蜍
+# $ noda_job_server start
class JobMonitor
require 'webrick'
require 'drb/drb'
attr_accessor :job_server, :web_server
@@ -19,15 +24,16 @@
@thread = Thread.new{ @web_server.start}
end
def stop_monitor
@web_server.stop
end
+ # 蜀驛ィ縺ァ菴ソ縺WEBRick繧偵う繝ウ繧ケ繧ソ繝ウ繧ケ蛹悶@縺ヲ繝槭え繝ウ繝医@縺セ縺呻シ
def init_webrick
config = WEBrick::Config::HTTP
config[:Port] = @port
config[:BindAddress]=@addr
- config[:AccessLog] = WEBrick::Log.new("/dev/null",1) #ログ要らない.
- config[:Logger] = Logger.new("/dev/null") #ログ要らない.
+ config[:AccessLog] = WEBrick::Log.new("/dev/null",1) #繝ュ繧ー隕√i縺ェ縺シ
+ config[:Logger] = Logger.new("/dev/null") #繝ュ繧ー隕√i縺ェ縺シ
@web_server = WEBrick::HTTPServer.new(config)
@web_server.mount_proc '/' do |req,res|
res.content_type="text/plain"
res.body = "running" if @job_server.alive?
res.body = "stopped" unless @job_server.alive?