diff -r 000000000000 -r b497e44ab2fc syncmlfw/common/sosserver/src/NSmlDataProvider.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/syncmlfw/common/sosserver/src/NSmlDataProvider.cpp	Thu Dec 17 09:07:52 2009 +0200
@@ -0,0 +1,174 @@
+/*
+* Copyright (c) 2004 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:  Symbian OS Server source.
+*
+*/
+
+
+#include "nsmlsosserver.h"
+#include "nsmldshostclient.h"
+
+// --------------------------------------------------------------------------
+// CNSmlDataProvider::CNSmlDataProvider( const TInt aId )
+// --------------------------------------------------------------------------
+//
+CNSmlDataProvider::CNSmlDataProvider( const TInt aId, CNSmlSOSSession& aSession ) 
+: iId(aId), iDataPtr(NULL, 0, 0), iSession(aSession) 
+    {    
+    }
+
+// --------------------------------------------------------------------------
+// CNSmlDataProvider::~CNSmlDataProvider()
+// --------------------------------------------------------------------------
+//
+CNSmlDataProvider::~CNSmlDataProvider()
+    {
+    delete iBuffer;
+    }
+
+// --------------------------------------------------------------------------
+// void CNSmlDataProvider::FetchDataL()
+// --------------------------------------------------------------------------
+//
+void CNSmlDataProvider::FetchDataL()
+    {
+
+    RArray<TInt> idArray;
+    RArray<TInt> resultArray;
+    CleanupClosePushL(resultArray);
+    CleanupClosePushL(idArray);
+    idArray.AppendL(iId);
+    
+    iSession.HostClient().CreateDataProvidersL( idArray, resultArray );
+
+    TInt res = resultArray[0];
+    User::LeaveIfError( res );
+
+    CleanupStack::PopAndDestroy(&idArray);
+    CleanupStack::PopAndDestroy(&resultArray);
+
+	TInt err = KErrNone;
+	TNSmlDPInformation* dpInfo = iSession.HostClient().DataProviderInformationL( iId, err );
+    User::LeaveIfError( err );
+    
+    HBufC* defds = iSession.HostClient().DefaultStoreL( iId, err );
+    User::LeaveIfError( err );
+    
+    CDesCArray* dsArray = new (ELeave) CDesCArrayFlat(1);
+    CleanupStack::PushL(dsArray);
+
+    iSession.HostClient().ListStoresL( dsArray, iId, err );
+    User::LeaveIfError( err );
+    
+    TInt mimeCount = dpInfo->iMimeTypes->Count();
+    
+    TInt mimelen = 0;
+    TInt mverlen = 0;
+    for (TInt mime = 0; mime < mimeCount; ++mime )
+    	{
+    	mimelen += ( *dpInfo->iMimeTypes )[ mime ].Size(); // mime type text length
+    	mimelen += KSizeofTInt32; // mime type length value
+    	mverlen += ( *dpInfo->iMimeVersions )[ mime ].Size(); // mime version text length
+    	mverlen += KSizeofTInt32; // mime version length value
+    	}
+    	
+    TInt dnamlen = dpInfo->iDisplayName->Size();
+    TInt defdslen = defds->Size();
+
+    CBufFlat* buffer = CBufFlat::NewL( KDefaultNSmlBufferGranularity );
+	CleanupStack::PushL( buffer );
+	RBufWriteStream stream( *buffer );  
+    
+    CleanupClosePushL(stream); 
+ 
+    stream.WriteInt32L( dpInfo->iVersion.iMajor );    // Version major
+    stream.WriteInt32L( dpInfo->iVersion.iMinor );    // Version minor
+    stream.WriteInt32L( dpInfo->iVersion.iBuild );    // Version build
+    stream.WriteInt8L( (TInt8)dpInfo->iProtocolVer ); // Req protocol version
+
+    // display name
+    stream.WriteInt32L( dnamlen );
+    stream << dpInfo->iDisplayName->Des();
+
+	// mime type count
+    stream.WriteInt32L( mimeCount );
+	
+    // mime types
+    for ( TInt type = 0; type < mimeCount; ++type )
+    	{
+        stream.WriteInt32L( ( *dpInfo->iMimeTypes )[ type ].Size() );
+        stream << ( *dpInfo->iMimeTypes )[ type ];
+    	}
+
+    // mime versions
+    for ( TInt ver = 0; ver < mimeCount; ++ver )
+    	{
+        stream.WriteInt32L( ( *dpInfo->iMimeVersions )[ ver ].Size() );
+        stream << ( *dpInfo->iMimeVersions )[ ver ];
+    	}
+
+    TInt count = dsArray->Count() + 1; // default ds + others.
+
+    stream.WriteInt8L( count ); // Amount of datastores.
+
+    // default datastore
+    stream.WriteInt32L( defdslen );   
+    stream << defds->Des();
+   
+    for ( TInt i(0) ; i < dsArray->Count() ; i++ )
+        {
+            stream.WriteInt32L( dsArray->operator[](i).Size() ); 
+            stream << dsArray->operator[](i);
+        }
+
+    // Allow multible datastores
+    stream.WriteInt8L( iSession.HostClient().SupportsOperationL( KUidSmlSupportMultipleStores, iId, err ) ); 
+    User::LeaveIfError( err );
+
+    stream.CommitL();
+    
+    CleanupStack::PopAndDestroy(&stream);
+    delete iBuffer;
+	iBuffer = buffer;
+	CleanupStack::Pop( buffer );    
+    CleanupStack::PopAndDestroy(dsArray);
+    
+    delete defds;
+    delete dpInfo->iDisplayName;
+    delete dpInfo->iMimeTypes;
+    delete dpInfo->iMimeVersions;
+    delete dpInfo;
+    }
+
+// --------------------------------------------------------------------------
+// TInt CNSmlDataProvider::DataSize()
+// --------------------------------------------------------------------------
+//
+TInt CNSmlDataProvider::DataSize()
+    {
+    return iBuffer->Size();
+    }
+
+// --------------------------------------------------------------------------
+// const TPtr8& CNSmlDataProvider::ReadData()
+// --------------------------------------------------------------------------
+//
+const TPtr8& CNSmlDataProvider::ReadData()
+    {
+    if ( iBuffer )
+        {
+        iDataPtr.Set( iBuffer->Ptr(0) );    
+        }    
+    return iDataPtr;
+    }