/*
* Copyright (c) 2002 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: 
*    Implementation for the RDosEventRcv class.
*
*/


#include "DosSvrServices.h"
#include "dosclientserver.h"

// ---------------------------------------------------------
// RDosEventRcv Constructor
// ---------------------------------------------------------
//  

RDosEventRcv::RDosEventRcv()
{
	iParamContent = NULL;
	iContentPtr = NULL;
	iRegistered = EFalse;
	iQueue = EQueue;
}


// ---------------------------------------------------------
// RDosEventRcv Destructor
// ---------------------------------------------------------
//  

RDosEventRcv::~RDosEventRcv()
{
	if(iParamContent) delete iParamContent;
	if(iContentPtr) delete iContentPtr;
}

// ---------------------------------------------------------
// RDosEventRcv::Open
// ---------------------------------------------------------
//  

TInt RDosEventRcv::Open(RDosServer& aServer)
{
	return CreateSubSession(aServer,EDosCreateEventRcvSubSession, TIpcArgs(TIpcArgs::ENothing, TIpcArgs::ENothing, KAutoComplete));
}


// ---------------------------------------------------------
// RDosEventRcv::Register
// ---------------------------------------------------------
//  

TInt RDosEventRcv::Register(TInt aEvent,TInt aParamSize,TQueueType aQueue)
{
	if(iRegistered)
			return KErrAlreadyExists;
	
	if(iParamContent)
	{
	   delete iParamContent;
	}

	iParamContent = HBufC8::New(aParamSize);
	if(iParamContent)
	{
		if(iContentPtr)
		{
		   delete iContentPtr;
		}

		iContentPtr = new TPtr8(iParamContent->Des());

		if(iContentPtr)
		{
			TInt err = SendReceive(ERegisterEvent, TIpcArgs(aEvent, TIpcArgs::ENothing, KAutoComplete));

			if(!err) 
			{
				iRegistered = ETrue;
				iQueue = aQueue;
				iDosEvent = aEvent;
			}

			return err;
		}
	}
	return KErrNoMemory;
}

// ---------------------------------------------------------
// RDosEventRcv::UnRegister
// ---------------------------------------------------------
//  

void RDosEventRcv::UnRegister()
{
	if(iRegistered) 
	{
		TInt err = SendReceive(EUnRegisterEvent, TIpcArgs(TIpcArgs::ENothing, TIpcArgs::ENothing, KAutoComplete));

		if(!err)
		{

			delete iContentPtr;
			iContentPtr=NULL;
			delete iParamContent;
			iParamContent = NULL;

			iRegistered = EFalse;
		}
	}
}

// ---------------------------------------------------------
// RDosEventRcv::WaitEvent
// ---------------------------------------------------------
//  

TInt RDosEventRcv::WaitEvent(TRequestStatus& aStatus) const
{
	if(iRegistered)
	{
		SendReceive(EWaitEvent, TIpcArgs(iQueue, iContentPtr, 0), aStatus);

		return KErrNone;
	}
	return KErrAbort; //It can't wait when it's not registered.
}

// ---------------------------------------------------------
// RDosEventRcv::CancelWaitEvent
// ---------------------------------------------------------
//  

TInt RDosEventRcv::CancelWaitEvent() const
{
	if(iRegistered)
	{
		SendReceive(ECancelWaitEvent, TIpcArgs(TIpcArgs::ENothing, TIpcArgs::ENothing, KAutoComplete));

		return KErrNone;
	}
	return KErrAbort; //It can't cancel wait when it's not registered.
}