Changeset 286
- Timestamp:
- 12/17/07 10:07:26 (8 months ago)
- Files:
-
- trunk/README (modified) (2 diffs)
- trunk/framework/double_keyed_hash.rb (modified) (1 diff)
- trunk/framework/packet_master.rb (modified) (1 diff)
- trunk/server/master_worker.rb (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/README
r280 r286 11 11 Copyright (c) 2006 Ezra Zygmuntowicz,skaar[at]waste[dot]org, 12 12 13 Copyright (c) 2007 Hemant Kumar (mail[at]gnufied[dot]org) 13 Copyright (c) 2007 Hemant Kumar (gethemant [at] gmail.com ) 14 14 15 15 16 == Usage … … 415 416 416 417 You are encouraged to look into framework directory and see the code that implements all this stuff. The guts of 417 this new version of bdrb is based on this library which will be released soon as a separate entity.418 this new version of bdrb is based on packet library(http://packet.googlecode.com ) 418 419 419 420 trunk/framework/double_keyed_hash.rb
r283 r286 16 16 17 17 def delete(key) 18 worker_key = @keys1[key] 18 19 @keys1.delete(key) 19 @internal_hash.delete(key) 20 if worker_key 21 @internal_hash.delete(worker_key) 22 else 23 @internal_hash.delete(key) 24 end 20 25 end 21 26 trunk/framework/packet_master.rb
r283 r286 63 63 worker_instance.receive_data(raw_data) if worker_instance.respond_to?(:receive_data) 64 64 rescue DisconnectError => sock_error 65 re ad_ios.delete(t_sock)65 remove_worker(t_sock) 66 66 end 67 end 68 69 def remove_worker(t_sock) 70 @live_workers.delete(t_sock.fileno) 71 read_ios.delete(t_sock) 67 72 end 68 73 trunk/server/master_worker.rb
r283 r286 55 55 ask_worker(worker_name,:job_key => t_data[:job_key],:type => :request, :data => { :worker_method => :exit}) 56 56 rescue Packet::DisconnectError => sock_error 57 reactor.live_workers.delete(worker_name_key) 57 # reactor.live_workers.delete(worker_name_key) 58 reactor.remove_worker(sock_error) 58 59 rescue 59 60 debug_logger.info($!.to_s)
