--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/esock_messages/src/DataMonitorMessages.cpp	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,141 @@
+// Copyright (c) 2006-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:
+//
+
+/**
+ @file
+ @internalTechnology
+*/
+
+#include "datamonitormessages.h"
+#include <comms-infras/ss_datamon_apiext.h> // MDataMonitorProtocolReq
+#include <elements/responsemsg.h> 		// CResponseMsg
+
+using namespace ESock;
+using namespace Elements;
+using namespace NetInterfaces;
+
+enum TMobilityRequestMessages
+	{
+	EDataMonitoringMsgRequestDataTransferred = 0,
+	EDataMonitoringMsgCancelDataTransferredRequest,
+	EDataMonitoringMsgRequestDataSentNotification,
+	EDataMonitoringMsgCancelDataSentNotificationRequest,
+	EDataMonitoringMsgRequestDataReceivedNotification,
+	EDataMonitoringMsgCancelDataReceivedNotificationRequest,
+	};
+
+/*-------------------------------------------------------
+	Client -> Server messages
+  -------------------------------------------------------*/
+
+EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TRequestDataTransferred, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgRequestDataTransferred)
+END_ATTRIBUTE_TABLE()
+
+EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TCancelDataTransferredRequest, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgCancelDataTransferredRequest)
+END_ATTRIBUTE_TABLE()
+
+EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TRequestDataSentNotification, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgRequestDataSentNotification)
+	REGISTER_ATTRIBUTE(TRequestDataSentNotification, iDelta, TMeta<TUint>)
+	REGISTER_ATTRIBUTE(TRequestDataSentNotification, iSentBytes, TMeta<TUint>)
+END_ATTRIBUTE_TABLE()
+
+EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TCancelDataSentNotificationRequest, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgCancelDataSentNotificationRequest)
+END_ATTRIBUTE_TABLE()
+
+EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TRequestDataReceivedNotification, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgRequestDataReceivedNotification)
+	REGISTER_ATTRIBUTE(TRequestDataReceivedNotification, iDelta, TMeta<TUint>)
+	REGISTER_ATTRIBUTE(TRequestDataReceivedNotification, iReceivedBytes, TMeta<TUint>)
+END_ATTRIBUTE_TABLE()
+
+EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TCancelDataReceivedNotificationRequest, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgCancelDataReceivedNotificationRequest)
+END_ATTRIBUTE_TABLE()
+
+EXPORT_C void TRequestDataTransferred::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)
+	{
+	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));
+	CDataMonitoringResponder* responder = CDataMonitoringResponder::NewL(aResponseMsg);
+	i->RequestDataTransferred(responder, aSubSessionUniqueId);
+	}
+
+EXPORT_C void TCancelDataTransferredRequest::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)
+	{
+	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));
+	i->CancelDataTransferredRequest(aSubSessionUniqueId);
+	aResponseMsg.Complete(KErrNone);
+	}
+
+EXPORT_C void TRequestDataReceivedNotification::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)
+	{
+	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));
+	CDataMonitoringResponder* responder = CDataMonitoringResponder::NewL(aResponseMsg);
+	i->RequestDataReceivedNotification(responder, iDelta, iReceivedBytes, aSubSessionUniqueId);
+	}
+
+EXPORT_C void TCancelDataReceivedNotificationRequest::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)
+	{
+	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));
+	i->CancelDataReceivedNotificationRequest(aSubSessionUniqueId);
+	aResponseMsg.Complete(KErrNone);
+	}
+
+EXPORT_C void TRequestDataSentNotification::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)
+	{
+	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));
+	CDataMonitoringResponder* responder = CDataMonitoringResponder::NewL(aResponseMsg);
+	i->RequestDataSentNotification(responder, iDelta, iSentBytes, aSubSessionUniqueId);
+	}
+
+EXPORT_C void TCancelDataSentNotificationRequest::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)
+	{
+	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));
+	i->CancelDataSentNotificationRequest(aSubSessionUniqueId);
+	aResponseMsg.Complete(KErrNone);
+	}
+
+DEFINE_MVIP_CTR(TRequestDataTransferred);
+DEFINE_MVIP_CTR(TCancelDataTransferredRequest);
+DEFINE_MVIP_CTR(TRequestDataSentNotification);
+DEFINE_MVIP_CTR(TCancelDataSentNotificationRequest);
+DEFINE_MVIP_CTR(TRequestDataReceivedNotification);
+DEFINE_MVIP_CTR(TCancelDataReceivedNotificationRequest);
+
+const TImplementationProxy DataMonitoringReqMsgImplementationTable[] =
+	{
+	MVIP_CTR_ENTRY(EDataMonitoringMsgRequestDataTransferred, TRequestDataTransferred),
+	MVIP_CTR_ENTRY(EDataMonitoringMsgCancelDataTransferredRequest, TCancelDataTransferredRequest),
+	MVIP_CTR_ENTRY(EDataMonitoringMsgRequestDataSentNotification, TRequestDataSentNotification),
+	MVIP_CTR_ENTRY(EDataMonitoringMsgCancelDataSentNotificationRequest, TCancelDataSentNotificationRequest),
+	MVIP_CTR_ENTRY(EDataMonitoringMsgRequestDataReceivedNotification, TRequestDataReceivedNotification),
+	MVIP_CTR_ENTRY(EDataMonitoringMsgCancelDataReceivedNotificationRequest, TCancelDataReceivedNotificationRequest),
+	};
+
+EXPORT_C CDataMonitoringMsgPluginInfo* CDataMonitoringMsgPluginInfo::NewL(TAny* /* aParams */)
+	{
+	return new(ELeave) CDataMonitoringMsgPluginInfo();
+	}
+
+EXPORT_C const TImplementationProxy* CDataMonitoringMsgPluginInfo::ImplementationProxy() const
+	{
+	return DataMonitoringReqMsgImplementationTable;
+	}
+
+EXPORT_C TInt CDataMonitoringMsgPluginInfo::ImplementationProxyTableSize() const
+	{
+	return sizeof(DataMonitoringReqMsgImplementationTable) / sizeof(DataMonitoringReqMsgImplementationTable[0]);
+	}
+
+
+
+