src/io/inc/FIo_IpcClient.h

   1 //
   2 // Open Service Platform
   3 // Copyright (c) 2012 Samsung Electronics Co., Ltd.
   4 //
   5 // Licensed under the Apache License, Version 2.0 (the License);
   6 // you may not use this file except in compliance with the License.
   7 // You may obtain a copy of the License at
   8 //
   9 //     http://www.apache.org/licenses/LICENSE-2.0
  10 //
  11 // Unless required by applicable law or agreed to in writing, software
  12 // distributed under the License is distributed on an "AS IS" BASIS,
  13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 // See the License for the specific language governing permissions and
  15 // limitations under the License.
  16 //
  17
  18 /**
  19  * @file        FIo_IpcClient.h
  20  * @brief       This is the header file for the _IpcClient class.
  21  *
  22  * This file contains the declarations of _IpcClient.
  23  */
  24
  25
  26 #ifndef _FIO_INTERNAL_IPC_CLIENT_H_
  27 #define _FIO_INTERNAL_IPC_CLIENT_H_
  28
  29 #include <string>
  30 #include <pthread.h>
  31 #include <glib.h>
  32
  33 #include <ipc/ipc_message_macros.h>
  34 #include <ipc/ipc_message_utils.h>
  35
  36 #include <FBaseResult.h>
  37 #include <FBaseObject.h>
  38 #include <FBaseString.h>
  39 #include <FOspConfig.h>
  40
  41
  42 namespace Tizen { namespace Base { namespace Runtime
  43 {
  44 class Mutex;
  45 }}}
  46 namespace Tizen { namespace Io
  47 {
  48
  49 class _IIpcClientEventListener;
  50
  51 /**
  52  * @class _IpcClient
  53  * @brief This class provides methods for sending a message to an IPC server.
  54  *
  55  */
  56 class _OSP_EXPORT_ _IpcClient
  57         : Tizen::Base::Object
  58 {
  59 public:
  60         _IpcClient(void);
  61
  62         virtual ~_IpcClient(void);
  63
  64         /**
  65          * Constructs the instance of this class.
  66          *
  67          * @return An error code
  68          * @param[in] serverName        The name of the server
  69          * @param[in] pListener Set if the client want to handle a message from the IPC server.
  70          *                                 @c null, otherwise.
  71          * @exception E_SUCCESS         The method was successful.
  72          * @exception E_OBJ_NOT_FOUND   The IPC server was not found.
  73          * @exception E_OUT_OF_MEMORY   Insufficient memory.
  74          * @exception E_SYSTEM          A system error occurred.
  75          */
  76         result Construct(const Tizen::Base::String& serverName, const _IIpcClientEventListener* pListener = null);
  77
  78         /**
  79          * Returns the name of the IPC server.
  80          *
  81          * @return The name of the IPC server.
  82          */
  83         Tizen::Base::String GetName(void) const;
  84
  85         /**
  86          * Sends a request message to an IPC server.
  87          *
  88          * @code
  89          *
  90          * int
  91          * CalculatorProxy::Add(int a , int b)
  92          * {
  93          *    int c = 0;
  94          *
  95          *    My_sum mySum(a, b, &c);
  96          *
  97          *    __pIpcClient->SendRequest(mySum);
  98          *
  99          *    return c;
 100          * }
 101          *
 102          * @endcode
 103          * @return An error code
 104          * @param[in] message   The message to send
 105          * @exception E_SUCCESS         The method was successful.
 106          * @exception E_INVALID_STATE   The instance is in an invalid state.
 107          * @exception E_OUT_OF_MEMORY   Insufficient memory.
 108          * @exception E_SYSTEM          A system error occurred.
 109          *
 110          */
 111         result SendRequest(const IPC::Message& message);
 112
 113         result SendRequest(IPC::Message* pMessage);
 114
 115 private:
 116         _IpcClient(const _IpcClient& value);
 117
 118         _IpcClient& operator =(const _IpcClient& value);
 119
 120         result Send(IPC::Message* pMessage);
 121
 122         result SendAsync(IPC::Message* pMessage);
 123
 124         result SendSync(IPC::Message* pMessage);
 125
 126         result MakeConnection(bool forReverse = false);
 127
 128         int AcquireFd(void);
 129
 130         void ReleaseFd(int fd);
 131
 132         static gboolean OnReadMessage(GIOChannel* source, GIOCondition condition, gpointer data);
 133
 134         gboolean HandleReceivedMessage(GIOChannel* source, GIOCondition condition);
 135
 136 private:
 137         GSource* __pReverseSource;
 138
 139         std::vector <int> __fds;
 140         Tizen::Base::Runtime::Mutex* __pFdLock;
 141         Tizen::Base::String __name;
 142         _IIpcClientEventListener* __pListener;
 143
 144         static const int __MAX_MESSAGE_BUFFER_SIZE = 1024;
 145         char __messageBuffer[__MAX_MESSAGE_BUFFER_SIZE];
 146         std::string __pending;
 147 };
 148
 149 } } // Tizen::Io
 150
 151 #endif // _FIO_INTERNAL_IPC_CLIENT_H_