src/common/sockets/SocketClient.h

   1 /*
   2  *  Copyright (c) 2014 Samsung Electronics Co., Ltd All Rights Reserved
   3  *
   4  *  Licensed under the Apache License, Version 2.0 (the "License");
   5  *  you may not use this file except in compliance with the License.
   6  *  You may obtain a copy of the License at
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  *  Unless required by applicable law or agreed to in writing, software
  11  *  distributed under the License is distributed on an "AS IS" BASIS,
  12  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  *  See the License for the specific language governing permissions and
  14  *  limitations under the License
  15  */
  16 /**
  17  * @file        src/common/sockets/SocketClient.h
  18  * @author      Lukasz Wojciechowski <l.wojciechow@partner.samsung.com>
  19  * @version     1.0
  20  * @brief       This file contains definition of cynara's socket client
  21  */
  22
  23 #ifndef SRC_COMMON_SOCKETS_SOCKETCLIENT_H_
  24 #define SRC_COMMON_SOCKETS_SOCKETCLIENT_H_
  25
  26 #include <memory>
  27
  28 #include <containers/BinaryQueue.h>
  29 #include <protocol/Protocol.h>
  30 #include <request/pointers.h>
  31 #include <response/pointers.h>
  32 #include <response/ResponseTaker.h>
  33 #include <sockets/Socket.h>
  34
  35 namespace Cynara {
  36
  37 class SocketClient;
  38 typedef std::shared_ptr<SocketClient> SocketClientPtr;
  39
  40 class SocketClient {
  41 private:
  42     Socket m_socket;
  43     ProtocolPtr m_protocol;
  44     BinaryQueue m_readQueue;
  45     BinaryQueue m_writeQueue;
  46
  47 public:
  48     SocketClient(const std::string &socketPath, ProtocolPtr protocol);
  49     virtual ~SocketClient() {};
  50
  51     //returns pointer to response
  52     //        or nullptr when connection to cynara service is lost
  53     ResponsePtr askCynaraServer(RequestPtr request);
  54
  55     bool isConnected(void);
  56 };
  57
  58 } // namespace Cynara
  59
  60 #endif /* SRC_COMMON_SOCKETS_SOCKETCLIENT_H_ */