The following code works fine as long as I don't try to run it through the distributed server. It doesn't get there... It runs fine out of delayed_job, runs fine if called directly. But if 'distrib' is true (the default) it runs right up to the call to the server and right past it without getting to the server or raising any errors.
Am using Ruby 1.8.6.26 , Ringy-Dingy 1.2.1, dj 1.8.4.
*********The server: require 'rinda/ring' class ScriptServer include DRbUndumped attr_accessor :result def run(fullScript) myTS = Time.now.strftime("%Y%m%d%H%M%S") msg = "===> Starting #{scriptname} in run #{scriptrun} on #{scriptenv} at #{myTS}" puts msg @result = "***#{scriptname} Launched [#{scriptlaunch}]" rslt = fullScript.run @result << rslt msg = "#{scriptname} Completed [#{Time.now.strftime("%Y%m%d%H%M %S")}]" @result << "***#{msg}" rescue @result << "#{scriptname} Aborted [#{Time.now.strftime("%Y%m%d%H%M %S")}] \n #{$!} \n #{caller.to_yaml}" ensure return @result end end DRb.start_service myPid = Process.pid.to_s puts myPid ring_server = Rinda::RingFinger.primary ring_server.write([:name, :ScriptServer, ScriptServer.new(), "ScriptServer #{myPid}"], Rinda::SimpleRenewer.new) DRb.thread.join
******** The worker/client require 'active_support' require 'drb'
class ScriptWorker
attr_accessor :script_id attr_accessor :run_id attr_accessor :distrib
def initialize( script_id, run_id, distrib = true ) self.script_id = script_id self.run_id = run_id self.distrib = distrib @myLog = '' end
def perform myScript = Script.find(script_id) # left out setting of variables used below...
require "#{myRoot}/script/#{myScript.name}"
fullScript = Object.const_get(myClass).new( myScript, myRun, runenv, myURI, myRoot )
if self.distrib require 'rinda/ring' DRb.start_service ring_server = Rinda::RingFinger.primary service = ring_server.take([:name, :ScriptServer, nil, nil]) server = service[2] result = server.run(fullScript) puts result else result = fullScript.run puts result end @myLog.close end
def init_my_log( name ) ... end end
******** The parent script class require 'rubygems' require 'util1' require 'drb'
class ScriptMain
currDir = Dir.pwd
include Util1 include DRbUndumped
def initialize( aScript, aRun, runenv, myURI, myRoot ) @myScript = aScript @myId = @myScript.id @myName = File.basename(@myScript.name, "*.rb") @usecase = @myName @myRun = aRun @myRoot = myRoot @rootDir = "#{RAILS_ROOT}" @launch = aRun.launched @runenv = runenv @myURI = myURI @runid = aRun.id @optionStrg = aRun.options @myBrowser = '' @myHwnd = 0
end end
**********a sample child script class (Just the run method. bunch of other methods in full script)
class SearchTest < ScriptMain
def run( limit = 5.minutes ) begin puts '&*&*&* I am here *&*&*&' @runenv = 'WEB' open_log(@myName, @rootDir, @myRoot, @launch, @start, @myId, @runenv, @usecase, @runid, @optionStrg )
mark_testlevel('Test Parent', 7) # Module mark_testlevel('Test Child', 6) # SubModule
@myBrowser = Watir::IE.new_process @myHwnd = @myBrowser.hwnd lookup('Google') emaillogin(@myBrowser, @service, @username, @password) logout(@myBrowser)
rescue log_message(FATAL, "(#{__LINE__}) #{$!}", @@fail) raise ensure create_flag_file(Time.new.to_f.to_s, 'parse' ) unless @runid == '99999' close_log(@myName, __LINE__) end end #def
end
