doc/rdoc/files/lib/hive/scheduler_rb.html doc/rdoc/files/lib/hive/worker_rb.html @@ -1 +1 @@ -0.1.3 \ No newline at end of file +0.1.5 \ No newline at end of file doc/VERSION @@ -55,12 +55,12 @@ <tr class="top-aligned-row"> <td>In:</td> <td> - <a href="../files/lib/scheduler_rb.html"> - lib/scheduler.rb + <a href="../files/lib/hive/scheduler_rb.html"> + lib/hive/scheduler.rb </a> - <a href="../files/lib/worker_rb.html"> - lib/worker.rb + <a href="../files/lib/hive/worker_rb.html"> + lib/hive/worker.rb </a> </td> doc/rdoc/classes/Hive.html @@ -55,8 +55,8 @@ <tr class="top-aligned-row"> <td>In:</td> <td> - <a href="../../files/lib/scheduler_rb.html"> - lib/scheduler.rb + <a href="../../files/lib/hive/scheduler_rb.html"> + lib/hive/scheduler.rb </a> </td> @@ -124,11 +124,11 @@ onclick="toggleCode('M000016-source');return false;">[Source]</a> <div class="method-source-code" id="M000016-source"> <pre> - # File lib/scheduler.rb, line 8 + # File lib/hive/scheduler.rb, line 8 8: def stop_tasks 9: threads = Thread.list.select { |t| t.alive? && t != Thread.current } 10: until threads.empty? -11: logger.info "#{threads.count} threads still running ... " +11: logger.info "#{threads.size} threads still running ... " 12: threads.each { |t| t.kill && t != Thread.current } 13: threads = threads.select { |t| t.alive? } 14: end doc/rdoc/classes/Hive/Scheduler.html @@ -55,8 +55,8 @@ <tr class="top-aligned-row"> <td>In:</td> <td> - <a href="../../files/lib/worker_rb.html"> - lib/worker.rb + <a href="../../files/lib/hive/worker_rb.html"> + lib/hive/worker.rb </a> </td> @@ -165,7 +165,7 @@ make this the one-and-only onclick="toggleCode('M000003-source');return false;">[Source]</a> <div class="method-source-code" id="M000003-source"> <pre> - # File lib/worker.rb, line 22 + # File lib/hive/worker.rb, line 22 22: def self.instance ; @instance ; end </pre> </div> @@ -186,7 +186,7 @@ make this the one-and-only onclick="toggleCode('M000004-source');return false;">[Source]</a> <div class="method-source-code" id="M000004-source"> <pre> - # File lib/worker.rb, line 28 + # File lib/hive/worker.rb, line 28 28: def initialize( options ) 29: @options = options 30: end @@ -209,7 +209,7 @@ make this the one-and-only onclick="toggleCode('M000002-source');return false;">[Source]</a> <div class="method-source-code" id="M000002-source"> <pre> - # File lib/worker.rb, line 16 + # File lib/hive/worker.rb, line 16 16: def self.run( options = {} ) 17: @instance ||= new( options ) 18: @instance.start @@ -235,7 +235,7 @@ make this the one-and-only onclick="toggleCode('M000008-source');return false;">[Source]</a> <div class="method-source-code" id="M000008-source"> <pre> - # File lib/worker.rb, line 57 + # File lib/hive/worker.rb, line 57 57: def daemonize 58: pwd = Dir.pwd ; pid = fork ; return pid if pid ; Dir.chdir( pwd ) 59: File.umask 0000 ; STDIN.reopen( '/dev/null') ; @@ -261,7 +261,7 @@ make this the one-and-only onclick="toggleCode('M000007-source');return false;">[Source]</a> <div class="method-source-code" id="M000007-source"> <pre> - # File lib/worker.rb, line 55 + # File lib/hive/worker.rb, line 55 55: def restart ; stop ; start ; end </pre> </div> @@ -282,7 +282,7 @@ make this the one-and-only onclick="toggleCode('M000009-source');return false;">[Source]</a> <div class="method-source-code" id="M000009-source"> <pre> - # File lib/worker.rb, line 64 + # File lib/hive/worker.rb, line 64 64: def set_traps 65: safe_trap( 'HUP' ) { restart } 66: safe_trap( 'TERM','INT' ) { stop } @@ -309,7 +309,7 @@ returns the PID of the <a href="Worker.html#M000004">new</a> process onclick="toggleCode('M000005-source');return false;">[Source]</a> <div class="method-source-code" id="M000005-source"> <pre> - # File lib/worker.rb, line 33 + # File lib/hive/worker.rb, line 33 33: def start 34: pid = daemonize if options[ :daemon ] 35: puts "#{self.class.name} process #{pid} started ..." if pid @@ -320,7 +320,7 @@ returns the PID of the <a href="Worker.html#M000004">new</a> process 40: start_debugger if options[:debug] # unless Kernel.engine == 'jruby' 41: # various ways to talk to a worker 42: set_traps ; start_console ; start_drb -43: start_tasks.join +43: start_tasks.join 44: rescue Exception => e 45: logger.error e.to_s 46: end @@ -344,7 +344,7 @@ returns the PID of the <a href="Worker.html#M000004">new</a> process onclick="toggleCode('M000010-source');return false;">[Source]</a> <div class="method-source-code" id="M000010-source"> <pre> - # File lib/worker.rb, line 69 + # File lib/hive/worker.rb, line 69 69: def start_console 70: # TODO: add live console support 71: end @@ -367,7 +367,7 @@ returns the PID of the <a href="Worker.html#M000004">new</a> process onclick="toggleCode('M000012-source');return false;">[Source]</a> <div class="method-source-code" id="M000012-source"> <pre> - # File lib/worker.rb, line 77 + # File lib/hive/worker.rb, line 77 77: def start_debugger 78: require 'ruby-debug' ; Debugger.start 79: Debugger.settings[:autoeval] = true if Debugger.respond_to?(:settings) @@ -392,7 +392,7 @@ returns the PID of the <a href="Worker.html#M000004">new</a> process onclick="toggleCode('M000011-source');return false;">[Source]</a> <div class="method-source-code" id="M000011-source"> <pre> - # File lib/worker.rb, line 73 + # File lib/hive/worker.rb, line 73 73: def start_drb 74: # TODO: add DRb support 75: end @@ -415,7 +415,7 @@ returns the PID of the <a href="Worker.html#M000004">new</a> process onclick="toggleCode('M000013-source');return false;">[Source]</a> <div class="method-source-code" id="M000013-source"> <pre> - # File lib/worker.rb, line 83 + # File lib/hive/worker.rb, line 83 83: def start_logger 84: if options[ :logger ] 85: @logger = options[ :logger ] @@ -443,7 +443,7 @@ returns the PID of the <a href="Worker.html#M000004">new</a> process onclick="toggleCode('M000006-source');return false;">[Source]</a> <div class="method-source-code" id="M000006-source"> <pre> - # File lib/worker.rb, line 49 + # File lib/hive/worker.rb, line 49 49: def stop 50: logger.info "#{self.class} shutting down ..." 51: @console.stop if @console @@ -473,7 +473,7 @@ workers should override these methods onclick="toggleCode('M000014-source');return false;">[Source]</a> <div class="method-source-code" id="M000014-source"> <pre> - # File lib/worker.rb, line 95 + # File lib/hive/worker.rb, line 95 95: def start_tasks 96: end </pre> @@ -495,7 +495,7 @@ workers should override these methods onclick="toggleCode('M000015-source');return false;">[Source]</a> <div class="method-source-code" id="M000015-source"> <pre> - # File lib/worker.rb, line 98 + # File lib/hive/worker.rb, line 98 98: def stop_tasks 99: end </pre> doc/rdoc/classes/Hive/Worker.html @@ -55,8 +55,8 @@ <tr class="top-aligned-row"> <td>In:</td> <td> - <a href="../files/lib/worker_rb.html"> - lib/worker.rb + <a href="../files/lib/hive/worker_rb.html"> + lib/hive/worker.rb </a> </td> @@ -116,7 +116,7 @@ onclick="toggleCode('M000001-source');return false;">[Source]</a> <div class="method-source-code" id="M000001-source"> <pre> - # File lib/worker.rb, line 2 + # File lib/hive/worker.rb, line 2 2: def safe_trap(*signals) 3: signals.each { |s| trap(s) { yield } } 4: Thread.new { loop { sleep 1 } } if RUBY_PLATFORM =~ /mswin32/ doc/rdoc/classes/Kernel.html @@ -1 +1 @@ -Tue, 02 Jun 2009 11:43:22 -0700 +Sat, 06 Jun 2009 20:10:25 -0700 doc/rdoc/created.rid @@ -56,7 +56,7 @@ </tr> <tr class="top-aligned-row"> <td>Last Update:</td> - <td>Mon Jun 01 20:15:02 -0700 2009</td> + <td>Sat Jun 06 20:09:51 -0700 2009</td> </tr> </table> </div> @@ -70,7 +70,7 @@ <div id="description"> -0.1 +0.1.5 </div> doc/rdoc/files/doc/VERSION.html @@ -21,8 +21,8 @@ <h1 class="section-bar">Files</h1> <div id="index-entries"> <a href="files/doc/VERSION.html">doc/VERSION</a> - <a href="files/lib/scheduler_rb.html">lib/scheduler.rb</a> - <a href="files/lib/worker_rb.html">lib/worker.rb</a> + <a href="files/lib/hive/scheduler_rb.html">lib/hive/scheduler.rb</a> + <a href="files/lib/hive/worker_rb.html">lib/hive/worker.rb</a> </div> </div> </body> doc/rdoc/fr_file_index.html @@ -19,6 +19,6 @@ <frame src="fr_class_index.html" name="Classes" /> <frame src="fr_method_index.html" name="Methods" /> </frameset> - <frame src="files/lib/scheduler_rb.html" name="docwin" /> + <frame src="files/lib/hive/scheduler_rb.html" name="docwin" /> </frameset> </html> \ No newline at end of file doc/rdoc/index.html @@ -2,11 +2,11 @@ Gem::Specification.new do |s| s.name = %q{hive} - s.version = "0.1.4" + s.version = "0.1.5" s.required_rubygems_version = Gem::Requirement.new(">= 0") if s.respond_to? :required_rubygems_version= s.authors = ["Dan Yoder"] - s.date = %q{2009-06-05} + s.date = %q{2009-06-06} s.email = %q{dan@zeraweb.com} s.files = ["lib/hive/scheduler.rb", "lib/hive/worker.rb"] s.has_rdoc = true hive.gemspec @@ -8,7 +8,7 @@ module Hive def stop_tasks threads = Thread.list.select { |t| t.alive? && t != Thread.current } until threads.empty? - logger.info "#{threads.count} threads still running ... " + logger.info "#{threads.size} threads still running ... " threads.each { |t| t.kill && t != Thread.current } threads = threads.select { |t| t.alive? } end lib/hive/scheduler.rb doc/rdoc/files/lib/scheduler_rb.html doc/rdoc/files/lib/worker_rb.html 40b8e313b56dc5b194f62dfcea05288b6fb26636 Dan Yoder dan@zeraweb.com http://github.com/dyoder/hive/commit/1eea3ea9586b991a9f46e75e600eb68160cfa54a 1eea3ea9586b991a9f46e75e600eb68160cfa54a

2009-06-06T20:12:20-07:00

Fixed a bug with shutting down. 7e19adecfedc1631f4c450fbdba337bdd7351546 Dan Yoder dan@zeraweb.com