'''
threadManager.py

Copyright 2006 Andres Riancho

This file is part of w3af, w3af.sourceforge.net .

w3af is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation version 2 of the License.

w3af is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with w3af; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

'''
import core.controllers.outputManager as om
from core.controllers.threads.threadpool import *
import core.data.kb.config as cf

class threadManager:
	'''
	This class manages threads.
	
	@author: Andres Riancho ( andres.riancho@gmail.com )
	'''	
	
	def __init__( self ):
		self._maxThreads = cf.cf.getData('maxThreads' ) or 0
		self._daemonThreads = []
		self.informed = False
		self._threadPool = ThreadPool( self._maxThreads )
		
	def setMaxThreads( self, threads ):
		if self._maxThreads == threads:
			self._maxThreads = threads
		elif self._maxThreads > threads:
			self._threadPool.dismissWorkers( self._maxThreads - threads )
			self._maxThreads = threads
		elif self._maxThreads < threads:
			self._threadPool.createWorkers( threads - self._maxThreads )
			self._maxThreads = threads

	def getMaxThreads( self ):
		return self._maxThreads
		
	def startDaemon( self, threadObj ):
		om.out.debug('Starting daemon thread: ' + str(threadObj) )
		threadObj.setDaemon(1)
		threadObj.start()
		self._daemonThreads.append( threadObj )
	
	def stopDaemon( self, threadObj ):
		for daemon in self._daemonThreads:
			if daemon == threadObj:
				threadObj.stop()
				om.out.debug('Calling join on daemon thread: ' + str(threadObj) )
				threadObj.join(self._waitJoin)
				self._threads.remove( threadObj )
				
	def stopAllDaemons( self ):
		om.out.debug('Calling join on all daemon threads')
		for thread in self._daemonThreads:
			thread.stop()
			om.out.debug('Calling join on daemon thread: ' + str(thread) )
			thread.join(self._waitJoin)
		
	def startFunction( self, target, args=(), restrict=True, ownerObj=None ):
		if self._maxThreads == 0:
			# Just start the function
			if not self.informed:
				om.out.debug('Threading is disabled.' )
				self.informed = True
			apply( target, args, {} )
		else:
			# Assign a job to a thread in the thread pool
			om.out.debug('Assigning ' + str(target) + ' to a thread in the thread pool.' )
			wr = WorkRequest( target, args=args, ownerObj=ownerObj )
			self._threadPool.putRequest( wr )
			
	def join( self, ownerObj=None, joinAll=False ):
		self._threadPool.wait( ownerObj, joinAll )

threadManagerObj = threadManager()