examples/Base/IPC/ClientServer/Gettingstarted/transient/src/client.cpp

00001 /*
00002 Copyright (c) 2000-2010 Nokia Corporation and/or its subsidiary(-ies). All rights reserved.
00003 
00004 Redistribution and use in source and binary forms, with or without
00005 modification, are permitted provided that the following conditions are met:
00006 
00007 * Redistributions of source code must retain the above copyright notice, this
00008   list of conditions and the following disclaimer.
00009 * Redistributions in binary form must reproduce the above copyright notice,
00010   this list of conditions and the following disclaimer in the documentation
00011   and/or other materials provided with the distribution.
00012 * Neither the name of Nokia Corporation nor the names of its contributors
00013   may be used to endorse or promote products derived from this software
00014   without specific prior written permission.
00015 
00016 THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
00017 AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
00018 IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
00019 DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
00020 FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
00021 DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
00022 SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
00023 CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
00024 OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
00025 OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
00026 
00027 Description: Transient server example - client interface implementation  
00028 */
00029 
00030 #include <t-client.h>
00031 #include "clientserver.h"
00032 
00033 static TInt StartServer()
00034 //
00035 // Start the server process. Simultaneous launching
00036 // of two such processes should be detected when the second one attempts to
00037 // create the server object, failing with KErrAlreadyExists.
00038 //
00039         {
00040         const TUidType serverUid(KNullUid,KNullUid,KServerUid3);
00041         RProcess server;
00042         TInt r=server.Create(KMyServerImg,KNullDesC,serverUid);
00043         if (r!=KErrNone)
00044                 return r;
00045         TRequestStatus stat;
00046         server.Rendezvous(stat);
00047         if (stat!=KRequestPending)
00048                 server.Kill(0);         // abort startup
00049         else
00050                 server.Resume();        // logon OK - start the server
00051         User::WaitForRequest(stat);             // wait for start or death
00052         // we can't use the 'exit reason' if the server panicked as this
00053         // is the panic 'reason' and may be '0' which cannot be distinguished
00054         // from KErrNone
00055         r=(server.ExitType()==EExitPanic) ? KErrGeneral : stat.Int();
00056         server.Close();
00057         return r;
00058         }
00059 
00060 EXPORT_C TInt RMySession::Connect()
00061 //
00062 // Connect to the server, attempting to start it if necessary
00063 //
00064         {
00065         TInt retry=2;
00066         for (;;)
00067                 {
00068                 TInt r=CreateSession(KMyServerName,TVersion(0,0,0),1);
00069                 if (r!=KErrNotFound && r!=KErrServerTerminated)
00070                         return r;
00071                 if (--retry==0)
00072                         return r;
00073                 r=StartServer();
00074                 if (r!=KErrNone && r!=KErrAlreadyExists)
00075                         return r;
00076                 }
00077         }
00078 
00079 EXPORT_C TInt RMySession::Send(const TDesC& aMessage)
00080         {
00081         if (aMessage.Length()>KMaxMyMessage)
00082                 return KErrArgument;
00083         return SendReceive(ESend,TIpcArgs(&aMessage));
00084         }
00085 
00086 EXPORT_C void RMySession::Receive(TRequestStatus& aStatus,TDes& aMessage)
00087         {
00088         SendReceive(EReceive,TIpcArgs(&aMessage,aMessage.MaxLength()),aStatus);
00089         }
00090 
00091 EXPORT_C void RMySession::CancelReceive()
00092         {
00093         SendReceive(ECancelReceive);
00094         }

Generated by  doxygen 1.6.2