src/shared/seqpacket_socket.cpp

   1 /*
   2  * sensord
   3  *
   4  * Copyright (c) 2017 Samsung Electronics Co., Ltd.
   5  *
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  * http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  */
  19
  20 #include "seqpacket_socket.h"
  21
  22 #include <sys/types.h>
  23 #include <sys/socket.h>
  24
  25 #include "sensor_log.h"
  26
  27 using namespace ipc;
  28
  29 seqpacket_socket::seqpacket_socket()
  30 : socket()
  31 {
  32 }
  33
  34 seqpacket_socket::~seqpacket_socket()
  35 {
  36 }
  37
  38 bool seqpacket_socket::create(const std::string &path)
  39 {
  40         return socket::create_by_type(path, SOCK_SEQPACKET);
  41 }
  42
  43 ssize_t seqpacket_socket::on_send(const void *buffer, size_t size) const
  44 {
  45         ssize_t err, len;
  46
  47         do {
  48                 len = ::send(socket::get_fd(),
  49                                 reinterpret_cast<const char *>(buffer),
  50                                 size,
  51                                 socket::get_mode());
  52
  53                 err = len < 0 ? errno : 0;
  54         } while (err == EINTR);
  55
  56         if (err) {
  57                 _ERRNO(errno, _E, "Failed to send(%d, %#x, %d) = %d",
  58                         socket::get_fd(), buffer, size, len);
  59         }
  60
  61         return err == 0 ? len : -err;
  62 }
  63
  64 ssize_t seqpacket_socket::on_recv(void *buffer, size_t size) const
  65 {
  66         ssize_t err, len;
  67
  68         do {
  69                 len = ::recv(socket::get_fd(),
  70                                 reinterpret_cast<char *>(buffer),
  71                                 size,
  72                                 socket::get_mode());
  73
  74                 if (len > 0) {
  75                         err = 0;
  76                 } else if (len == 0) {
  77                         _E("Failed to recv(%d, %#p , %d) = %d, because the peer performed shutdown!",
  78                                 socket::get_fd(), buffer, size, len);
  79                         err = 1;
  80                 } else {
  81                         err = errno;
  82                 }
  83         } while (err == EINTR);
  84
  85         if ((err == EAGAIN) || (err == EWOULDBLOCK))
  86                 return 0;
  87
  88         if (err) {
  89                 _ERRNO(errno, _E, "Failed to recv(%d, %#x, %d) = %d",
  90                         socket::get_fd(), buffer, size, len);
  91         }
  92
  93         return err == 0 ? len : -err;
  94 }
  95