--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/syncmlfw/common/obex/obexdsplugin/inc/NSmlObexDSplugin.h	Thu Dec 17 09:07:52 2009 +0200
@@ -0,0 +1,249 @@
+/*
+* 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:  SyncML Obex plugin for data syncronization
+*
+*/
+
+
+#ifndef __NSMLOBEXDSPLUGIN__
+#define __NSMLOBEXDSPLUGIN__
+
+#include <e32std.h>
+#include <e32base.h>
+#include <es_sock.h>
+#include <obex.h>
+#include <btsdp.h>
+#include <btmanclient.h>
+#include <SrcsInterface.h>
+#include <nsmldebug.h>
+#include <nsmlconstants.h>
+#include <nsmldefines.h>
+#include <nsmlsyncalerthandlerif.h>
+
+#include "nsmltransport.h"
+#include "NSmlObexDSpluginConstants.h"
+#include "nsmlobexserversession.h"
+#include "nsmlobexcommserver.h"
+#include "nsmlobexdefs.h"
+
+
+#ifdef __NSML_DEBUG__
+#include "wbxml2xmlconverter.h"
+#endif // __NSML_DEBUG__
+
+const TInt KPluginTimeOutValue = 180000000;// Time (in milliseconds) for the timer
+
+class CDisListener;
+class CNSmlObexServerSession;
+class CPluginServiceTimer;
+class CThreadObserver;
+class CNSmlObexPacketWaiterAsync;
+
+enum TNSmlObexContent
+    {
+    ENSmlDataSync,
+    ENSmlDeviceManagement
+    };
+
+
+class CNSmlObexDSplugin : public CSrcsInterface,
+			public MObexServerNotifyAsync, public MNSmlAlertObexPluginContext
+    {
+friend class CDisListener;
+
+public:
+	IMPORT_C static CNSmlObexDSplugin* NewL();
+    IMPORT_C static CNSmlObexDSplugin* NewLC();
+    ~CNSmlObexDSplugin();
+
+	// virtuals from MNSmlAlertObexPluginContext
+	RLibrary& AlertLibrary();
+	TThreadId* AlertThreadId();
+
+	TBool IsOBEXActive();
+
+public:
+	TPtr8 iPtr;
+	TPtr8 iSendPtr;
+	HBufC8* iData;
+	RNSmlDSObexServerSession iSs;
+	TBool iStopped;
+
+private:
+    void ConstructL();
+    CNSmlObexDSplugin();
+
+	static TInt CreateServerL( TAny* aPtr );
+	static void StartServerL( TAny* aPtr );
+	TInt ForwardZeroPkgL( TNSmlObexContent aSyncSelection );
+	TInt CheckMimeType();
+	void TrimRightSpaceAndNull( TDes8& aDes ) const;
+	void Disconnect();
+	TInt ConvertError( TInt aError );
+    TInt SetObexServer( CObexServer* aObexServer );
+    void BluetoothNameByAddressL( TSockAddr aAddr );
+
+private: // from CSrcsInterface
+    void ErrorIndication( TInt aError );
+    void TransportUpIndication();
+    void TransportDownIndication();
+	void ObexDisconnectIndication( const TDesC8& aInfo );
+	TInt PutPacketIndication();
+	TInt GetPacketIndication();
+	void AbortIndication();
+	void SetMediaType( TSrcsMediaType aMediaType );
+	void GetCompleteIndication ();
+	void GetRequestIndication (CObexBaseObject *aRequestedObject);
+	void PutCompleteIndication ();
+	void PutRequestIndication ();
+	void SetPathIndication (const CObex::TSetPathInfo& aPathInfo, const TDesC8& aInfo);
+	void ObexConnectIndication  (const TObexConnectInfo& aRemoteInfo, const TDesC8& aInfo);
+	void CancelIndicationCallback();
+
+private:
+	enum TState
+		{
+		EIdle,
+		EGetSendPacket
+		};
+
+	TBool iZeroPkg;
+	TNSmlObexContent iObexContent;
+    CBufFlat* iObexBufData;
+    CObexBufObject* iObexBufObject;
+	CDisListener* iListener;
+	TState iState;
+	TBool iSessCancelled;
+	TBool iSessionActive;
+    CObexServer* iObexServer;
+
+	RLibrary iAlertLib;
+	TThreadId iThreadId;
+
+	TBTDevAddr iBtAddr;
+	HBufC* iBtName;
+
+	CPluginServiceTimer* iServiceTimer;
+	TBool iStartTimer;
+	TSrcsMediaType iMediaType;
+	RThread* iServerThread;
+
+	TBool iConnectionAlive;
+
+private:
+	friend class CPluginServiceTimer;
+
+	CNSmlObexPacketWaiterAsync* iGetPacketWaiterAo;
+
+	TInt iResponseError;
+	};
+
+
+class CDisListener : public CActive
+	{
+public:
+
+	CDisListener( RNSmlDSObexServerSession& aSs, CNSmlObexDSplugin* aPlugin )
+			: CActive(0), iSessCancelled(EFalse), iSs(aSs), iPlugin( aPlugin )
+	{
+		CActiveScheduler::Add(this);
+	};
+
+	~CDisListener();
+	void RunL();
+	void DoCancel();
+	void ListenDisconnect();
+	TBool iSessCancelled;
+
+private:
+	enum TState
+		{
+		EIdle,
+		EListening
+		};
+	TState iState;
+	RNSmlDSObexServerSession& iSs;
+	CNSmlObexDSplugin* iPlugin;
+	};
+
+
+//============================================================
+// Class CPluginServiceTimer declaration
+//============================================================
+
+class CPluginServiceTimer : public CActive
+	{
+	public:
+		CPluginServiceTimer( CNSmlObexDSplugin* aEngine, TInt aValue );
+		void ConstructL();
+		~CPluginServiceTimer();
+		void StartTimer();
+		void StopTimer();
+
+	private:
+		void DoCancel();
+		void RunL();
+
+	private:
+		RTimer iTimer;
+		CNSmlObexDSplugin* iEngine;
+		TInt iValue;
+	};
+
+//============================================================
+// CNSmlObexPacketWaiterAsync
+//
+//============================================================
+class CNSmlObexPacketWaiterAsync : public CActive
+	{
+public:
+	static CNSmlObexPacketWaiterAsync* NewL (RNSmlDSObexServerSession& aSession,
+									  CBufFlat* aObexBufData,
+									  CObexBufObject* aObexBufObject);
+
+	void WaitForGetData() ;
+	inline const TDesC8& Data() const { return *iData; }
+
+	void SetObexServer( CObexServer* aObexServer );
+
+	~CNSmlObexPacketWaiterAsync();
+
+private:
+	CNSmlObexPacketWaiterAsync (RNSmlDSObexServerSession& aSession,
+							    CBufFlat* aObexBufData,
+							    CObexBufObject* aObexBufObject);
+
+	void ConstructL();
+	void RunL();
+	void DoCancel();
+
+private:
+
+	enum TState
+		{
+		EIdle,
+		EGetting
+		};
+
+	RNSmlDSObexServerSession& iSession;
+	CObexServer* iObexServer ;
+	CBufFlat* iObexBufData;
+    CObexBufObject* iObexBufObject;
+    HBufC8* iData;
+	TPtr8 iPtr;
+	TState iState;
+	};
+
+#endif // __NSMLOBEXDSPLUGIN__
+