BitTube.cpp revision 801ea093b0e923a61b832f2adba698a273479880
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 17801ea093b0e923a61b832f2adba698a273479880Mathias Agopian#include <private/gui/BitTube.h> 18801ea093b0e923a61b832f2adba698a273479880Mathias Agopian 19589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <stdint.h> 20589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <sys/types.h> 217b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian#include <sys/socket.h> 22589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 23589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <fcntl.h> 2499fe3c6d3dcb6fb26bf283343f946d031b052dffMathias Agopian#include <unistd.h> 25589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 26589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <utils/Errors.h> 27589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 28589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <binder/Parcel.h> 29589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 30589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 31589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopiannamespace android { 32589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian// ---------------------------------------------------------------------------- 33589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 347b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian// Socket buffer size. The default is typically about 128KB, which is much larger than 357b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian// we really need. So we make it smaller. 3690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopianstatic const size_t DEFAULT_SOCKET_BUFFER_SIZE = 4 * 1024; 377b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 387b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 395cae0d0699a169e468fff3e21165f35db12f2cdeMathias AgopianBitTube::BitTube() 40589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian : mSendFd(-1), mReceiveFd(-1) 41589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 4290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian init(DEFAULT_SOCKET_BUFFER_SIZE, DEFAULT_SOCKET_BUFFER_SIZE); 4390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian} 4490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 4590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias AgopianBitTube::BitTube(size_t bufsize) 4690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian : mSendFd(-1), mReceiveFd(-1) 4790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian{ 4890ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian init(bufsize, bufsize); 49589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 50589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 515cae0d0699a169e468fff3e21165f35db12f2cdeMathias AgopianBitTube::BitTube(const Parcel& data) 52589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian : mSendFd(-1), mReceiveFd(-1) 53589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 54589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian mReceiveFd = dup(data.readFileDescriptor()); 5590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian if (mReceiveFd < 0) { 565cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian mReceiveFd = -errno; 57e6f43ddce78d6846af12550ff9193c5c6fe5844bSteve Block ALOGE("BitTube(Parcel): can't dup filedescriptor (%s)", 585cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian strerror(-mReceiveFd)); 595cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } 60589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 61589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 625cae0d0699a169e468fff3e21165f35db12f2cdeMathias AgopianBitTube::~BitTube() 63589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 64589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian if (mSendFd >= 0) 65589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian close(mSendFd); 66589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 67589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian if (mReceiveFd >= 0) 68589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian close(mReceiveFd); 69589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 70589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 7190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopianvoid BitTube::init(size_t rcvbuf, size_t sndbuf) { 7290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian int sockets[2]; 7390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets) == 0) { 7490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian size_t size = DEFAULT_SOCKET_BUFFER_SIZE; 7590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf)); 7690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof(sndbuf)); 7790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // sine we don't use the "return channel", we keep it small... 7890ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size)); 7990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size)); 8090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian fcntl(sockets[0], F_SETFL, O_NONBLOCK); 8190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian fcntl(sockets[1], F_SETFL, O_NONBLOCK); 8290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian mReceiveFd = sockets[0]; 8390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian mSendFd = sockets[1]; 8490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian } else { 8590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian mReceiveFd = -errno; 8690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ALOGE("BitTube: pipe creation failed (%s)", strerror(-mReceiveFd)); 8790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian } 8890ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian} 8990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 905cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianstatus_t BitTube::initCheck() const 915cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian{ 925cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian if (mReceiveFd < 0) { 935cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return status_t(mReceiveFd); 945cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } 955cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return NO_ERROR; 965cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian} 975cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian 985cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianint BitTube::getFd() const 99589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 100589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian return mReceiveFd; 101589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 102589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 10356ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akellaint BitTube::getSendFd() const 10456ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella{ 10556ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella return mSendFd; 10656ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella} 10756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 1085cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianssize_t BitTube::write(void const* vaddr, size_t size) 109589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 1105cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian ssize_t err, len; 1115cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian do { 1127b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian len = ::send(mSendFd, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL); 11390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // cannot return less than size, since we're using SOCK_SEQPACKET 1145cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian err = len < 0 ? errno : 0; 1155cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } while (err == EINTR); 1165cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return err == 0 ? len : -err; 117589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 118589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 1195cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianssize_t BitTube::read(void* vaddr, size_t size) 120589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 1215cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian ssize_t err, len; 1225cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian do { 1237b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian len = ::recv(mReceiveFd, vaddr, size, MSG_DONTWAIT); 1245cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian err = len < 0 ? errno : 0; 1255cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian } while (err == EINTR); 1263ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian if (err == EAGAIN || err == EWOULDBLOCK) { 1273ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian // EAGAIN means that we have non-blocking I/O but there was 1283ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian // no data to be read. Nothing the client should care about. 1293ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian return 0; 1303ad3807a5c4039618175c042a1121c926c2c62e9Mathias Agopian } 1315cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian return err == 0 ? len : -err; 132589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 133589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 1345cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopianstatus_t BitTube::writeToParcel(Parcel* reply) const 135589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian{ 136589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian if (mReceiveFd < 0) 137589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian return -EINVAL; 138589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 139589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian status_t result = reply->writeDupFileDescriptor(mReceiveFd); 140589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian close(mReceiveFd); 141589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian mReceiveFd = -1; 142589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian return result; 143589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian} 144589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 1457b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 1467b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopianssize_t BitTube::sendObjects(const sp<BitTube>& tube, 1477b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian void const* events, size_t count, size_t objSize) 1487b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian{ 14990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian const char* vaddr = reinterpret_cast<const char*>(events); 15090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ssize_t size = tube->write(vaddr, count*objSize); 15190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 15290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // should never happen because of SOCK_SEQPACKET 153d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza LOG_ALWAYS_FATAL_IF((size >= 0) && (size % static_cast<ssize_t>(objSize)), 154911004506dcb6ee68efdfd6636e0ffc72e6972b8Mark Salyzyn "BitTube::sendObjects(count=%zu, size=%zu), res=%zd (partial events were sent!)", 15590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian count, objSize, size); 15690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 15790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian //ALOGE_IF(size<0, "error %d sending %d events", size, count); 158d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza return size < 0 ? size : size / static_cast<ssize_t>(objSize); 1597b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian} 1607b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 1617b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopianssize_t BitTube::recvObjects(const sp<BitTube>& tube, 1627b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian void* events, size_t count, size_t objSize) 1637b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian{ 16490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian char* vaddr = reinterpret_cast<char*>(events); 16590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ssize_t size = tube->read(vaddr, count*objSize); 16690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 16790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // should never happen because of SOCK_SEQPACKET 168d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza LOG_ALWAYS_FATAL_IF((size >= 0) && (size % static_cast<ssize_t>(objSize)), 169911004506dcb6ee68efdfd6636e0ffc72e6972b8Mark Salyzyn "BitTube::recvObjects(count=%zu, size=%zu), res=%zd (partial events were received!)", 17090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian count, objSize, size); 17190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 17290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian //ALOGE_IF(size<0, "error %d receiving %d events", size, count); 173d723bd7669b4fc88dc282d8bf8ba5ecb2849d22fDan Stoza return size < 0 ? size : size / static_cast<ssize_t>(objSize); 1747b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian} 1757b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 176589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian// ---------------------------------------------------------------------------- 177589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian}; // namespace android 178