--- a/activityfw/storage/client/s60/src/afstorageclientimp.cpp	Fri Jul 23 14:03:00 2010 +0300
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,190 +0,0 @@
-/*
-* Copyright (c) 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 <fbs.h>
-#include <s32mem.h>
-#include "afstorageclientimp.h"
-#include "afstorageglobals.h"
-#include "afglobals.h"
-#include "afentry.h"
-#include "afasyncrequest_p.h"
-#include "afthumbnailrequest_p.h"
-
-// -----------------------------------------------------------------------------
-/**
- * Furst phase constructor 
- */
-RAfStorageClientImplementation::RAfStorageClientImplementation(MAfAsyncRequestObserver &observer)
-:
-mObserver(observer)
-{}
-
-// -----------------------------------------------------------------------------
-/**
- * Destructor
- */
-RAfStorageClientImplementation::~RAfStorageClientImplementation()
-{
-    Close();
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::Close()
-{
-    mAsyncTasks.ResetAndDestroy();
-    RSessionBase::Close();
-}
-
-// -----------------------------------------------------------------------------
-/**
- * Function establish connection to activity server
-  */
-void RAfStorageClientImplementation::connectL()
-{
-    const int asyncMessageSlots(12);
-    const int maxRetry(4);
-    TInt retry = maxRetry;
-    TInt errNo(KErrNone);
-    do {
-        errNo = CreateSession(KActivityServerName, 
-                              TVersion(0, 0, 0), 
-                              asyncMessageSlots);
-        if (KErrNotFound != errNo && KErrServerTerminated != errNo) {
-            retry =0;
-        } else {
-            TRAP(errNo, startServerL());
-            if (KErrNone != errNo && KErrAlreadyExists != errNo) {
-                retry =0;
-                errNo = CreateSession(KActivityServerName, 
-                                      TVersion(0, 0, 0), 
-                                      asyncMessageSlots);
-            }
-        }
-    } while (--retry > 0);
-    User::LeaveIfError(errNo);
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::startServerL()
-{
-    RProcess server;
-    const TUidType uid(KNullUid, KNullUid, KActivityServerUid);
-    User::LeaveIfError(server.Create(KActivityServerName, KNullDesC, uid));
-    TRequestStatus stat;
-    server.Rendezvous(stat);
-    if (stat != KRequestPending) {
-        server.Kill(0);
-    } else {
-        server.Resume();
-    }
-    User::WaitForRequest(stat);
-    int errNo = (EExitPanic == server.ExitType()) ?
-                KErrGeneral : stat.Int();
-    if (KErrCancel == errNo) {
-        errNo = KErrNone;
-    }
-    server.Close();
-    User::LeaveIfError(errNo);
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::executeL(int function)
-{
-    switch (function) {
-    case WaitActivity:
-    case NotifyChange:
-        CAfAsyncRequestPrivate::NewLD(mObserver, *this, static_cast<ActivityCmd>(function));
-        break;
-    default:
-        User::LeaveIfError(SendReceive(function, TIpcArgs()));
-    }
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::executeL(int function, 
-                                              const CAfEntry &entry,
-                                              int userData)
-{
-    TPckgBuf<TInt> data(userData);
-    RBuf8 serializedEntry;
-    CleanupClosePushL(serializedEntry);
-    serializedEntry.CreateL(entry.Size());
-    RDesWriteStream stream(serializedEntry);
-    CleanupClosePushL(stream);
-    stream << entry;
-    CleanupStack::PopAndDestroy(&stream);
-    User::LeaveIfError(SendReceive(function, TIpcArgs(&serializedEntry, &data)));
-    CleanupStack::PopAndDestroy(&serializedEntry);
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::executeL(int function, RPointerArray<CAfEntry> &resultsList, const CAfEntry& templateEntry)
-{
-    resultsList.ResetAndDestroy();
-    RBuf8 buffer;
-    CleanupClosePushL(buffer);
-    CAfEntry::ReallocL(buffer, templateEntry.Size());
-    RDesWriteStream writer(buffer);
-    CleanupClosePushL(writer);
-    writer << templateEntry;
-    CleanupStack::PopAndDestroy(&writer);
-    TPckgBuf<int> length(0), taskId(0);
-    User::LeaveIfError(SendReceive(function,
-                                   TIpcArgs(&buffer, &length, &taskId)));
-    CAfEntry::ReallocL(buffer, length());
-    User::LeaveIfError(SendReceive(GetData, TIpcArgs(&taskId, &buffer)));
-    resultsList << buffer;
-    CleanupStack::PopAndDestroy(&buffer);
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::getThumbnailL(TSize size, 
-                                                   const TDesC& source, 
-                                                   TAny *userData )
-{
-    CAfThumbnailRequestPrivate::NewLD(mObserver, *this, size, source, userData);
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::PushL(CBase* asyncTask)
-{
-    const TInt offset(mAsyncTasks.Find(asyncTask));
-    (KErrNotFound == offset) ? mAsyncTasks.AppendL(asyncTask) : User::Leave(KErrAlreadyExists);
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::Pop(CBase* asyncTask)
-{
-    const TInt offset(mAsyncTasks.Find(asyncTask));
-    if (KErrNotFound != offset) {
-        mAsyncTasks.Remove(offset);
-    }
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::sendAsync(int function, 
-                                              const TIpcArgs& args, 
-                                              TRequestStatus& status)
-{
-    SendReceive(function, args, status);
-}
-
-// -----------------------------------------------------------------------------
-void RAfStorageClientImplementation::getDataL(int id, TDes8& buffer)
-{
-    TPckgBuf<int> requestId(id);
-    SendReceive(GetData, TIpcArgs(&requestId, &buffer));
-}