--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/activityfw/activitydatabase/hsactivitydbclient/s60/src/hsactivitydbasyncrequest_p.cpp	Fri Apr 16 15:16:09 2010 +0300
@@ -0,0 +1,119 @@
+/*
+* 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 "hsactivitydbasyncrequest_p.h"
+#include "hsactivitydbclient_p.h"
+#include "hsserializer.h"
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+HsActivityDbAsyncRequestPrivate* 
+    HsActivityDbAsyncRequestPrivate::NewL(HsActivityDbAsyncRequestObserver& observer,
+                                          HsActivityDbClientPrivate& session)
+{
+    HsActivityDbAsyncRequestPrivate* self = 
+        HsActivityDbAsyncRequestPrivate::NewLC(observer, session);
+    CleanupStack::Pop(self);
+    return self;
+}
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+HsActivityDbAsyncRequestPrivate* 
+    HsActivityDbAsyncRequestPrivate::NewLC(HsActivityDbAsyncRequestObserver& observer,
+                                           HsActivityDbClientPrivate& session)
+{
+    HsActivityDbAsyncRequestPrivate* self = 
+        new (ELeave)HsActivityDbAsyncRequestPrivate(observer, session);
+    CleanupStack::PushL(self);
+    self->mDataBuf.CreateL(64);
+    return self;
+}
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+HsActivityDbAsyncRequestPrivate::HsActivityDbAsyncRequestPrivate(HsActivityDbAsyncRequestObserver &observer,
+                                                                 HsActivityDbClientPrivate &session)
+:
+    CActive(EPriorityStandard),
+    mObserver(observer),
+    mSession(session),
+    mRequestType(-1),
+    mDataSize()
+{
+    CActiveScheduler::Add(this);
+}
+
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+HsActivityDbAsyncRequestPrivate::~HsActivityDbAsyncRequestPrivate()
+{
+    mDataBuf.Close();
+    Cancel();
+}
+
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+void HsActivityDbAsyncRequestPrivate::DoCancel()
+{
+    if(IsActive()) {
+    mSession.cancelWaitActivity();
+    }
+}
+
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+void HsActivityDbAsyncRequestPrivate::RunL()
+{
+    RBuf8 buff;
+    CleanupClosePushL(buff);
+    QString data;
+    int requestResult(iStatus.Int());
+    if(KErrNone == requestResult) {
+        if(0 < mDataSize()) {
+            buff.CreateL(mDataSize());
+        }
+        mSession.getData(buff);
+        data = QString::fromAscii(reinterpret_cast<const char*>(buff.Ptr()), 
+                                  buff.Length());
+        buff.Close();
+    }
+    mObserver.asyncRequestCompleated(requestResult, mRequestType, data);
+    CleanupStack::PopAndDestroy(&buff);
+}
+
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+void HsActivityDbAsyncRequestPrivate::waitActivity(const QVariantHash& condition)
+{
+    mRequestType = WaitActivity;
+    iStatus = KRequestPending;
+    SetActive();
+    mDataBuf << condition;
+    mSession.sendDataAsync(mRequestType, TIpcArgs(&mDataBuf, &mDataSize), iStatus);
+}