| /system/update_engine/payload_consumer/ |
| D | file_descriptor.cc | 32 CHECK_EQ(fd_, -1); in Open()
33 return ((fd_ = HANDLE_EINTR(open(path, flags, mode))) >= 0); in Open()
37 CHECK_EQ(fd_, -1); in Open()
38 return ((fd_ = HANDLE_EINTR(open(path, flags))) >= 0); in Open()
42 CHECK_GE(fd_, 0); in Read()
43 return HANDLE_EINTR(read(fd_, buf, count)); in Read()
47 CHECK_GE(fd_, 0); in Write()
53 ssize_t ret = HANDLE_EINTR(write(fd_, char_buf, count)); in Write()
66 CHECK_GE(fd_, 0); in Seek()
67 return lseek64(fd_, offset, whence); in Seek()
[all …]
|
| D | file_writer.cc | 24 CHECK_EQ(fd_, -1); in Open()
25 fd_ = open(path, flags, mode); in Open()
26 if (fd_ < 0) in Open()
32 CHECK_GE(fd_, 0); in Write()
37 ssize_t rc = write(fd_, char_bytes + bytes_written, in Write()
48 CHECK_GE(fd_, 0); in Close()
49 int rc = close(fd_); in Close()
53 fd_ = -2; in Close()
|
| D | cached_file_descriptor.h | 34 CachedFileDescriptor(FileDescriptorPtr fd, size_t cache_size) : fd_(fd) { in CachedFileDescriptor()
40 return fd_->Open(path, flags, mode); in Open()
43 return fd_->Open(path, flags); in Open()
46 return fd_->Read(buf, count); in Read()
50 uint64_t BlockDevSize() override { return fd_->BlockDevSize(); } in BlockDevSize()
55 return fd_->BlkIoctl(request, start, length, result); in BlkIoctl()
59 bool IsSettingErrno() override { return fd_->IsSettingErrno(); } in IsSettingErrno()
60 bool IsOpen() override { return fd_->IsOpen(); } in IsOpen()
66 FileDescriptorPtr fd_; variable
|
| D | extent_reader_unittest.cc | 59 fd_.reset(new EintrSafeFileDescriptor()); in SetUp()
60 ASSERT_TRUE(fd_->Open(temp_file_.path().c_str(), O_RDONLY, 0600)); in SetUp()
62 void TearDown() override { fd_->Close(); } in TearDown()
74 FileDescriptorPtr fd_; member in chromeos_update_engine::ExtentReaderTest
82 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
94 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
103 EXPECT_TRUE(reader.Init(fd_, {}, kBlockSize)); in TEST_F()
113 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
122 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
129 reader.Init(fd_, {}, kBlockSize); in TEST_F()
[all …]
|
| D | bzip_extent_writer_unittest.cc | 46 fd_.reset(new EintrSafeFileDescriptor); in SetUp()
47 ASSERT_TRUE(fd_->Open(temp_file_.path().c_str(), O_RDWR, 0600)); in SetUp()
50 fd_->Close(); in TearDown()
55 FileDescriptorPtr fd_; member in chromeos_update_engine::BzipExtentWriterTest
73 bzip_writer.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
108 bzip_writer.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
|
| D | extent_writer_unittest.cc | 50 fd_.reset(new EintrSafeFileDescriptor); in SetUp()
51 ASSERT_TRUE(fd_->Open(temp_file_.path().c_str(), O_RDWR, 0600)); in SetUp()
54 fd_->Close(); in TearDown()
64 FileDescriptorPtr fd_; member in chromeos_update_engine::ExtentWriterTest
73 direct_writer.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
93 direct_writer.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
119 direct_writer.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in WriteAlignedExtents()
165 zero_pad_writer.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TestZeroPad()
169 fd_->Seek(kBlockSize - missing_bytes, SEEK_SET); in TestZeroPad()
170 EXPECT_EQ(3, fd_->Write("xxx", 3)); in TestZeroPad()
[all …]
|
| D | cached_file_descriptor.cc | 43 if (fd_->Seek(next_offset, SEEK_SET) < 0) { in Seek()
76 return FlushCache() && fd_->Flush(); in Flush()
81 return FlushCache() && fd_->Close(); in Close()
87 auto bytes_wrote = fd_->Write(cache_.data() + begin, bytes_cached_ - begin); in FlushCache()
|
| D | xz_extent_writer_unittest.cc | 90 EXPECT_TRUE(xz_writer_->Init(fd_, {}, 1024)); in WriteAll()
106 FileDescriptorPtr fd_; member in chromeos_update_engine::XzExtentWriterTest
137 EXPECT_TRUE(xz_writer_->Init(fd_, {}, 1024)); in TEST_F()
148 EXPECT_TRUE(xz_writer_->Init(fd_, {}, 1024)); in TEST_F()
|
| D | file_descriptor.h | 113 EintrSafeFileDescriptor() : fd_(-1) {} in EintrSafeFileDescriptor()
132 return (fd_ >= 0); in IsOpen()
136 int fd_;
|
| D | extent_writer.cc | 50 TEST_AND_RETURN_FALSE_ERRNO(fd_->Seek(offset, SEEK_SET) != in Write()
53 utils::WriteAll(fd_, c_bytes + bytes_written, bytes_to_write)); in Write()
|
| D | file_writer.h | 78 int fd() const { return fd_; } in fd()
81 int fd_{-1};
|
| /system/tpm/trunks/ |
| D | tpm_handle.cc | 36 TpmHandle::TpmHandle() : fd_(kInvalidFileDescriptor) {} in TpmHandle()
39 int result = IGNORE_EINTR(close(fd_)); in ~TpmHandle()
47 if (fd_ != kInvalidFileDescriptor) { in Init()
51 fd_ = HANDLE_EINTR(open(kTpmDevice, O_RDWR)); in Init()
52 if (fd_ == kInvalidFileDescriptor) { in Init()
76 CHECK_NE(fd_, kInvalidFileDescriptor); in SendCommandInternal()
77 int result = HANDLE_EINTR(write(fd_, command.data(), command.length())); in SendCommandInternal()
88 result = HANDLE_EINTR(read(fd_, response_buf, kTpmBufferSize)); in SendCommandInternal()
|
| /system/core/libmemunreachable/ |
| D | LeakPipe.h | 78 LeakPipeBase() : fd_(-1) {} in LeakPipeBase()
82 void SetFd(int fd) { fd_ = fd; } in SetFd()
85 close(fd_); in Close()
86 fd_ = -1; in Close()
90 int fd_;
102 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, &value, sizeof(T))); in Send()
121 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, vector.data(), size)); in SendVector()
140 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, reinterpret_cast<void*>(value), sizeof(T))); in Receive()
163 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, ptr, size)); in ReceiveVector()
|
| D | LineBuffer.cpp | 29 : fd_(fd), buffer_(buffer), buffer_len_(buffer_len) {} in LineBuffer()
49 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1)); in GetLine()
|
| /system/core/adb/ |
| D | shell_service_protocol.cpp | 25 ShellProtocol::ShellProtocol(int fd) : fd_(fd) { in ShellProtocol()
35 if (!ReadFdExactly(fd_, buffer_, kHeaderSize)) { in Read()
46 if (read_length && !ReadFdExactly(fd_, data(), read_length)) { in Read()
61 return WriteFdExactly(fd_, buffer_, kHeaderSize + length); in Write()
|
| /system/core/libziparchive/ |
| D | zip_writer_test.cc | 32 int fd_; member
37 fd_ = temp_file_->fd; in SetUp()
38 file_ = fdopen(fd_, "w"); in SetUp()
59 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
62 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); in TEST_F()
91 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
94 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); in TEST_F()
126 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
129 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); in TEST_F()
160 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
[all …]
|
| D | zip_archive_private.h | 96 : has_fd_(true), fd_(fd), base_ptr_(nullptr), data_length_(0) {} in MappedZipFile()
99 : has_fd_(false), fd_(-1), base_ptr_(address), data_length_(static_cast<off64_t>(length)) {} in MappedZipFile()
118 const int fd_; variable
|
| /system/extras/simpleperf/ |
| D | UnixSocket.cpp | 111 read_event_ = loop.AddReadEvent(fd_, [&]() { return ReadData(); }); in PrepareForIO()
116 write_event_ = loop.AddWriteEvent(fd_, [&]() { return WriteData(); }); in PrepareForIO()
134 TEMP_FAILURE_RETRY(send(fd_, write_data, write_data_size, MSG_NOSIGNAL)); in WriteData()
164 TEMP_FAILURE_RETRY(read(fd_, &read_buffer_[read_buffer_size_], in ReadData()
221 close(fd_); in CloseConnection()
222 fd_ = -1; in CloseConnection()
227 if (fd_ != -1) { in ~UnixSocketConnection()
231 close(fd_); in ~UnixSocketConnection()
|
| D | utils.h | 68 fd_ = other.fd_; in FileHelper()
69 other.fd_ = -1; in FileHelper()
75 return fd_ != -1;
79 return fd_; in fd()
83 explicit FileHelper(int fd) : fd_(fd) {} in FileHelper()
84 int fd_; variable
|
| /system/bt/binder/android/os/ |
| D | parcel_file_descriptor.cc | 28 CHECK(fd_ >= 0); in writeToParcel()
29 return parcel->writeParcelFileDescriptor(fd_, takeOwnership_); in writeToParcel()
38 fd_ = fd; in setFileDescriptor()
|
| D | parcel_file_descriptor.h | 27 ParcelFileDescriptor() : fd_(-1), takeOwnership_(false) {} in ParcelFileDescriptor()
47 int fd_;
|
| /system/extras/libperfmgr/ |
| D | Node.cc | 85 fd_.reset(TEMP_FAILURE_RETRY( in Update()
88 if (fd_ == -1 || !android::base::WriteStringToFd(req_value, fd_)) { in Update()
90 << " with value: " << req_value << ", fd: " << fd_; in Update()
95 fsync(fd_); in Update()
102 fd_.reset(); in Update()
|
| /system/core/libappfuse/ |
| D | FuseAppLoop.cc | 134 FuseAppLoop::FuseAppLoop(base::unique_fd&& fd) : fd_(std::move(fd)) {} in FuseAppLoop()
151 return response.Write(fd_); in ReplySimple()
163 return response.Write(fd_); in ReplyLookup()
174 return response.Write(fd_); in ReplyGetAttr()
181 return response.Write(fd_); in ReplyOpen()
189 return response.Write(fd_); in ReplyWrite()
196 return response.WriteWithBody(fd_, sizeof(FuseResponse), data); in ReplyRead()
216 if (!epoll_controller->AddFd(fd_, EPOLLIN, &last_event)) { in Start()
239 if (!HandleMessage(this, &buffer, fd_, callback)) { in Start()
|
| /system/extras/memory_replay/ |
| D | LineBuffer.cpp | 23 LineBuffer::LineBuffer(int fd, char* buffer, size_t buffer_len) : fd_(fd), buffer_(buffer), buffer_… in LineBuffer()
44 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1)); in GetLine()
|
| /system/update_engine/common/ |
| D | utils.h | 340 explicit ScopedFdCloser(int* fd) : fd_(fd) {} in ScopedFdCloser()
342 if (should_close_ && fd_ && (*fd_ >= 0) && !IGNORE_EINTR(close(*fd_))) in ~ScopedFdCloser()
343 *fd_ = -1; in ~ScopedFdCloser()
347 int* fd_;
|