@@ -1,5 +1,43 @@ require File.join(File.dirname(__FILE__) + "/bdrb_test_helper") +context "Master proxy for reloadable workers" do + BackgrounDRb::Config::RAILS_ENV = "production" + CONFIG_FILE = {:schedules=> + { + :foo_worker => { :barbar => {:trigger_args=>"*/10 * * * * *", :data =>"Hello World" }}, + :bar_worker => { :do_job => {:trigger_args=>"*/10 * * * * *", :data =>"Hello World" }} + }, + :backgroundrb=> {:log=>"foreground", :lazy_load=>true, :debug_log=>false, :environment=>"production", :port=>11006, :ip=>"localhost"} + } + + setup do + Packet::Reactor.stubs(:run) + @master_proxy = BackgrounDRb::MasterProxy.new + end + + specify "should load schedule of workers which are reloadable" do + @master_proxy.find_reloadable_worker + @master_proxy.reloadable_workers.should.not.be [] + @master_proxy.reloadable_workers.should == [BarWorker] + @master_proxy.worker_triggers.should.not.be {} + assert @master_proxy.worker_triggers.keys.include?(:bar_worker) + assert @master_proxy.worker_triggers[:bar_worker].keys.include?(:do_job) + @master_proxy.worker_triggers[:bar_worker][:do_job].should.not.be { } + end + + specify "load schedule should load schedule of worker specified" do + require "bar_worker" + @master_proxy.load_reloadable_schedule(BarWorker).should.not.be { } + end + + specify "should invoke worker methods which are ready to run" do + + end + + specify "should not run worker methods which are not ready to run" do + + end +end context "Master Worker in general should" do specify "read data according to binary protocol and recreate objects" do @@ -49,41 +87,3 @@ context "Master Worker in general should" do end end -context "Master proxy for reloadable workers" do - BackgrounDRb::Config::RAILS_ENV = "production" - CONFIG_FILE = {:schedules=> - { - :foo_worker => { :barbar => {:trigger_args=>"*/10 * * * * *", :data =>"Hello World" }}, - :bar_worker => { :do_job => {:trigger_args=>"*/10 * * * * *", :data =>"Hello World" }} - }, - :backgroundrb=> {:log=>"foreground", :lazy_load=>true, :debug_log=>false, :environment=>"production", :port=>11006, :ip=>"localhost"} - } - - setup do - Packet::Reactor.stubs(:run) - @master_proxy = BackgrounDRb::MasterProxy.new - end - - specify "should load schedule of workers which are reloadable" do - @master_proxy.find_reloadable_worker - @master_proxy.reloadable_workers.should.not.be [] - @master_proxy.reloadable_workers.should == [BarWorker] - @master_proxy.worker_triggers.should.not.be {} - assert @master_proxy.worker_triggers.keys.include?(:bar_worker) - assert @master_proxy.worker_triggers[:bar_worker].keys.include?(:do_job) - @master_proxy.worker_triggers[:bar_worker][:do_job].should.not.be { } - end - - specify "load schedule should load schedule of worker specified" do - require "bar_worker" - @master_proxy.load_reloadable_schedule(BarWorker).should.not.be { } - end - - specify "should invoke worker methods which are ready to run" do - - end - - specify "should not run worker methods which are not ready to run" do - - end -end test/test_master_worker.rb ab7711294a121dfff3bfbf7793ce7fc88290d6c8 gnufied mail@gnufied.org http://github.com/georgepalmer/backgroundrb_merb/commit/f18b5c9f6c33c68a7593307c9353031b26a4951c f18b5c9f6c33c68a7593307c9353031b26a4951c 2008-03-01T18:23:28-08:00 2008-03-01T18:23:28-08:00 Commit Master Worker Testcases abde080bafa221af5c67b8b2cb14824d8d61f077 gnufied mail@gnufied.org