rsFifoSocket.cpp revision bd726b2159c14bd78d45f3157befcb733037f8d4
1/* 2 * Copyright (C) 2011 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17#include "rsFifoSocket.h" 18#include "utils/Timers.h" 19#include "utils/StopWatch.h" 20 21#include <stdio.h> 22#include <stdlib.h> 23#include <ctype.h> 24#include <unistd.h> 25#include <poll.h> 26#include <sys/types.h> 27#include <sys/socket.h> 28 29using namespace android; 30using namespace android::renderscript; 31 32FifoSocket::FifoSocket() { 33 mShutdown = false; 34} 35 36FifoSocket::~FifoSocket() { 37 38} 39 40bool FifoSocket::init(bool supportNonBlocking, bool supportReturnValues, size_t maxDataSize) { 41 int ret = socketpair(AF_UNIX, SOCK_STREAM, 0, sv); 42 return false; 43} 44 45void FifoSocket::shutdown() { 46 mShutdown = true; 47 uint64_t d = 0; 48 ::send(sv[0], &d, sizeof(d), 0); 49 ::send(sv[1], &d, sizeof(d), 0); 50 close(sv[0]); 51 close(sv[1]); 52} 53 54bool FifoSocket::writeAsync(const void *data, size_t bytes, bool waitForSpace) { 55 if (bytes == 0) { 56 return true; 57 } 58 //ALOGE("writeAsync %p %i", data, bytes); 59 size_t ret = ::send(sv[0], data, bytes, 0); 60 rsAssert(ret == bytes); 61 if (ret != bytes) { 62 ALOGE("writeAsync %p %zu ret %zu", data, bytes, ret); 63 } 64 return true; 65} 66 67void FifoSocket::writeWaitReturn(void *retData, size_t retBytes) { 68 if (mShutdown) { 69 return; 70 } 71 72 //ALOGE("writeWaitReturn %p %i", retData, retBytes); 73 size_t ret = ::recv(sv[0], retData, retBytes, MSG_WAITALL); 74 //ALOGE("writeWaitReturn %i", ret); 75 rsAssert(ret == retBytes); 76} 77 78size_t FifoSocket::read(void *data, size_t bytes) { 79 if (mShutdown) { 80 return 0; 81 } 82 83 //ALOGE("read %p %i", data, bytes); 84 size_t ret = ::recv(sv[1], data, bytes, MSG_WAITALL); 85 rsAssert(ret == bytes || mShutdown); 86 //ALOGE("read ret %i bytes %i", ret, bytes); 87 if (mShutdown) { 88 ret = 0; 89 } 90 return ret; 91} 92 93bool FifoSocket::isEmpty() { 94 struct pollfd p; 95 p.fd = sv[1]; 96 p.events = POLLIN; 97 int r = poll(&p, 1, 0); 98 //ALOGE("poll r=%i", r); 99 return r == 0; 100} 101 102 103void FifoSocket::readReturn(const void *data, size_t bytes) { 104 //ALOGE("readReturn %p %Zu", data, bytes); 105 size_t ret = ::send(sv[1], data, bytes, 0); 106 //ALOGE("readReturn %Zu", ret); 107 //rsAssert(ret == bytes); 108} 109 110 111