1589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian/* 2589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * Copyright (C) 2010 The Android Open Source Project 3589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * 4589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * Licensed under the Apache License, Version 2.0 (the "License"); 5589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * you may not use this file except in compliance with the License. 6589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * You may obtain a copy of the License at 7589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * 8589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * http://www.apache.org/licenses/LICENSE-2.0 9589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * 10589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * Unless required by applicable law or agreed to in writing, software 11589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * distributed under the License is distributed on an "AS IS" BASIS, 12589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * See the License for the specific language governing permissions and 14589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian * limitations under the License. 15589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian */ 16589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 17589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <stdint.h> 18589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <sys/types.h> 197b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian#include <sys/socket.h> 20589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 21589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <fcntl.h> 2299fe3c6d3dcb6fb26bf283343f946d031b052dffMathias Agopian#include <unistd.h> 23589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 24589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <utils/Errors.h> 25589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 26589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <binder/Parcel.h> 27589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 285cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian#include <gui/BitTube.h> 29589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 30589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopiannamespace android { 31589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian// ---------------------------------------------------------------------------- 32589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 337b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian// Socket buffer size. The default is typically about 128KB, which is much larger than 347b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian// we really need. So we make it smaller. 3590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopianstatic const size_t DEFAULT_SOCKET_BUFFER_SIZE = 4 * 1024; 367b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 377b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 385cae0d0699a169e468fff3e21165f35db12f2cdeMathias AgopianBitTube::BitTube() 39589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian : mSendFd(-1), mReceiveFd(-1) 40589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 4190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian init(DEFAULT_SOCKET_BUFFER_SIZE, DEFAULT_SOCKET_BUFFER_SIZE); 4290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian} 4390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 4490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias AgopianBitTube::BitTube(size_t bufsize) 4590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian : mSendFd(-1), mReceiveFd(-1) 4690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian{ 4790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian init(bufsize, bufsize); 48589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 49589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 505cae0d0699a169e468fff3e21165f35db12f2cdeMathias AgopianBitTube::BitTube(const Parcel& data) 51589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian : mSendFd(-1), mReceiveFd(-1) 52589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 53589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian mReceiveFd = dup(data.readFileDescriptor()); 5490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian if (mReceiveFd < 0) { 555cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian mReceiveFd = -errno; 56e6f43ddce78d6846af12550ff9193c5c6fe5844bSteve Block ALOGE("BitTube(Parcel): can't dup filedescriptor (%s)", 575cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian strerror(-mReceiveFd)); 585cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } 59589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 60589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 615cae0d0699a169e468fff3e21165f35db12f2cdeMathias AgopianBitTube::~BitTube() 62589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 63589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian if (mSendFd >= 0) 64589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian close(mSendFd); 65589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 66589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian if (mReceiveFd >= 0) 67589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian close(mReceiveFd); 68589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 69589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 7090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopianvoid BitTube::init(size_t rcvbuf, size_t sndbuf) { 7190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian int sockets[2]; 7290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets) == 0) { 7390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian size_t size = DEFAULT_SOCKET_BUFFER_SIZE; 7490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf)); 7590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof(sndbuf)); 7690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // sine we don't use the "return channel", we keep it small... 7790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size)); 7890ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size)); 7990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian fcntl(sockets[0], F_SETFL, O_NONBLOCK); 8090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian fcntl(sockets[1], F_SETFL, O_NONBLOCK); 8190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian mReceiveFd = sockets[0]; 8290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian mSendFd = sockets[1]; 8390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian } else { 8490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian mReceiveFd = -errno; 8590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ALOGE("BitTube: pipe creation failed (%s)", strerror(-mReceiveFd)); 8690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian } 8790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian} 8890ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 895cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianstatus_t BitTube::initCheck() const 905cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian{ 915cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian if (mReceiveFd < 0) { 925cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return status_t(mReceiveFd); 935cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } 945cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return NO_ERROR; 955cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian} 965cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian 975cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianint BitTube::getFd() const 98589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 99589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian return mReceiveFd; 100589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 101589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 10256ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akellaint BitTube::getSendFd() const 10356ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella{ 10456ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella return mSendFd; 10556ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella} 10656ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 1075cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianssize_t BitTube::write(void const* vaddr, size_t size) 108589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 1095cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian ssize_t err, len; 1105cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian do { 1117b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian len = ::send(mSendFd, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL); 11290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // cannot return less than size, since we're using SOCK_SEQPACKET 1135cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian err = len < 0 ? errno : 0; 1145cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } while (err == EINTR); 1155cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return err == 0 ? len : -err; 116589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 117589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 1185cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianssize_t BitTube::read(void* vaddr, size_t size) 119589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 1205cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian ssize_t err, len; 1215cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian do { 1227b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian len = ::recv(mReceiveFd, vaddr, size, MSG_DONTWAIT); 1235cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian err = len < 0 ? errno : 0; 1245cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } while (err == EINTR); 1253ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian if (err == EAGAIN || err == EWOULDBLOCK) { 1263ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian // EAGAIN means that we have non-blocking I/O but there was 1273ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian // no data to be read. Nothing the client should care about. 1283ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian return 0; 1293ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian } 1305cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return err == 0 ? len : -err; 131589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 132589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 1335cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianstatus_t BitTube::writeToParcel(Parcel* reply) const 134589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 135589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian if (mReceiveFd < 0) 136589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian return -EINVAL; 137589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 138589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian status_t result = reply->writeDupFileDescriptor(mReceiveFd); 139589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian close(mReceiveFd); 140589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian mReceiveFd = -1; 141589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian return result; 142589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 143589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 1447b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 1457b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopianssize_t BitTube::sendObjects(const sp<BitTube>& tube, 1467b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian void const* events, size_t count, size_t objSize) 1477b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian{ 14890ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian const char* vaddr = reinterpret_cast<const char*>(events); 14990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ssize_t size = tube->write(vaddr, count*objSize); 15090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 15190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // should never happen because of SOCK_SEQPACKET 152d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza LOG_ALWAYS_FATAL_IF((size >= 0) && (size % static_cast<ssize_t>(objSize)), 153911004506dcb6ee68efdfd6636e0ffc72e6972b8Mark Salyzyn "BitTube::sendObjects(count=%zu, size=%zu), res=%zd (partial events were sent!)", 15490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian count, objSize, size); 15590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 15690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian //ALOGE_IF(size<0, "error %d sending %d events", size, count); 157d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza return size < 0 ? size : size / static_cast<ssize_t>(objSize); 1587b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian} 1597b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 1607b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopianssize_t BitTube::recvObjects(const sp<BitTube>& tube, 1617b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian void* events, size_t count, size_t objSize) 1627b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian{ 16390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian char* vaddr = reinterpret_cast<char*>(events); 16490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ssize_t size = tube->read(vaddr, count*objSize); 16590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 16690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // should never happen because of SOCK_SEQPACKET 167d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza LOG_ALWAYS_FATAL_IF((size >= 0) && (size % static_cast<ssize_t>(objSize)), 168911004506dcb6ee68efdfd6636e0ffc72e6972b8Mark Salyzyn "BitTube::recvObjects(count=%zu, size=%zu), res=%zd (partial events were received!)", 16990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian count, objSize, size); 17090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 17190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian //ALOGE_IF(size<0, "error %d receiving %d events", size, count); 172d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza return size < 0 ? size : size / static_cast<ssize_t>(objSize); 1737b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian} 1747b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 175589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian// ---------------------------------------------------------------------------- 176589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian}; // namespace android 177