/system/update_engine/payload_consumer/ |
H A D | file_writer.cc | 24 CHECK_EQ(fd_, -1); 25 fd_ = open(path, flags, mode); 26 if (fd_ < 0) 32 CHECK_GE(fd_, 0); 37 ssize_t rc = write(fd_, char_bytes + bytes_written, 48 CHECK_GE(fd_, 0); 49 int rc = close(fd_); 53 fd_ = -2;
|
H A D | file_descriptor.cc | 30 CHECK_EQ(fd_, -1); 31 return ((fd_ = HANDLE_EINTR(open(path, flags, mode))) >= 0); 35 CHECK_EQ(fd_, -1); 36 return ((fd_ = HANDLE_EINTR(open(path, flags))) >= 0); 40 CHECK_GE(fd_, 0); 41 return HANDLE_EINTR(read(fd_, buf, count)); 45 CHECK_GE(fd_, 0); 51 ssize_t ret = HANDLE_EINTR(write(fd_, char_buf, count)); 64 CHECK_GE(fd_, 0); 65 return lseek64(fd_, offse [all...] |
H A D | file_descriptor.h | 114 EintrSafeFileDescriptor() : fd_(-1) {} 132 return (fd_ >= 0); 136 int fd_; member in class:chromeos_update_engine::EintrSafeFileDescriptor
|
H A D | bzip_extent_writer_unittest.cc | 44 fd_.reset(new EintrSafeFileDescriptor); 45 ASSERT_TRUE(fd_->Open(temp_file_.path().c_str(), O_RDWR, 0600)); 48 fd_->Close(); 53 FileDescriptorPtr fd_; member in class:chromeos_update_engine::BzipExtentWriterTest 75 EXPECT_TRUE(bzip_writer.Init(fd_, extents, kBlockSize)); 113 EXPECT_TRUE(bzip_writer.Init(fd_, extents, kBlockSize));
|
H A D | extent_writer_unittest.cc | 49 fd_.reset(new EintrSafeFileDescriptor); 50 ASSERT_TRUE(fd_->Open(temp_file_.path().c_str(), O_RDWR, 0600)); 53 fd_->Close(); 63 FileDescriptorPtr fd_; member in class:chromeos_update_engine::ExtentWriterTest 77 EXPECT_TRUE(direct_writer.Init(fd_, extents, kBlockSize)); 101 EXPECT_TRUE(direct_writer.Init(fd_, extents, kBlockSize)); 136 EXPECT_TRUE(direct_writer.Init(fd_, extents, kBlockSize)); 190 EXPECT_TRUE(zero_pad_writer.Init(fd_, extents, kBlockSize)); 194 fd_->Seek(kBlockSize - missing_bytes, SEEK_SET); 195 EXPECT_EQ(3, fd_ [all...] |
H A D | extent_writer.cc | 52 TEST_AND_RETURN_FALSE_ERRNO(fd_->Seek(offset, SEEK_SET) != 55 utils::WriteAll(fd_, c_bytes + bytes_written, bytes_to_write));
|
/system/connectivity/shill/net/ |
H A D | io_ready_handler.cc | 28 : fd_(fd), 46 fd_, true, mode, &fd_watcher_, this)) { 56 CHECK_EQ(fd_, fd); 59 ready_callback_.Run(fd_); 63 CHECK_EQ(fd_, fd); 66 ready_callback_.Run(fd_);
|
H A D | io_input_handler.cc | 30 : fd_(fd), 40 fd_, true, base::MessageLoopForIO::WATCH_READ, 51 CHECK_EQ(fd_, fd);
|
H A D | io_input_handler.h | 43 int fd_; member in class:shill::IOInputHandler
|
H A D | io_ready_handler.h | 46 int fd_; member in class:shill::IOReadyHandler
|
/system/core/adb/ |
H A D | adb_utils.h | 72 if (fd != fd_) { 74 adb_close(fd_); 76 fd_ = fd; 81 int temp = fd_; 82 fd_ = -1; 87 return fd_ >= 0; 91 return fd_; 95 int fd_ = -1; member in class:ScopedFd
|
H A D | shell_service_protocol.cpp | 25 ShellProtocol::ShellProtocol(int fd) : fd_(fd) { 35 if (!ReadFdExactly(fd_, buffer_, kHeaderSize)) { 46 if (read_length && !ReadFdExactly(fd_, data(), read_length)) { 61 return WriteFdExactly(fd_, buffer_, kHeaderSize + length);
|
/system/connectivity/shill/ |
H A D | async_connection.cc | 44 fd_(-1), 53 DCHECK_LT(fd_, 0); 59 fd_ = sockets_->Socket(family, SOCK_STREAM, 0); 60 if (fd_ < 0 || 61 sockets_->SetNonBlocking(fd_) < 0) { 69 sockets_->BindToDevice(fd_, interface_name_) < 0) { 78 callback_.Run(true, fd_); // Passes ownership 79 fd_ = -1; 91 dispatcher_->CreateReadyHandler(fd_, 101 if (fd_ > [all...] |
H A D | protobuf_lite_streams.cc | 50 : fd_(fd), 51 scoped_fd_closer_(fd_), 57 return HANDLE_EINTR(read(fd_, buffer, size)); 62 lseek(fd_, count, SEEK_CUR) != static_cast<off_t>(-1)) {
|
H A D | protobuf_lite_streams.h | 46 int fd_; member in class:shill::ProtobufLiteCopyingFileInputStream
|
/system/tpm/trunks/ |
H A D | tpm_handle.cc | 36 TpmHandle::TpmHandle() : fd_(kInvalidFileDescriptor) {} 39 int result = IGNORE_EINTR(close(fd_)); 47 if (fd_ != kInvalidFileDescriptor) { 51 fd_ = HANDLE_EINTR(open(kTpmDevice, O_RDWR)); 52 if (fd_ == kInvalidFileDescriptor) { 76 CHECK_NE(fd_, kInvalidFileDescriptor); 77 int result = HANDLE_EINTR(write(fd_, command.data(), command.length())); 88 result = HANDLE_EINTR(read(fd_, response_buf, kTpmBufferSize));
|
H A D | tpm_handle.h | 56 int fd_; // A file descriptor for /dev/tpm0. member in class:trunks::TpmHandle
|
/system/core/libmemunreachable/ |
H A D | LineBuffer.h | 29 int fd_; member in class:LineBuffer
|
H A D | LeakPipe.h | 78 LeakPipeBase() : fd_(-1) {} 85 fd_ = fd; 89 close(fd_); 90 fd_ = -1; 94 int fd_; member in class:LeakPipe::LeakPipeBase 106 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, &value, sizeof(T))); 125 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, vector.data(), size)); 144 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, reinterpret_cast<void*>(value), sizeof(T))); 167 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, ptr, size));
|
H A D | LineBuffer.cpp | 26 LineBuffer::LineBuffer(int fd, char* buffer, size_t buffer_len) : fd_(fd), buffer_(buffer), buffer_len_(buffer_len) { 47 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1));
|
/system/extras/memory_replay/ |
H A D | LineBuffer.h | 29 int fd_; member in class:LineBuffer
|
H A D | LineBuffer.cpp | 23 LineBuffer::LineBuffer(int fd, char* buffer, size_t buffer_len) : fd_(fd), buffer_(buffer), buffer_len_(buffer_len) { 44 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1));
|
/system/extras/simpleperf/ |
H A D | utils.h | 65 fd_ = other.fd_; 66 other.fd_ = -1; 72 return fd_ != -1; 76 return fd_; 80 FileHelper(int fd) : fd_(fd) {} 81 int fd_; member in class:FileHelper
|
/system/core/libziparchive/ |
H A D | zip_writer_test.cc | 28 int fd_; member in struct:zipwriter 33 fd_ = temp_file_->fd; 34 file_ = fdopen(fd_, "w"); 55 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); 58 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); 92 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); 95 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); 134 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); 137 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); 179 ASSERT_GE(0, lseek(fd_, [all...] |
/system/bt/vendor_libs/test_vendor_lib/include/ |
H A D | test_channel_transport.h | 37 // file descriptor gets stored in |fd_|. 68 std::unique_ptr<base::ScopedFD> fd_; member in class:test_vendor_lib::TestChannelTransport
|