// Copyright (c) 2004-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of "Eclipse Public License v1.0"
// which accompanies this distribution, and is available
// at the URL "http://www.eclipse.org/legal/epl-v10.html".
//
// Initial Contributors:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
// Message sender header file
// 
//

/**
 @file MsgSender.h
*/

#ifndef MSGSENDER_H
#define MSGSENDER_H

#include <e32base.h>
#include <./libc/limits.h>
#include "ExpireTimer.h"
#include "DHCP_Std.h"

class TInetAddr;
class RSocket;

const TInt KMicrosecondsInSecs = 1000000;

class MMSListener
/**
  * Just a notification interface
  *
  * @internalTechnology
  */
	{
public:
	virtual TInt MSReportError(TInt aError) = 0;
	};

class CMessageSender : public CActive, public MExpireTimer
	{
public:
	CMessageSender(MMSListener* aMMSListener, RSocket& aSocket, TTime *aTaskStartedAtCopy, const TUint aFamily);
	virtual ~CMessageSender();

	//if aRetransmitAfterMcSecs == 0 than just one transmition happens
	void SendL(TInetAddr& aAddr, const TDesC8& aMsg, TTimeIntervalMicroSeconds aRetransmitAfterSecs, TInt aRetryCount);
	void Cancel();
   
	//MExpireTimer virtuals
	virtual void TimerExpired();
	void SetTaskStartedTime(TTime aTaskStartedAtCopy);
	const TUint GetFamilyType();

protected:
	virtual void DoCancel();
	virtual void RunL();
	virtual TInt RunError(TInt aError);

protected:
   virtual TBool SendingContinues() const;
   virtual TBool CalculateDelay();

   void StartTimerL();

protected:
	HBufC8* iMsg;
	CExpireTimer* iExpireTimer;
	TInetAddr iAddr;
	RSocket& iSocket;
	TTimeIntervalMicroSeconds32 iMicroSecs;
	MMSListener* iMMSListener;
   TInt iRetryCount; //counts how many times the message's been successfully sent
   TInt iRetryDuration;
   TInt iMaxRetryCount; //counts the max times the message has to be sent
   TTime iTaskStartedAtCopy;
	const TUint iFamily;
	};

inline CMessageSender::CMessageSender(MMSListener* aMMSListener,RSocket& aSocket, TTime *aTaskStartedAtCopy, const TUint aFamily) :
      CActive(EPriorityStandard), iSocket(aSocket),iMMSListener(aMMSListener),iTaskStartedAtCopy(*aTaskStartedAtCopy),iFamily(aFamily)
      {
      }
	  
inline void CMessageSender::SetTaskStartedTime(TTime aTaskStartedAtCopy)
     {
     iTaskStartedAtCopy = aTaskStartedAtCopy;
     }

inline const TUint CMessageSender::GetFamilyType()
     {
     return iFamily;
     }

#endif