Navigation

Changeset 312

Timestamp:

01/22/08 01:45:16 (7 months ago)

Author:

gethema..@gmail.com

Message:

fixes for query all workers and starting workers which don't exist

Files:

r305	r312
111	111	return if @live_workers[worker_name_key]
112	112	worker_options.delete(:worker)
113		require worker_name
114		worker_klass = Object.const_get(packet_classify(worker_name))
115		fork_and_load(worker_klass,worker_options)
	113	begin
	114	require worker_name
	115	worker_klass = Object.const_get(packet_classify(worker_name))
	116	fork_and_load(worker_klass,worker_options)
	117	rescue MissingSourceFile
	118	puts "no such worker #{worker_name}"
	119	return
	120	end
116	121	end
117	122

r303	r312
46	46	end
47	47	end
48
49		#
	48
	49	#
50	50	def pass_worker_info(t_data)
51	51	worker_name_key = gen_worker_key(t_data[:worker],t_data[:job_key])
…	…
55	55	send_object(info_response)
56	56	end
57
	57
58	58	def all_worker_info(t_data)
59	59	info_response = []
…	…
67	67	def query_all_worker_status(p_data)
68	68	dumpable_status = { }
69		reactor.live_workers.each { \|key,value\| dumpable_status[key] = ~~value.worker_status~~ }
	69	reactor.live_workers.each { \|key,value\| dumpable_status[key] = reactor.result_hash[key] }
70	70	send_object(dumpable_status)
71	71	end