TB10.1 Example Applications: examples/Base/IPC/ClientServer/Complex/ComplexServer.cpp Source File

00001 // Copyright (c) 2000-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 "ComplexClientAndServer.h"
-00017 #include "ComplexServer.h"
-00018 #include <e32svr.h>
-00019 #include <e32uid.h>
-00020 
-00021 //
-00022 //NOTE**: The example does not demonstrate any security features - its purpose is simply
-00023 //        to demonstrate the basic principles of client/server interaction.
-00024 //
-00025 
-00026 
-00030 TInt CCountServer::ThreadFunction(TAny* )
-00031         {
-00032           // Useful TInt variable
-00033         TInt err;
-00034         
-00035           // create cleanup stack
-00036         CTrapCleanup* cleanup = CTrapCleanup::New();
-00037         if (cleanup == NULL)
-00038             {
-00039                 PanicServer(ECreateTrapCleanup);
-00040             }
-00041                 
-00042           // Create an active scheduler.
-00043         CActiveScheduler* pScheduler=new CActiveScheduler;
-00044         __ASSERT_ALWAYS(pScheduler,PanicServer(EMainSchedulerError));
-00045           // Install the active scheduler.
-00046         CActiveScheduler::Install(pScheduler);
-00047         
-00048           // Create the server object.
-00049         CCountServer* pServer = NULL;
-00050         TRAP(err,pServer = CCountServer::NewL(EPriorityStandard));
-00051         __ASSERT_ALWAYS(!err,CCountServer::PanicServer(ESvrCreateServer));
-00052         
-00053           // Start the server
-00054         err = pServer->Start(KCountServerName);
-00055         if (err != KErrNone)
-00056             {
-00057                 CCountServer::PanicServer(ESvrStartServer);
-00058             }
-00059             
-00060       // Let everyone know that we are ready to
-00061       // deal with requests.
-00062     RThread::Rendezvous(KErrNone);
-00063     
-00064       // And start fielding requests from client(s).
-00065         CActiveScheduler::Start();
-00066         
-00067       // Tidy up...
-00068     delete pServer;
-00069     delete pScheduler;
-00070     delete cleanup; 
-00071 
-00072           // ...although we should never get here!
-00073         return KErrNone;
-00074         }
-00075 
-00076 
-00084 EXPORT_C TInt StartThread(RThread& aServerThread)
-00085         {
-00086         TInt res=KErrNone;
-00087         
-00088       // Create the server, if one with this name does not already exist.
-00089         
-00090         TFindServer findCountServer(KCountServerName);
-00091         TFullName   name;
-00092         
-00093           // Need to check that the server exists.
-00094         if (findCountServer.Next(name)!=KErrNone)
-00095             {
-00096               // Create the thread for the server.
-00097                 res=aServerThread.Create(KCountServerName,
-00098                         CCountServer::ThreadFunction,
-00099                         KDefaultStackSize,
-00100                         KDefaultHeapSize,
-00101                         KDefaultHeapSize,
-00102                         NULL
-00103                         );
-00104                   // The thread has been created OK so get it started - however
-00105           // we need to make sure that it has started before we continue.
-00106                 if (res==KErrNone)
-00107                         {
-00108                         TRequestStatus rendezvousStatus;
-00109                         
-00110                         aServerThread.SetPriority(EPriorityNormal);
-00111                         aServerThread.Rendezvous(rendezvousStatus);
-00112                         aServerThread.Resume();
-00113                         User::WaitForRequest(rendezvousStatus);
-00114                         }
-00115                         
-00116                   // The thread has not been created - clearly there's been a problem.
-00117                 else
-00118                         {
-00119                         aServerThread.Close();
-00120                         }
-00121                 }
-00122     return res;
-00123         }
-