#!/usr/bin/env python
import Pyro.core
import Pyro.errors
import Queue
from workitem import Workitem
import os, socket, sys
from math import sqrt

WORKERNAME = "Worker_%d@%s" % (os.getpid(), socket.gethostname())
Pyro.core.initClient()


def factorize(n):
	def isPrime(n):
		return not [x for x in xrange(2,int(sqrt(n))+1) if n%x == 0]
	primes = []
	candidates = xrange(2,n+1)
	candidate = 2
	while not primes and candidate in candidates:
		if n%candidate == 0 and isPrime(candidate):
			primes = primes + [candidate] + factorize(n/candidate)
		candidate += 1            
	return primes
    
def process(item):
	print "factorizing",item.data,"-->",
	sys.stdout.flush()
	item.result=factorize(int(item.data))
	print item.result
	item.processedBy = WORKERNAME

def main():
	dispatcher = Pyro.core.getProxyForURI("PYRONAME://:Distributed2.dispatcher")
	print "This is worker",WORKERNAME
	
	print "getting work from dispatcher."
	
	while True:
		try:
			item = dispatcher.getWork()
		except Queue.Empty:
			print "no work available yet."
		else:
			process(item)
			dispatcher.putResult(item)
			


if __name__=="__main__":
	main()