examples/Base/IPC/AdvancedClientServerExample/ThreadServer/inc/threadserversession.h

// Copyright (c) 2007-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:
// ProcessServerSession.h
//

#ifndef __PROCESSSERVERSESSION_H__
#define __PROCESSSERVERSESSION_H__

#include <e32base.h>
#include <e32std.h>
#include "threadserver.h"

const TInt KMaxAsyncRequests = 4;
class CThreadServer;

class CThreadServerSession : public CSession2
        {
public:
        static CThreadServerSession* NewL(CThreadServer& aServer);
        ~CThreadServerSession();
        void CreateL();
        void ServiceL(const RMessage2& aMessage);
        
private:
        CThreadServerSession(CThreadServer& aServer);
        void ConstructL();
        
        // Active object class for asynchronous requests
        class CAsyncHandler : public CActive 
                {
        public:
                static CAsyncHandler* NewL(CThreadServer& aServer);
                ~CAsyncHandler();
                //Store async request in message array
                TInt ProcessRequest(const RMessage2& aMessage);
        private:

                CAsyncHandler(CThreadServer& aServer);
                void ConstructL();
                
                void RunL();
                void DoCancel();
                        
                TInt ExecuteFirstRequestInArray();
                
                class TMessage
                        {
                public:
                        const RMessage2& Message() const;       // getter
                        RMessage2& Message();                           // setter
                private:
                        RMessage2 iMessage;
                        };
                
                void Complete(TInt aResult);
                
        private:
                RArray<TMessage>                iMessageArray;
                CThreadServer&                  iServer;
                };
        
private:
        CThreadServer& iServer;
        CAsyncHandler*  iAsyncRequestHandler;
        };

#endif

---