/*******************************************************************************
 * Copyright (c) 2016 CEA LIST.
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Created on: 24 févr. 2014
 *
 * Contributors:
 *  Arnault Lapitre (CEA LIST) arnault.lapitre@cea.fr
 *   - Initial API and implementation
 ******************************************************************************/

#ifndef COMMUNICATIONDEPENDENCY_H_
#define COMMUNICATIONDEPENDENCY_H_

#include <common/BF.h>

#include <fml/expression/AvmCode.h>

#include <fml/executable/AvmProgram.h>

#include <fml/operator/OperatorLib.h>


namespace sep
{


class ExecutionData;


class CommunicationDependency
{

public:

	/**
	 * Collect information about
	 * general communication
	 */
	static BF getCommunicationCode(
			AvmProgram * anAvmProgram, const BFCode & aCode,
			bool (*isCom)(AvmCode * comCode) , bool & hasMutableSchedule );


	static bool isCommunicationCode(AvmCode * comCode)
	{
		AVM_OPCODE opCode = comCode->getAvmOpCode();

		return( (opCode == AVM_OPCODE_INPUT      ) ||
				(opCode == AVM_OPCODE_INPUT_FROM ) ||
				(opCode == AVM_OPCODE_OUTPUT     ) ||
				(opCode == AVM_OPCODE_OUTPUT_TO  ) );
	}

	inline static BF getCommunicationCode(AvmProgram * anAvmProgram,
			const BFCode & aCode, bool & hasMutableSchedule)
	{
		return( getCommunicationCode(anAvmProgram, aCode,
				& CommunicationDependency::isCommunicationCode,
				hasMutableSchedule) );
	}


	static bool isInternalCommunicationCode(AvmCode * comCode)
	{
		AVM_OPCODE opCode = comCode->getAvmOpCode();
		AVM_OPCODE optimizCode = comCode->getOptimizedOpCode();

		return( ((opCode == AVM_OPCODE_INPUT     ) ||
				(opCode == AVM_OPCODE_INPUT_FROM ) ||
				(opCode == AVM_OPCODE_OUTPUT     ) ||
				(opCode == AVM_OPCODE_OUTPUT_TO  ) )  &&
				(optimizCode != AVM_OPCODE_INPUT_ENV) &&
				(optimizCode != AVM_OPCODE_OUTPUT_ENV) );
	}

	inline static BF getInternalCommunicationCode(AvmProgram * anAvmProgram,
			const BFCode & aCode, bool & hasMutableSchedule)
	{
		return( getCommunicationCode(anAvmProgram, aCode,
				& CommunicationDependency::isInternalCommunicationCode,
				hasMutableSchedule) );
	}


	/**
	 * Collect information about
	 * communication with the environment
	 */
	static bool isEnvironmentCom(AvmCode * comCode)
	{
		AVM_OPCODE optimizeCode = comCode->getOptimizedOpCode();

		return( (optimizeCode == AVM_OPCODE_INPUT_ENV) ||
				(optimizeCode == AVM_OPCODE_OUTPUT_ENV) );
	}

	inline static BF getEnvironmentCom(AvmProgram * anAvmProgram,
			const BFCode & aCode, bool & hasMutableSchedule)
	{
		return( getCommunicationCode(anAvmProgram, aCode,
				& CommunicationDependency::isEnvironmentCom,
				hasMutableSchedule) );
	}


	static bool isEnvironmentInputCom(AvmCode * comCode)
	{
		return( comCode->getOptimizedOpCode() == AVM_OPCODE_INPUT_ENV );
	}

	inline static BF getEnvironmentInputCom(AvmProgram * anAvmProgram,
			const BFCode & aCode, bool & hasMutableSchedule)
	{
		return( getCommunicationCode(anAvmProgram, aCode,
				& CommunicationDependency::isEnvironmentInputCom,
				hasMutableSchedule) );
	}


	static bool isEnvironmentOutputCom(AvmCode * comCode)
	{
		return( comCode->getOptimizedOpCode() == AVM_OPCODE_OUTPUT_ENV );
	}

	inline static BF getEnvironmentOutputCom(AvmProgram * anAvmProgram,
			const BFCode & aCode, bool & hasMutableSchedule)
	{
		return( getCommunicationCode(anAvmProgram, aCode,
				& CommunicationDependency::isEnvironmentOutputCom,
				hasMutableSchedule) );
	}


	/**
	 * Collect information about
	 * static input enabled communication
	 */
	static void computeInputEnabledCom(AvmProgram * anAvmProgram,
			ListOfInstanceOfPort & inputEnabledCom, AvmCode * aCode,
			bool (*isCom)(AvmCode * comCode) , bool & hasMutableSchedule );


