39     int ret = socketpair(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0, sv);  in init()  local
40     return (ret == 0);  in init()
57     size_t ret = ::send(sv[0], data, bytes, 0);  in writeAsync()  local
58     rsAssert(ret == bytes);  in writeAsync()
59     if (ret != bytes) {  in writeAsync()
60         ALOGE("writeAsync %p %zu  ret %zu", data, bytes, ret);  in writeAsync()
71     size_t ret = ::recv(sv[0], retData, retBytes, MSG_WAITALL);  in writeWaitReturn()  local
73     rsAssert(ret == retBytes);  in writeWaitReturn()
82     size_t ret = ::recv(sv[1], data, bytes, MSG_WAITALL);  in read()  local
83     rsAssert(ret == bytes || mShutdown);  in read()
86         ret = 0;  in read()
88     return ret;  in read()