diff options
author | 2017-03-31 16:30:42 -0700 | |
---|---|---|
committer | 2017-04-06 11:42:52 -0700 | |
commit | 27c8115510cebda13cbe24fd4caa946ea9c5003c (patch) | |
tree | 1f905493d9c2122f921ee78b3c18b24e70222b79 /libs/gui/BitTube.cpp | |
parent | 1e438d2c9ce366ef98452ed6e50699196433bf2c (diff) |
libgui: Format BitTube and move into gui namespace
Reformats BitTube using the framework default .clang-format and moves
it into the android::gui namespace.
Test: m -j + manual testing
Change-Id: I5ea748b809f37c2ec4dcfb41e7b84daf7a084368
Diffstat (limited to 'libs/gui/BitTube.cpp')
-rw-r--r-- | libs/gui/BitTube.cpp | 93 |
1 files changed, 36 insertions, 57 deletions
diff --git a/libs/gui/BitTube.cpp b/libs/gui/BitTube.cpp index 51a8d67118..63f594bf8b 100644 --- a/libs/gui/BitTube.cpp +++ b/libs/gui/BitTube.cpp @@ -17,8 +17,8 @@ #include <private/gui/BitTube.h> #include <stdint.h> -#include <sys/types.h> #include <sys/socket.h> +#include <sys/types.h> #include <fcntl.h> #include <unistd.h> @@ -27,45 +27,33 @@ #include <binder/Parcel.h> - namespace android { -// ---------------------------------------------------------------------------- +namespace gui { -// Socket buffer size. The default is typically about 128KB, which is much larger than -// we really need. So we make it smaller. +// Socket buffer size. The default is typically about 128KB, which is much larger than we really +// need. So we make it smaller. static const size_t DEFAULT_SOCKET_BUFFER_SIZE = 4 * 1024; - -BitTube::BitTube() - : mSendFd(-1), mReceiveFd(-1) -{ +BitTube::BitTube() : mSendFd(-1), mReceiveFd(-1) { init(DEFAULT_SOCKET_BUFFER_SIZE, DEFAULT_SOCKET_BUFFER_SIZE); } -BitTube::BitTube(size_t bufsize) - : mSendFd(-1), mReceiveFd(-1) -{ +BitTube::BitTube(size_t bufsize) : mSendFd(-1), mReceiveFd(-1) { init(bufsize, bufsize); } -BitTube::BitTube(const Parcel& data) - : mSendFd(-1), mReceiveFd(-1) -{ +BitTube::BitTube(const Parcel& data) : mSendFd(-1), mReceiveFd(-1) { mReceiveFd = dup(data.readFileDescriptor()); if (mReceiveFd < 0) { mReceiveFd = -errno; - ALOGE("BitTube(Parcel): can't dup filedescriptor (%s)", - strerror(-mReceiveFd)); + ALOGE("BitTube(Parcel): can't dup filedescriptor (%s)", strerror(-mReceiveFd)); } } -BitTube::~BitTube() -{ - if (mSendFd >= 0) - close(mSendFd); +BitTube::~BitTube() { + if (mSendFd >= 0) close(mSendFd); - if (mReceiveFd >= 0) - close(mReceiveFd); + if (mReceiveFd >= 0) close(mReceiveFd); } void BitTube::init(size_t rcvbuf, size_t sndbuf) { @@ -74,7 +62,7 @@ void BitTube::init(size_t rcvbuf, size_t sndbuf) { size_t size = DEFAULT_SOCKET_BUFFER_SIZE; setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf)); setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof(sndbuf)); - // sine we don't use the "return channel", we keep it small... + // since we don't use the "return channel", we keep it small... setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size)); setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size)); fcntl(sockets[0], F_SETFL, O_NONBLOCK); @@ -87,26 +75,22 @@ void BitTube::init(size_t rcvbuf, size_t sndbuf) { } } -status_t BitTube::initCheck() const -{ +status_t BitTube::initCheck() const { if (mReceiveFd < 0) { return status_t(mReceiveFd); } return NO_ERROR; } -int BitTube::getFd() const -{ +int BitTube::getFd() const { return mReceiveFd; } -int BitTube::getSendFd() const -{ +int BitTube::getSendFd() const { return mSendFd; } -ssize_t BitTube::write(void const* vaddr, size_t size) -{ +ssize_t BitTube::write(void const* vaddr, size_t size) { ssize_t err, len; do { len = ::send(mSendFd, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL); @@ -116,25 +100,22 @@ ssize_t BitTube::write(void const* vaddr, size_t size) return err == 0 ? len : -err; } -ssize_t BitTube::read(void* vaddr, size_t size) -{ +ssize_t BitTube::read(void* vaddr, size_t size) { ssize_t err, len; do { len = ::recv(mReceiveFd, vaddr, size, MSG_DONTWAIT); err = len < 0 ? errno : 0; } while (err == EINTR); if (err == EAGAIN || err == EWOULDBLOCK) { - // EAGAIN means that we have non-blocking I/O but there was - // no data to be read. Nothing the client should care about. + // EAGAIN means that we have non-blocking I/O but there was no data to be read. Nothing the + // client should care about. return 0; } return err == 0 ? len : -err; } -status_t BitTube::writeToParcel(Parcel* reply) const -{ - if (mReceiveFd < 0) - return -EINVAL; +status_t BitTube::writeToParcel(Parcel* reply) const { + if (mReceiveFd < 0) return -EINVAL; status_t result = reply->writeDupFileDescriptor(mReceiveFd); close(mReceiveFd); @@ -142,36 +123,34 @@ status_t BitTube::writeToParcel(Parcel* reply) const return result; } - -ssize_t BitTube::sendObjects(const sp<BitTube>& tube, - void const* events, size_t count, size_t objSize) -{ +ssize_t BitTube::sendObjects(const sp<BitTube>& tube, void const* events, size_t count, + size_t objSize) { const char* vaddr = reinterpret_cast<const char*>(events); - ssize_t size = tube->write(vaddr, count*objSize); + ssize_t size = tube->write(vaddr, count * objSize); // should never happen because of SOCK_SEQPACKET LOG_ALWAYS_FATAL_IF((size >= 0) && (size % static_cast<ssize_t>(objSize)), - "BitTube::sendObjects(count=%zu, size=%zu), res=%zd (partial events were sent!)", - count, objSize, size); + "BitTube::sendObjects(count=%zu, size=%zu), res=%zd (partial events were " + "sent!)", + count, objSize, size); - //ALOGE_IF(size<0, "error %d sending %d events", size, count); + // ALOGE_IF(size<0, "error %d sending %d events", size, count); return size < 0 ? size : size / static_cast<ssize_t>(objSize); } -ssize_t BitTube::recvObjects(const sp<BitTube>& tube, - void* events, size_t count, size_t objSize) -{ +ssize_t BitTube::recvObjects(const sp<BitTube>& tube, void* events, size_t count, size_t objSize) { char* vaddr = reinterpret_cast<char*>(events); - ssize_t size = tube->read(vaddr, count*objSize); + ssize_t size = tube->read(vaddr, count * objSize); // should never happen because of SOCK_SEQPACKET LOG_ALWAYS_FATAL_IF((size >= 0) && (size % static_cast<ssize_t>(objSize)), - "BitTube::recvObjects(count=%zu, size=%zu), res=%zd (partial events were received!)", - count, objSize, size); + "BitTube::recvObjects(count=%zu, size=%zu), res=%zd (partial events were " + "received!)", + count, objSize, size); - //ALOGE_IF(size<0, "error %d receiving %d events", size, count); + // ALOGE_IF(size<0, "error %d receiving %d events", size, count); return size < 0 ? size : size / static_cast<ssize_t>(objSize); } -// ---------------------------------------------------------------------------- -}; // namespace android +} // namespace gui +} // namespace android |