	static bool isInputEnabledCom(AvmCode * comCode)
	{
		return( (comCode->hasOpCode( AVM_OPCODE_INPUT, AVM_OPCODE_INPUT_FROM ))
				&& (comCode->getOptimizedOpCode() != AVM_OPCODE_INPUT_ENV) );
	}

	inline static void computeInputEnabledCom(
			AvmProgram * anAvmProgram, AvmCode * aCode)
	{
		bool hasMutableSchedule = false;

		computeInputEnabledCom( anAvmProgram,
				anAvmProgram->getInputEnabledCom(), aCode,
				& CommunicationDependency::isInputEnabledCom,
				hasMutableSchedule );

		anAvmProgram->setMutableCommunication( hasMutableSchedule );
	}


	static bool isInputEnabledSave(AvmCode * comCode)
	{
		return( comCode->isOpCode( AVM_OPCODE_INPUT_SAVE ) );
	}

	inline static void computeInputEnabledSave(
			AvmProgram * anAvmProgram, AvmCode * aCode)
	{
		bool hasMutableSchedule = false;

		computeInputEnabledCom( anAvmProgram,
				anAvmProgram->getInputEnabledSave(), aCode,
				& CommunicationDependency::isInputEnabledSave,
				hasMutableSchedule );

		anAvmProgram->setMutableCommunication( hasMutableSchedule );
	}


	/**
	 * Collect information about
	 * input / output internal communication
	 */
	static bool isInputCom(AvmCode * comCode)
	{
		return( (comCode->hasOpCode( AVM_OPCODE_INPUT, AVM_OPCODE_INPUT_FROM ))
				&& (comCode->getOptimizedOpCode() != AVM_OPCODE_INPUT_ENV) );
	}

	inline static BF getInputCom(AvmProgram * anAvmProgram,
			const BFCode & aCode, bool & hasMutableSchedule)
	{
		return( getCommunicationCode(anAvmProgram, aCode,
				& CommunicationDependency::isInputCom, hasMutableSchedule) );
	}

	static void computeInputCom(AvmProgram * anAvmProgram, AvmCode * aCode)
	{
		bool hasMutableSchedule = false;

		computeInputEnabledCom(anAvmProgram, anAvmProgram->getInputCom(), aCode,
				& CommunicationDependency::isInputCom, hasMutableSchedule);

		anAvmProgram->setMutableCommunication( hasMutableSchedule );
	}


	static bool isOutputCom(AvmCode * comCode)
	{
		return( (comCode->hasOpCode( AVM_OPCODE_OUTPUT, AVM_OPCODE_OUTPUT_TO ))
				&& (comCode->getOptimizedOpCode() != AVM_OPCODE_OUTPUT_ENV) );
	}

	inline static BF getOutputCom(AvmProgram * anAvmProgram,
			const BFCode & aCode, bool & hasMutableSchedule)
	{
		return( getCommunicationCode(anAvmProgram, aCode,
				& CommunicationDependency::isOutputCom, hasMutableSchedule) );
	}


	static void computeOutputCom( AvmProgram * anAvmProgram, AvmCode * aCode)
	{
		bool hasMutableSchedule = false;

		computeInputEnabledCom(anAvmProgram, anAvmProgram->getOutputCom(), aCode,
				& CommunicationDependency::isOutputCom, hasMutableSchedule);

		anAvmProgram->setMutableCommunication( hasMutableSchedule );
	}


	/**
	 * Collect information about
	 * runtime input enabled communication
	 */
	static void computeInputEnabledCom(const ExecutionData & anED,
			const RuntimeID & aRID, ListOfInstanceOfPort & inputEnabledCom,
			AvmCode * aCode, bool (*isCom)(AvmCode * comCode) );


	inline static void computeInputEnabledCom(
			const ExecutionData & anED, const RuntimeID & aRID,
			ListOfInstanceOfPort & inputEnabledCom, AvmCode * aCode)
	{
		computeInputEnabledCom(anED, aRID, inputEnabledCom, aCode,
				& CommunicationDependency::isInputEnabledCom );
	}

	inline static void computeInputEnabledSave(
			const ExecutionData & anED, const RuntimeID & aRID,
			ListOfInstanceOfPort & inputEnabledSave, AvmCode * aCode )
	{
		computeInputEnabledCom(anED, aRID, inputEnabledSave, aCode,
				& CommunicationDependency::isInputEnabledSave );
	}


};

} /* namespace sep */

#endif /* COMMUNICATIONDEPENDENCY_H_ */