TB10.1 Example Applications: examples/Base/IPC/AdvancedClientServerExample/ProcessServer/src/processserversession.cpp 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 //
-00015 
-00016 #include "processserversession.h"
-00017 
-00018 
-00019 /*****************CProcessServerSession**********************/
-00023 CProcessServerSession* CProcessServerSession::NewL(CProcessServer& aServer)
-00024         {
-00025         CProcessServerSession* s = new(ELeave) CProcessServerSession(aServer);
-00026         CleanupStack::PushL(s);
-00027         s->ConstructL();
-00028         CleanupStack::Pop();
-00029         return s;       
-00030         }
-00034 CProcessServerSession::CProcessServerSession(CProcessServer& aServer)
-00035 :iServer(aServer)
-00036         {
-00037         
-00038         }
-00039 
-00040 void CProcessServerSession::ConstructL()
-00041         {
-00042         }
-00046 CProcessServerSession::~CProcessServerSession()
-00047         {
-00048         delete iAsyncRequestHandler;            
-00049         iServer.CloseLogicalChannel();
-00050         iServer.DecrementRefCount();
-00051         }
-00056 void CProcessServerSession::CreateL()
-00057 //
-00058 // 2nd phase constructor for sessions - called by the CServer framework
-00059 //
-00060         {
-00061         iServer.IncrementRefCount();            
-00062         //load dummy ldd
-00063         User::LeaveIfError(iServer.LoadDevice());
-00064         iAsyncRequestHandler = CAsyncHandler::NewL(iServer);    
-00065         }
-00069 void CProcessServerSession::ServiceL(const RMessage2& aMessage)
-00070         {
-00071         TInt r = KErrNone;
-00072         switch(aMessage.Function())
-00073                 {                               
-00074                 case ELoadDeviceDriver:
-00075                         aMessage.Complete(iServer.LoadDevice());
-00076                         break;
-00077                 
-00078                 case EOpenDriver:
-00079                         aMessage.Complete(iServer.OpenLogicalChannel());
-00080                         break;
-00081                         
-00082                 case EDummyLDDSendData: //async
-00083                         r = iAsyncRequestHandler->ProcessRequest(aMessage);
-00084                         if (r!=KErrNone)
-00085                                 aMessage.Complete(r);
-00086                         break;
-00087                         
-00088                 case EDummyLDDSendDataCancel: //cancel async
-00089                         iAsyncRequestHandler->Cancel(); 
-00090                         aMessage.Complete(KErrNone); 
-00091                         break;
-00092                         
-00093                 case EUnloadDeviceDriver:
-00094                         aMessage.Complete(iServer.UnloadDevice());
-00095                         break;
-00096                         
-00097                 default:
-00098                         User::Leave(KErrNotSupported);
-00099                         break;
-00100                 }
-00101 
-00102         }
-00103                 
-00104 
-00105 
-00106 /*****************CAsyncHandler**********************/
-00110 CProcessServerSession::CAsyncHandler* CProcessServerSession::CAsyncHandler::NewL(CProcessServer& aServer)
-00111         {
-00112         CAsyncHandler* self = new(ELeave) CAsyncHandler(aServer);
-00113         CleanupStack::PushL(self);
-00114         self ->ConstructL();
-00115         CleanupStack::Pop();
-00116         return self;
-00117         }
-00121 CProcessServerSession::CAsyncHandler::~CAsyncHandler()
-00122         {
-00123         Cancel();
-00124         iMessageArray.Close();
-00125         }
-00129 void CProcessServerSession::CAsyncHandler::RunL()
-00130         {
-00131         // complete the request
-00132         Complete(iStatus.Int());
-00133         
-00134         //continue to execute next request if there is any
-00135         ExecuteFirstRequestInArray();
-00136         }
-00140 void CProcessServerSession::CAsyncHandler::DoCancel()
-00141         {
-00142         iServer.CancelSendData();
-00143         // complete the request
-00144         Complete(iStatus.Int());
-00145         }
-00149 CProcessServerSession::CAsyncHandler::CAsyncHandler(CProcessServer& aServer)
-00150         :CActive(EPriorityStandard), iServer(aServer)
-00151         {
-00152         CActiveScheduler::Add(this);
-00153         }
-00154 
-00155 void CProcessServerSession::CAsyncHandler::ConstructL()
-00156         {
-00157         
-00158         }
-00164 TInt CProcessServerSession::CAsyncHandler::ProcessRequest(const RMessage2& aMessage)
-00165         {
-00166         TInt ret;
-00167         //store message
-00168         TMessage newMessage;
-00169         newMessage.Message() = aMessage;
-00170         ret= iMessageArray.Append(newMessage);
-00171         if (ret != KErrNone)
-00172                 return ret;
-00173         
-00174         // kick off the first request in the array when there is only one in the array 
-00175         if (iMessageArray.Count() == 1) 
-00176                 ret= ExecuteFirstRequestInArray();
-00177 
-00178         return ret;
-00179         }
-00184 TInt CProcessServerSession::CAsyncHandler::ExecuteFirstRequestInArray()
-00185         {
-00186         TInt r = KErrNone;
-00187         if (iMessageArray.Count() != 0)
-00188                 {
-00189                 const RMessage2& message = iMessageArray[0].Message();
-00190                 switch (message.Function())
-00191                         {
-00192                         case EDummyLDDSendData:
-00193                                 {
-00194                                 TBuf8<KMaxMessageLen> sendObject;
-00195                                 r= message.Read(0, sendObject);
-00196                                 if (r == KErrNone)
-00197                                         {
-00198                                         r = iServer.SendDataToDevice(iStatus, sendObject);
-00199                                         if (r==KErrNone)
-00200                                                 SetActive();
-00201                                         }
-00202                                 }
-00203                                 break;
-00204                         
-00205                         default:
-00206                                 break;
-00207                         }
-00208                 
-00209                 }
-00210         return r; 
-00211         }
-00215 void CProcessServerSession::CAsyncHandler::Complete(TInt aResult)
-00216         {
-00217         iMessageArray[0].Message().Complete(aResult);
-00218         iMessageArray.Remove(0);
-00219         iServer.UpdateDriverState(CProcessServer::ELogicalChannelOpened);
-00220         }
-00221 
-00222 /***************TMessage****************/
-00226 const RMessage2& CProcessServerSession::CAsyncHandler::TMessage::Message() const
-00227         {
-00228         return iMessage;
-00229         }
-00230         
-00231 RMessage2& CProcessServerSession::CAsyncHandler::TMessage::Message()
-00232         {
-00233         return iMessage; 
-00234         }
-00235 
-00236 //EOF
-