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 1727c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza#pragma once 18589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 197d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza#include <android-base/unique_fd.h> 207d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza#include <binder/Parcelable.h> 21589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian#include <utils/Errors.h> 22589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 23589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopiannamespace android { 2427c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza 25589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopianclass Parcel; 26589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 2727c8115510cebda13cbe24fd4caa946ea9c5003cDan Stozanamespace gui { 28589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 296b698e4fe4ff50dcef818452283637f9870ae770Dan Stozaclass BitTube : public Parcelable { 3027c8115510cebda13cbe24fd4caa946ea9c5003cDan Stozapublic: 317d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza // creates an uninitialized BitTube (to unparcel into) 327d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza BitTube() = default; 3390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 3490ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // creates a BitTube with a a specified send and receive buffer size 3590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian explicit BitTube(size_t bufsize); 3690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 377d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza // creates a BitTube with a default (4KB) send buffer 387d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza struct DefaultSizeType {}; 397d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza static constexpr DefaultSizeType DefaultSize{}; 407d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza explicit BitTube(DefaultSizeType); 417d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza 4290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian explicit BitTube(const Parcel& data); 437d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza 447d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza virtual ~BitTube() = default; 45589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 4690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // check state after construction 475cae0d0699a169e468fff3e21165f35db12f2cdeMathias Agopian status_t initCheck() const; 48589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 4990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // get receive file-descriptor 5090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian int getFd() const; 51589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 5256ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // get the send file-descriptor. 5356ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella int getSendFd() const; 5456ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 556b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza // moves the receive file descriptor out of this BitTube 566b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza base::unique_fd moveReceiveFd(); 576b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza 586b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza // resets this BitTube's receive file descriptor to receiveFd 596b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza void setReceiveFd(base::unique_fd&& receiveFd); 606b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza 6190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // send objects (sized blobs). All objects are guaranteed to be written or the call fails. 627b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian template <typename T> 636b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza static ssize_t sendObjects(BitTube* tube, T const* events, size_t count) { 647b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian return sendObjects(tube, events, count, sizeof(T)); 657b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian } 667b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 6727c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza // receive objects (sized blobs). If the receiving buffer isn't large enough, excess messages 6827c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza // are silently discarded. 697b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian template <typename T> 706b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza static ssize_t recvObjects(BitTube* tube, T* events, size_t count) { 717b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian return recvObjects(tube, events, count, sizeof(T)); 727b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian } 737b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 747d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza // implement the Parcelable protocol. Only parcels the receive file descriptor 7590ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian status_t writeToParcel(Parcel* reply) const; 767d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza status_t readFromParcel(const Parcel* parcel); 7790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 78589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopianprivate: 7990ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian void init(size_t rcvbuf, size_t sndbuf); 8090ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 8190ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian // send a message. The write is guaranteed to send the whole message or fail. 8290ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ssize_t write(void const* vaddr, size_t size); 8390ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 8427c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza // receive a message. the passed buffer must be at least as large as the write call used to send 8527c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza // the message, excess data is silently discarded. 8690ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian ssize_t read(void* vaddr, size_t size); 8790ed3e8d7883d9c80fb8bf11b1c593bd8b2b39d0Mathias Agopian 887d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza base::unique_fd mSendFd; 897d290174b08a56ae6bc6719bec58805ca38b348bDan Stoza mutable base::unique_fd mReceiveFd; 907b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 916b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza static ssize_t sendObjects(BitTube* tube, void const* events, size_t count, size_t objSize); 927b5be95cb3903087742f1079fe89cddd8abe3696Mathias Agopian 936b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza static ssize_t recvObjects(BitTube* tube, void* events, size_t count, size_t objSize); 94589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian}; 95589ce85ee4174829cfedce91b6b2509d2a4002ebMathias Agopian 9627c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza} // namespace gui 9727c8115510cebda13cbe24fd4caa946ea9c5003cDan Stoza} // namespace android 98