diff -r 000000000000 -r e686773b3f54 presencecache/presencecacheclient2/src/presencecacheclientnotification.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/presencecache/presencecacheclient2/src/presencecacheclientnotification.cpp	Tue Feb 02 10:12:17 2010 +0200
@@ -0,0 +1,203 @@
+/*
+* Copyright (c) 2008 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:  Implementation for presence cache client.
+*
+*/
+
+#include <e32std.h>
+
+#include <mpresencebuddyinfo2.h>
+#include <presencecachereadhandler2.h>
+
+#include "presencecacheclientnotification.h"
+#include "presencecachedefs2.h"
+#include "cacheobjecthelpers.h"
+
+// ============================ MEMBER FUNCTIONS =============================
+
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::NewL
+// ---------------------------------------------------------------------------
+//
+CPresenceCacheClientNotification* CPresenceCacheClientNotification::NewL(
+    CPresenceCacheClient& aClient)
+    {
+    CPresenceCacheClientNotification* self = new(ELeave)CPresenceCacheClientNotification(aClient);
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop();
+    return self;    
+    }
+    
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::~CPresenceCacheClientNotification
+// ---------------------------------------------------------------------------
+//
+CPresenceCacheClientNotification::~CPresenceCacheClientNotification()
+    {
+    Cancel();
+    }
+    
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::CPresenceCacheClientNotification
+// ---------------------------------------------------------------------------
+//
+CPresenceCacheClientNotification::CPresenceCacheClientNotification(CPresenceCacheClient& aClient)
+: CActive( EPriorityStandard ), iClient( aClient ), iNotificationSubscribed( EFalse )
+    {        
+    }
+
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::ConstructL
+// ---------------------------------------------------------------------------
+//
+void CPresenceCacheClientNotification::ConstructL()
+    {
+    CActiveScheduler::Add( this );   
+    }
+    
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::RunL
+// ---------------------------------------------------------------------------
+//
+void CPresenceCacheClientNotification::RunL()
+    {    
+    TInt origStatus = iStatus.Int();
+    
+    MPresenceCacheReadHandler2* client = ClientNotifyHandler();    
+    
+    if ( origStatus )
+        {
+        iNotificationSubscribed = EFalse;        
+        TRAP_IGNORE( client->HandlePresenceNotificationL( origStatus, NULL ));
+        }
+    else
+        {
+        StartNotifySubscription();        
+        PreseneceFromServerToClientL( *client, iSizePckg() );
+        }              
+    }
+// ----------------------------------------------------------
+// CPresenceCacheClientNotification::RunError
+// ----------------------------------------------------------
+//
+TInt CPresenceCacheClientNotification::RunError( TInt aError )
+    {         
+    if ( KErrServerTerminated == aError )
+        {
+        // When server is terminated we notify the clienrt about that
+        iNotificationSubscribed = EFalse;         
+        MPresenceCacheReadHandler2* client = ClientNotifyHandler();
+        TRAP_IGNORE( client->HandlePresenceNotificationL( aError, NULL ));        
+        }
+    else
+        {
+        // StartNotifySubscription is already called.
+        }
+    return KErrNone;    
+    } 
+
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::DoCancel
+// ---------------------------------------------------------------------------
+//
+void CPresenceCacheClientNotification::DoCancel()
+    {
+    iClient.SendReceive( NRequest::ECancelWaitingForNotification );
+    }
+
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::SubscribePresenceBuddyChangeL
+// ---------------------------------------------------------------------------
+//    
+TInt CPresenceCacheClientNotification::SubscribePresenceBuddyChangeL(
+	const TDesC& aIdentity)
+    {       
+    if ( !iNotificationSubscribed )
+        {
+        StartNotifySubscription();
+        }
+                   
+    // Package message arguments before sending to the server
+    TIpcArgs args;
+    args.Set(1, &aIdentity);  
+        
+    TInt err = iClient.SendReceive( NRequest::ESubscribeBuddyPresenceChange, args );    
+        
+    return err;
+    }
+
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::UnsubscribePresenceBuddyChangeL
+// ---------------------------------------------------------------------------
+//    
+void CPresenceCacheClientNotification::UnsubscribePresenceBuddyChangeL(
+	const TDesC& aIdentity)
+    {
+    // Package message arguments before sending to the server
+    TIpcArgs args;
+    args.Set(1, &aIdentity);  
+        
+    TInt err = iClient.SendReceive( NRequest::EUnSubscribeBuddyPresenceChange, args );
+    User::LeaveIfError( err );
+    }
+ 
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::StartNotifySubscriptionL
+// ---------------------------------------------------------------------------
+//    
+void CPresenceCacheClientNotification::StartNotifySubscription()
+    {                                    
+    // Package message arguments before sending to the server
+    SetActive();
+    TIpcArgs args(&iSizePckg);            
+    iClient.SendReceive( NRequest::EWaitingForNotification, args, iStatus );
+    iNotificationSubscribed = ETrue;
+    }
+
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::ClientNotifyHandler
+// ---------------------------------------------------------------------------
+//    
+MPresenceCacheReadHandler2* CPresenceCacheClientNotification::ClientNotifyHandler()
+    {
+	return iClient.iNotifyClient;
+    }
+
+// ---------------------------------------------------------------------------
+// CPresenceCacheClientNotification::PreseneceFromServerToClientL
+// ---------------------------------------------------------------------------
+//    
+void CPresenceCacheClientNotification::PreseneceFromServerToClientL( 
+    MPresenceCacheReadHandler2& aClient, TInt aSize )
+    {     
+    MPresenceBuddyInfo2* buddyInfo = MPresenceBuddyInfo2::NewLC();     
+    HBufC8* presInfoDes = HBufC8::NewLC( aSize );
+    TPtr8 ptrBuf( presInfoDes->Des() );
+    TInt err = iClient.SendReceive( NRequest::EGetLastNotifiedtPacket, TIpcArgs( &ptrBuf ));    
+    if ( !err )
+        {
+        TCacheObjectPacker< MPresenceBuddyInfo2 >::UnPackL( *buddyInfo, *presInfoDes );        
+        CleanupStack::PopAndDestroy( presInfoDes );                          
+        CleanupStack::Pop( ); //  buddyInfo
+        aClient.HandlePresenceNotificationL( KErrNone, buddyInfo );
+        }
+    else
+        {
+        CleanupStack::PopAndDestroy( presInfoDes );         
+        CleanupStack::PopAndDestroy( buddyInfo );          
+        }
+    }
+
+// end of file