--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/cellularsrvapitest/datatransferhaitest/common/src/BreathSaver.cpp	Tue Feb 02 01:41:59 2010 +0200
@@ -0,0 +1,190 @@
+/*
+* 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:
+*
+*/
+
+
+#include <e32def.h>
+
+#include "DataDealer.h"
+#include "BreathSaver.h"
+
+CBreathSaver* CBreathSaver::NewL()
+    {
+    CBreathSaver* self = new (ELeave) CBreathSaver();
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop(self);
+    return self;
+    }
+
+CBreathSaver::~CBreathSaver()
+    {
+    // Free DataDealer
+	if (iDataDealer)
+		{
+		delete iDataDealer;
+		iDataDealer = 0;
+		}
+    // Close handle to File server session
+    iRFsession.Close();
+    }
+
+/**
+ * Start function for data dealer
+ * @param aKey			Data dealer key
+ * @return				TInt. Error code.
+ */
+TInt CBreathSaver::StartDealer(const TUint aKey)
+	{
+	TInt error = KErrNone;
+    // return error if DataDealer is already started
+    if (iDealerStarted != EFalse)
+        {
+        error = KErrLocked;
+        }
+    else
+    	{
+    	// iDataDealer is deleted in End-function or in destructor and
+    	// Start cannot be called again before End is called first
+        TRAP (error, iDataDealer = CDataDealer::NewL(ETrue, aKey));
+        // NewL failed
+        if (error == KErrNone)
+            {
+            // DataDealer is started
+        	iDealerStarted = ETrue;
+        	}        
+    	}
+    
+	return error;
+	}
+
+/**
+ * Start function for file saving. This function replaces the file if it already exists
+ * @param aFileName		File name
+ * @return				TInt. Error code.
+ */
+TInt CBreathSaver::StartFile(const TDesC &aFileName)
+    {
+    TInt error = KErrNone;
+    // Check that start is not called when somebody else have already called start
+    // but not end
+    if (iFileStarted != EFalse)
+        {
+        error = KErrLocked;
+        }
+    else
+    	{
+    	error = iFile.Replace(iRFsession,aFileName,EFileWrite|EFileStream);
+        // Check that file replase was successful
+        if (error == KErrNone)
+            {
+            // All must be fine so lets start file
+            iFileStarted = ETrue;
+            }
+    	}
+    return error;
+    }
+
+/**
+ * Appends Buffer into a started file.
+ * @param aBuffer		Buffer to be appened.
+ * @return				TInt. Error code.
+ */
+TInt CBreathSaver::Append(TDes8 &aBuffer)
+    {
+	// If nothing is started then nothing should be appended
+    if (iFileStarted == EFalse && iDealerStarted == EFalse)
+        {
+        return KErrNotFound;
+        }
+
+    TInt error = KErrNone;
+
+    // Check if file is started
+    if (iFileStarted)
+        {
+        // Add more to existing file
+        error = iFile.Write(aBuffer);
+		if (error != KErrNone)
+			{
+			return error;
+			}
+        }
+    // Check if DataDealer is started
+    if (iDealerStarted)
+		{
+		// ProduceDataL waits until consumer has devoured all the previously
+		// produced data
+		TRAP (error, iDataDealer->ProduceDataL(aBuffer));
+		if (error != KErrNone)
+			{
+			return error;
+			}
+		}
+    // more types can be added here
+    return error;
+    }
+
+/**
+ * Ends function for file saving.
+ * @return				TInt. Error code.
+ */
+TInt CBreathSaver::End()
+    {
+    TInt error = KErrNone;
+	// If nothing is started then nothing should be ended
+    if (iFileStarted == EFalse && iDealerStarted == EFalse)
+        {
+        error = KErrNotFound;
+        }
+    else
+    	{
+        // Check if file is started
+        if (iFileStarted)
+            {
+            // Flush and close file
+            error = iFile.Flush();
+            iFile.Close();
+            // Now new file can be started
+    		iFileStarted = EFalse;
+            }
+        // Check if DataDealer is started
+    	if (iDealerStarted)
+    		{
+            // free DataDealer, new dealer is born(captured?) in start function
+    		delete iDataDealer;
+    		iDataDealer = 0;
+            // Now new data dealer can be started
+    		iDealerStarted = EFalse;
+    		}
+    	}
+    return error;
+    }
+
+CBreathSaver::CBreathSaver()
+    {
+    iFileStarted = EFalse;
+	iDealerStarted = EFalse;
+	iDataDealer = 0;
+    }
+
+void CBreathSaver::ConstructL()
+    {
+    // Open file server session
+    // Session is closed in destructor
+    User::LeaveIfError(iRFsession.Connect());
+    }
+