--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/genericopenlibs/openenvcore/backend/src/signalserver/server/signalserver.cpp	Tue Feb 02 02:01:42 2010 +0200
@@ -0,0 +1,270 @@
+// Copyright (c) 2005-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:
+// Name        : signalserver.cpp
+// Part of     : Signal Server
+//
+
+
+
+#include <e32base.h>
+#include "signalserver.h"
+#include "signalsession.h"
+#include "signalcommon.h"
+#include "tsignalmessage.h"
+#include <signal.h>
+
+
+
+static void RunTheServerL()
+	{
+	CSignalServer* lServer = 0;
+
+	User::LeaveIfError(RThread::RenameMe(KServerName));
+
+	CActiveScheduler* scheduler = new (ELeave) CActiveScheduler;
+	CleanupStack::PushL(scheduler);
+	CActiveScheduler::Install(scheduler);
+	lServer = static_cast<CSignalServer*>(CSignalServer::NewL());
+	RProcess::Rendezvous(KErrNone);
+	CActiveScheduler::Start();
+	if(lServer)
+		{
+		delete lServer;
+		lServer = 0;
+		}
+	CleanupStack::PopAndDestroy();
+	}
+
+static TInt RunServer()
+	{
+	TRAPD(ret, RunTheServerL());
+	return ret;
+	}
+
+//-------------------------------------------------------------------------------
+// Function Name : E32Main()
+// Description   : Entry point for the server process.
+//
+//-------------------------------------------------------------------------------
+TInt E32Main()
+	{
+	TInt ret = KErrNoMemory;
+	CTrapCleanup* cleanup = CTrapCleanup::New();
+	if (cleanup)
+		{
+		ret = RunServer();
+		delete cleanup;
+		}
+	return ret;
+	}
+
+CSignalServer::CSignalServer(CActive::TPriority aPriority) : CServer2(aPriority, ESharableSessions)
+	{
+	iSessionCount = 0;
+	}
+
+CSignalServer::~CSignalServer()
+	{
+	if(iShutDown)
+		{
+		delete iShutDown;
+		iShutDown = 0;
+		}
+	}
+
+CServer2* CSignalServer::NewL()
+	{
+	CSignalServer* self = new (ELeave)CSignalServer(EPriorityStandard);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop();
+	return self;
+	}
+
+void CSignalServer::ConstructL()
+	{
+	StartL(KServerName);
+	iShutDown = CSigShutDown::NewL();
+	RPipe::Init();
+	iShutDown->Start();
+	}
+
+TInt CSignalServer::CheckForCapability(const RMessage2& aMessage)
+	{
+	RThread lThread;
+	RProcess lProcess;
+	TInt lRetVal = KErrGeneral;
+
+	TInt lPid = aMessage.Int0();
+	TInt lSigNo = aMessage.Int1();
+
+	if(lSigNo != SIGKILL && lSigNo != SIGSTOP)
+		return KErrNone;
+
+	lRetVal = aMessage.Client(lThread);
+	if(lRetVal!= KErrNone)
+		return lRetVal;
+	lRetVal = lThread.Process(lProcess);
+	if(lRetVal!= KErrNone)
+		return lRetVal;
+
+	if(!lProcess.HasCapability(ECapabilityPowerMgmt) && lPid!=lProcess.Id())
+		lRetVal = KErrGeneral;
+	else
+		lRetVal = KErrNone;
+
+	lThread.Close();
+	lProcess.Close();
+	return lRetVal;
+	}
+
+CSession2* CSignalServer::NewSessionL(const TVersion& aVersion,const RMessage2& /*aMessage2*/) const
+	{
+	TVersion v(KSignalServMajorVersionNumber, KSignalServMinorVersionNumber, KSignalServBuildVersionNumber);
+
+	if (!User::QueryVersionSupported(v, aVersion))
+    	{
+    	User::Leave(KErrNotSupported);
+    	}
+
+	return CSignalSession::NewL(); // TBD
+	}
+
+void CSignalServer::AddSession()
+	{
+	iSessionCount++;
+	iShutDown->Cancel();
+	}
+
+void CSignalServer::RemoveSession()
+	{
+	iSessionCount--;
+
+	TInt lIdx = 0;
+	for(lIdx = 0; lIdx < iProcessHdlList.Count();)
+		{
+		TProcessId lPid(iProcessHdlList[lIdx].mPid);
+		RProcess lProcHdl;
+		if(lProcHdl.Open(lPid) != KErrNone)
+			{
+			iProcessHdlList.Remove(lIdx);
+			}
+		else
+			{
+			lProcHdl.Close();
+			lIdx++;
+			}
+		}
+
+	if( iSessionCount == 0 )
+		{
+		iShutDown->Start();
+		}
+	}
+
+void CSignalServer::ServiceL(const RMessage2& aMessage)
+	{
+	TInt lPid = 0;
+	TOeProcessHdl lTmpHdl;
+	TInt lIndex = 0;
+	TUint8 lSignal = 0;
+	RThread lClientThread;
+	RProcess lProcess;
+
+	switch (aMessage.Function ())
+		{
+		//if this query is related to message Q, call
+		//ServiceL of message Q handler
+		case ESendSignal:
+			if(CheckForCapability(aMessage) != KErrNone)
+				aMessage.Complete(KErrPermissionDenied);
+			else
+				{
+				// serialize data
+				lPid = aMessage.Int0();
+				lSignal = aMessage.Int1();
+
+				lTmpHdl.mPid = lPid;
+				lIndex = iProcessHdlList.Find(lTmpHdl,TIdentityRelation<TOeProcessHdl>(TOeProcessHdl::MatchByPid));
+
+				if(lIndex == KErrNotFound)
+					aMessage.Complete(KErrGeneral);
+				else
+					{
+					TSignalMessage lMsg;
+					lMsg.mType = TSignalMessage::ESignal;
+					lMsg.mSignal = lSignal;
+					TBuf8<KSigMsgLength> lMsgBuf;
+					lMsg.Marshall(lMsgBuf);
+
+					iProcessHdlList[lIndex].mPipe.WriteBlocking(lMsgBuf,KSigMsgLength);
+					aMessage.Complete (KErrNone);
+					}
+				}
+			break;
+		case ESendSignalValue:
+			if(CheckForCapability(aMessage) != KErrNone)
+				aMessage.Complete(KErrPermissionDenied);
+			else
+				{
+				// serialize data
+				lPid = aMessage.Int0();
+				lSignal = aMessage.Int1();
+				TUint32 lValue = (TUint32)aMessage.Int2();
+				lTmpHdl.mPid = lPid;
+
+				lIndex = iProcessHdlList.Find(lTmpHdl,TIdentityRelation<TOeProcessHdl>(TOeProcessHdl::MatchByPid));
+				if(lIndex == KErrNotFound)
+					aMessage.Complete(KErrGeneral);
+				else
+					{
+					TSignalMessage lMsg;
+					lMsg.mType = TSignalMessage::ESignalValuePair;
+					lMsg.mSigVal.mSignal = lSignal;
+					lMsg.mSigVal.mValue = lValue;
+					TBuf8<KSigMsgLength> lMsgBuf;
+					lMsg.Marshall(lMsgBuf);
+
+					iProcessHdlList[lIndex].mPipe.WriteBlocking(lMsgBuf,KSigMsgLength);
+					aMessage.Complete (KErrNone);
+					}
+				}
+			break;
+		case ESendPipe:
+			aMessage.Client(lClientThread);
+			lClientThread.Process(lProcess);
+			lPid = lProcess.Id();
+
+			lTmpHdl.mPid = lPid;
+			lIndex = iProcessHdlList.Find(lTmpHdl,TIdentityRelation<TOeProcessHdl>(TOeProcessHdl::MatchByPid));
+			if(lIndex == KErrNotFound)
+				{
+				TOeProcessHdl lHdl;
+				lHdl.mPid = lPid;
+				lHdl.mPipe.Open(aMessage,0);
+				iProcessHdlList.Append(lHdl);
+				}
+			else
+				{
+				if(iProcessHdlList[lIndex].mPipe.Open(aMessage,0)!=KErrNone)
+					aMessage.Complete(KErrGeneral);
+				}
+			aMessage.Complete(KErrNone);
+			break;
+		default:
+			aMessage.Complete(KErrNotSupported);
+			break;
+		}
+		return;
+	}