@@ -1,3 +1,4 @@ +examples/queue_worker_example.rb examples/token_worker_example.rb History.rdoc lib/init.rb @@ -11,7 +12,6 @@ Manifest politics.gemspec Rakefile README.rdoc -test/bucket_worker_test.rb test/static_queue_worker_test.rb test/test_helper.rb test/token_worker_test.rb Manifest @@ -4,12 +4,15 @@ require 'politics/token_worker' # Test this example by starting memcached locally and then in two irb sessions, run this: # -# require 'token_worker_example' -# p = Politics::TokenWorkerExample.new -# p.start # # You can then watch as one of them is elected leader. You can kill the leader and verify # the backup process is elected after approximately iteration_length seconds. +# +=begin + require 'token_worker_example' + p = Politics::TokenWorkerExample.new + p.start +=end module Politics class TokenWorkerExample include Politics::TokenWorker @@ -20,12 +23,12 @@ module Politics def start process do - puts "PID #{$$} processing at #{Time.now}..." + puts "PID #{$$} processing at #{Time.now}..." end end def memcached_servers - ['localhost:11211'] + ['localhost:11211'] end end examples/token_worker_example.rb @@ -78,7 +78,6 @@ module Politics @bucket_count = bucket_count initialize_buckets - start_drb register_with_bonjour log.info { "Registered #{self} in group #{group_name} at port #{@port}" } @@ -228,21 +227,19 @@ module Politics def register_with_bonjour + server = DRb.start_service(nil, self) + @uri = DRb.uri + @port = URI.parse(DRb.uri).port + # Register our DRb server with Bonjour. handle = Net::DNS::MDNSSD.register("#{self.group_name}-#{local_ip}-#{$$}", "_#{group_name}._tcp", 'local', @port) ['INT', 'TERM'].each { |signal| - trap(signal) { handle.stop } - } - end - - def start_drb - server = DRb.start_service(nil, self) - @uri = DRb.uri - @port = URI.parse(DRb.uri).port - ['INT', 'TERM'].each { |signal| - trap(signal) { server.stop_service } + trap(signal) do + handle.stop + server.stop_service + end } end lib/politics/static_queue_worker.rb @@ -9,11 +9,11 @@ Gem::Specification.new do |s| s.require_path = 'lib' - # get this easily and accurately by running 'Dir.glob("{lib,test}/**/*")' + # get this easily and accurately by running 'Dir.glob("{lib,examples}/**/*")' # in an IRB session. However, GitHub won't allow that command hence # we spell it out. - s.files = ["README.rdoc", "LICENSE", "History.rdoc", "Rakefile", "lib/init.rb", "lib/politics", "lib/politics/bucket_worker.rb", "lib/politics/discoverable_node.rb", "lib/politics/token_worker.rb", "lib/politics/version.rb", "lib/politics.rb"] - s.test_files = ["test/bucket_worker_test.rb", "test/political_test.rb", "test/test_helper.rb", "test/token_worker_test.rb"] + s.files = ["lib/init.rb", "lib/politics", "lib/politics/discoverable_node.rb", "lib/politics/static_queue_worker.rb", "lib/politics/token_worker.rb", "lib/politics/version.rb", "lib/politics.rb", "examples/queue_worker_example.rb", "examples/token_worker_example.rb"] + s.test_files = ["test/static_queue_worker_test.rb", "test/test_helper.rb", "test/token_worker_test.rb"] s.has_rdoc = true s.rdoc_options = ["--quiet", "--title", "Politics documentation", "--opname", "index.html", "--line-numbers", "--main", "README.rdoc", "--inline-source"] s.extra_rdoc_files = ["README.rdoc", "History.rdoc", "LICENSE"] politics.gemspec 3122d61670777c1210815c0b4479cd6c220eb140 Mike Perham mperham@gmail.com http://github.com/mperham/politics/commit/8b7b8fcfd36811e53b6e8a7ac51d318a6268e174 8b7b8fcfd36811e53b6e8a7ac51d318a6268e174 2008-10-28T14:55:53-07:00 2008-10-28T14:55:53-07:00 Add static queue worker example Update gemspec with latest files. TODO Something is still very wrong with signal handling with SQW. 3fa5a49c2cd0b197f9aa79556b2e8837bf757109 Mike Perham mperham@gmail.com