TB10.1 Example Applications: examples/Base/IPC/AdvancedClientServerExample/ThreadServer/inc/threadserversession.h Source File

00001 // Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).
-00002 // All rights reserved.
-00003 // This component and the accompanying materials are made available
-00004 // under the terms of "Eclipse Public License v1.0"
-00005 // which accompanies this distribution, and is available
-00006 // at the URL "http://www.eclipse.org/legal/epl-v10.html".
-00007 //
-00008 // Initial Contributors:
-00009 // Nokia Corporation - initial contribution.
-00010 //
-00011 // Contributors:
-00012 //
-00013 // Description:
-00014 // ProcessServerSession.h
-00015 //
-00016 
-00017 #ifndef __PROCESSSERVERSESSION_H__
-00018 #define __PROCESSSERVERSESSION_H__
-00019 
-00020 #include <e32base.h>
-00021 #include <e32std.h>
-00022 #include "threadserver.h"
-00023 
-00024 const TInt KMaxAsyncRequests = 4;
-00025 class CThreadServer;
-00026 
-00030 class CThreadServerSession : public CSession2
-00031         {
-00032 public:
-00033         static CThreadServerSession* NewL(CThreadServer& aServer);
-00034         ~CThreadServerSession();
-00035         void CreateL();
-00036         void ServiceL(const RMessage2& aMessage);
-00037         
-00038 private:
-00039         CThreadServerSession(CThreadServer& aServer);
-00040         void ConstructL();
-00041         
-00042         // Active object class for asynchronous requests
-00043         class CAsyncHandler : public CActive 
-00044                 {
-00045         public:
-00046                 static CAsyncHandler* NewL(CThreadServer& aServer);
-00047                 ~CAsyncHandler();
-00048                 //Store async request in message array
-00049                 TInt ProcessRequest(const RMessage2& aMessage);
-00050         private:
-00051 
-00052                 CAsyncHandler(CThreadServer& aServer);
-00053                 void ConstructL();
-00054                 
-00055                 void RunL();
-00056                 void DoCancel();
-00057                         
-00058                 TInt ExecuteFirstRequestInArray();
-00059                 
-00063                 class TMessage
-00064                         {
-00065                 public:
-00066                         const RMessage2& Message() const;       // getter
-00067                         RMessage2& Message();                           // setter
-00068                 private:
-00069                         RMessage2 iMessage;
-00070                         };
-00071                 
-00072                 void Complete(TInt aResult);
-00073                 
-00074         private:
-00075                 RArray<TMessage>                iMessageArray;
-00076                 CThreadServer&                  iServer;
-00077                 };
-00078         
-00079 private:
-00080         CThreadServer& iServer;
-00081         CAsyncHandler*  iAsyncRequestHandler;
-00082         };
-00083 
-00084 #endif
-