Searched refs:fd_ (Results 1 - 25 of 44) sorted by relevance

12

/system/update_engine/payload_consumer/
H A Dfile_writer.cc24 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 Dfile_descriptor.cc30 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 Dfile_descriptor.h114 EintrSafeFileDescriptor() : fd_(-1) {}
132 return (fd_ >= 0);
136 int fd_; member in class:chromeos_update_engine::EintrSafeFileDescriptor
H A Dbzip_extent_writer_unittest.cc44 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 Dextent_writer_unittest.cc49 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 Dextent_writer.cc52 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 Dio_ready_handler.cc28 : 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 Dio_input_handler.cc30 : fd_(fd),
40 fd_, true, base::MessageLoopForIO::WATCH_READ,
51 CHECK_EQ(fd_, fd);
H A Dio_input_handler.h43 int fd_; member in class:shill::IOInputHandler
H A Dio_ready_handler.h46 int fd_; member in class:shill::IOReadyHandler
/system/core/adb/
H A Dadb_utils.h72 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 Dshell_service_protocol.cpp25 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 Dasync_connection.cc44 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 Dprotobuf_lite_streams.cc50 : 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 Dprotobuf_lite_streams.h46 int fd_; member in class:shill::ProtobufLiteCopyingFileInputStream
/system/tpm/trunks/
H A Dtpm_handle.cc36 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 Dtpm_handle.h56 int fd_; // A file descriptor for /dev/tpm0. member in class:trunks::TpmHandle
/system/core/libmemunreachable/
H A DLineBuffer.h29 int fd_; member in class:LineBuffer
H A DLeakPipe.h78 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 DLineBuffer.cpp26 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 DLineBuffer.h29 int fd_; member in class:LineBuffer
H A DLineBuffer.cpp23 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 Dutils.h65 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 Dzip_writer_test.cc28 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 Dtest_channel_transport.h37 // file descriptor gets stored in |fd_|.
68 std::unique_ptr<base::ScopedFD> fd_; member in class:test_vendor_lib::TestChannelTransport

Completed in 475 milliseconds

12