Home
last modified time | relevance | path

Searched refs:fd_ (Results 1 – 25 of 64) sorted by relevance

123

/system/update_engine/payload_consumer/
Dfile_descriptor.cc39 CHECK_EQ(fd_, -1); in Open()
40 return ((fd_ = HANDLE_EINTR(open(path, flags, mode))) >= 0); in Open()
44 CHECK_EQ(fd_, -1); in Open()
45 return ((fd_ = HANDLE_EINTR(open(path, flags))) >= 0); in Open()
49 CHECK_GE(fd_, 0); in Read()
50 return HANDLE_EINTR(read(fd_, buf, count)); in Read()
54 CHECK_GE(fd_, 0); in Write()
60 ssize_t ret = HANDLE_EINTR(write(fd_, char_buf, count)); in Write()
73 CHECK_GE(fd_, 0); in Seek()
74 return lseek64(fd_, offset, whence); in Seek()
[all …]
Dfile_writer.cc24 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, count - bytes_written); in Write()
47 CHECK_GE(fd_, 0); in Close()
48 int rc = close(fd_); in Close()
52 fd_ = -2; in Close()
Dextent_reader_unittest.cc59 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 …]
Dcached_file_descriptor.h77 : CachedFileDescriptorBase(cache_size), fd_(fd) {} in CachedFileDescriptor()
80 virtual FileDescriptor* GetFd() { return fd_.get(); } in GetFd()
81 FileDescriptorPtr fd_; variable
87 : CachedFileDescriptorBase(cache_size), fd_(fd) {} in UnownedCachedFileDescriptor()
92 virtual FileDescriptor* GetFd() { return fd_; } in GetFd()
93 FileDescriptor* fd_; variable
Dbzip_extent_writer_unittest.cc42 fd_.reset(new EintrSafeFileDescriptor); in SetUp()
43 ASSERT_TRUE(fd_->Open(temp_file_.path().c_str(), O_RDWR, 0600)); in SetUp()
45 void TearDown() override { fd_->Close(); } in TearDown()
47 FileDescriptorPtr fd_; member in chromeos_update_engine::BzipExtentWriterTest
63 BzipExtentWriter bzip_writer(std::make_unique<DirectExtentWriter>(fd_)); in TEST_F()
95 BzipExtentWriter bzip_writer(std::make_unique<DirectExtentWriter>(fd_)); in TEST_F()
Dextent_writer_unittest.cc50 fd_.reset(new EintrSafeFileDescriptor); in SetUp()
51 ASSERT_TRUE(fd_->Open(temp_file_.path().c_str(), O_RDWR, 0600)); in SetUp()
53 void TearDown() override { fd_->Close(); } in TearDown()
61 FileDescriptorPtr fd_; member in chromeos_update_engine::ExtentWriterTest
68 DirectExtentWriter direct_writer{fd_}; in TEST_F()
86 DirectExtentWriter direct_writer{fd_}; in TEST_F()
110 DirectExtentWriter direct_writer{fd_}; in WriteAlignedExtents()
150 DirectExtentWriter direct_writer{fd_}; in TEST_F()
Dfile_descriptor.h120 EintrSafeFileDescriptor() : fd_(-1) {} in EintrSafeFileDescriptor()
137 bool IsOpen() override { return (fd_ >= 0); } in IsOpen()
138 int Fd() override { return fd_; } in Fd()
141 int fd_;
Dextent_writer.cc50 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()
/system/teeui/libteeui/src/
Devdev.cpp177 EventDev::EventDev() : fd_(-1), path_("") {} in EventDev()
178 EventDev::EventDev(const std::string& path) : fd_(-1), path_(path) {} in EventDev()
179 EventDev::EventDev(EventDev&& other) : fd_(other.fd_), path_(std::move(other.path_)) { in EventDev()
180 other.fd_ = -1; in EventDev()
184 fd_ = other.fd_; in operator =()
186 other.fd_ = -1; in operator =()
190 if (fd_ >= 0) { in grab()
193 fd_ = TEMP_FAILURE_RETRY(open(path_.c_str(), O_RDWR | O_NONBLOCK)); in grab()
194 if (fd_ < 0) { in grab()
198 int error = ioctl(fd_, EVIOCGRAB, 1); in grab()
[all …]
/system/core/fastboot/device/
Dutility.h42 fd_ = {}; in ~PartitionHandle()
47 int fd() const { return fd_.get(); } in fd()
54 fd_.reset(); in Open()
56 fd_ = android::base::unique_fd(TEMP_FAILURE_RETRY(open(path_.c_str(), flags))); in Open()
57 if (fd_ < 0) { in Open()
66 if (fd_.ok() && (flags | O_EXCL | O_CLOEXEC | O_BINARY) == flags_) { in Reset()
70 off_t offset = fd_.ok() ? lseek(fd_.get(), 0, SEEK_CUR) : 0; in Reset()
82 if (lseek(fd_.get(), offset, SEEK_SET) != offset) { in Reset()
91 android::base::unique_fd fd_; variable
/system/libbase/include/android-base/
Dunique_fd.h72 int fd = s.fd_;
73 s.fd_ = -1;
80 int get() const { return fd_; } in get()
101 tag(fd_, this, nullptr); in release()
102 int ret = fd_; in release()
103 fd_ = -1; in release()
111 if (fd_ != -1) { in reset()
112 close(fd_, this); in reset()
115 fd_ = new_value; in reset()
123 int fd_ = -1; variable
[all …]
/system/memory/libmemunreachable/
DLeakPipe.h78 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()
/system/libziparchive/
Dzip_writer_test.cc32 int fd_; member
37 fd_ = temp_file_->fd; in SetUp()
38 file_ = fdopen(fd_, "w"); in SetUp()
57 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
60 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); in TEST_F()
82 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
85 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); in TEST_F()
108 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
111 ASSERT_EQ(0, OpenArchiveFd(fd_, "temp", &handle, false)); in TEST_F()
140 ASSERT_GE(0, lseek(fd_, 0, SEEK_SET)); in TEST_F()
[all …]
/system/testing/gtest_extras/
DTest.cpp45 fd_(fd), in Test()
53 if (fd_ != -1) { in CloseFd()
54 close(fd_); in CloseFd()
55 fd_ = -1; in CloseFd()
86 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer, sizeof(buffer) - 1)); in Read()
106 while (fd_ != -1) { in ReadUntilClosed()
/system/logging/logd/
DRecordingLogBuffer.cpp42 if (!fd_.ok()) { in RecordLogMessage()
43 fd_.reset(open("/data/misc/logd/recorded-messages", in RecordLogMessage()
45 if (!fd_.ok()) { in RecordLogMessage()
50 WriteLogMessage(fd_.get(), meta, msg); in RecordLogMessage()
55 WriteLogMessage(fd_.get(), recorded_log_message, std::string(msg, len)); in RecordLogMessage()
/system/core/init/
Dkeychords_test.cpp61 int fd_; member in android::init::__anon252cc8af0111::EventHandler
64 EventHandler::EventHandler() : fd_(-1) {} in EventHandler()
66 EventHandler::EventHandler(EventHandler&& rval) noexcept : fd_(rval.fd_) { in EventHandler()
67 rval.fd_ = -1; in EventHandler()
71 fd_ = rval.fd_; in operator =()
72 rval.fd_ = -1; in operator =()
77 if (fd_ == -1) return; in ~EventHandler()
78 ::ioctl(fd_, UI_DEV_DESTROY); in ~EventHandler()
79 ::close(fd_); in ~EventHandler()
83 if (fd_ != -1) return true; in init()
[all …]
/system/core/libprocessgroup/
Dtask_profiles.cpp314 FdCacheHelper::Init(controller_.GetTasksFilePath(path_), fd_[ProfileAction::RCT_TASK]); in SetCgroupAction()
316 FdCacheHelper::Init(controller_.GetProcsFilePath(path_, 0, 0), fd_[ProfileAction::RCT_PROCESS]); in SetCgroupAction()
357 if (FdCacheHelper::IsCached(fd_[cache_type])) { in UseCachedFd()
359 if (!AddTidToCgroup(id, fd_[cache_type], controller()->name())) { in UseCachedFd()
366 if (fd_[cache_type] == FdCacheHelper::FDS_INACCESSIBLE) { in UseCachedFd()
372 fd_[cache_type] == FdCacheHelper::FDS_APP_DEPENDENT) { in UseCachedFd()
427 if (fd_[cache_type] != FdCacheHelper::FDS_NOT_CACHED) { in EnableResourceCaching()
432 FdCacheHelper::Cache(controller_.GetTasksFilePath(path_), fd_[cache_type]); in EnableResourceCaching()
436 FdCacheHelper::Cache(controller_.GetProcsFilePath(path_, 0, 0), fd_[cache_type]); in EnableResourceCaching()
446 FdCacheHelper::Drop(fd_[cache_type]); in DropResourceCaching()
[all …]
/system/core/fs_mgr/libsnapshot/libsnapshot_cow/
Dcow_writer.cpp135 CowWriter::CowWriter(const CowOptions& options) : ICowWriter(options), fd_(-1) { in CowWriter()
223 fd_ = owned_fd_; in SetFd()
226 fd_ = fd; in SetFd()
347 if (lseek(fd_.get(), 0, SEEK_SET) < 0) { in OpenForWrite()
358 if (!android::base::WriteFully(fd_, &header_, sizeof(header_))) { in OpenForWrite()
366 if (!android::base::WriteFully(fd_, data.data(), header_.buffer_size)) { in OpenForWrite()
377 if (lseek(fd_.get(), sizeof(header_) + header_.buffer_size, SEEK_SET) < 0) { in OpenForWrite()
392 if (!reader->Parse(fd_, {label}) || !reader->GetHeader(&header_)) { in OpenForAppend()
413 if (lseek(fd_.get(), next_op_pos_, SEEK_SET) < 0) { in OpenForAppend()
642 if (lseek(fd_.get(), next_op_pos_, SEEK_SET) < 0) { in Finalize()
[all …]
Dcow_reader.cpp38 : fd_(-1), in CowReader()
74 fd_ = owned_fd_.get(); in InitForMerge()
76 auto pos = lseek(fd_.get(), 0, SEEK_END); in InitForMerge()
83 if (lseek(fd_.get(), 0, SEEK_SET) < 0) { in InitForMerge()
87 if (!android::base::ReadFully(fd_, &header_, sizeof(header_))) { in InitForMerge()
101 fd_ = fd; in Parse()
103 auto pos = lseek(fd_.get(), 0, SEEK_END); in Parse()
110 if (lseek(fd_.get(), 0, SEEK_SET) < 0) { in Parse()
114 if (!android::base::ReadFully(fd_, &header_, sizeof(header_))) { in Parse()
173 pos = lseek(fd_.get(), init_offset, SEEK_SET); in ParseOps()
[all …]
/system/update_engine/aosp/
Dlogging_android.cc125 fd_.reset(TEMP_FAILURE_RETRY( in FileLogger()
129 if (fd_ == -1) { in FileLogger()
137 if (fchmod(fd_.get(), 0640) == -1) { in FileLogger()
146 FileLogger(const FileLogger& other) { fd_.reset(dup(other.fd_)); } in FileLogger()
148 if (fd_ == -1) { in operator ()()
161 android::base::unique_fd fd_; member in chromeos_update_engine::__anonc92b3f1c0111::FileLogger
164 android::base::WriteFully(fd_, message.data(), message.size())); in WriteToFd()
/system/core/libappfuse/
DFuseAppLoop.cc134 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/core/fs_mgr/libdm/
Ddm.cpp48 DeviceMapper::DeviceMapper() : fd_(-1) { in DeviceMapper()
49 fd_ = TEMP_FAILURE_RETRY(open("/dev/device-mapper", O_RDWR | O_CLOEXEC)); in DeviceMapper()
50 if (fd_ < 0) { in DeviceMapper()
77 if (ioctl(fd_, DM_DEV_CREATE, &io)) { in CreateDevice()
112 if (ioctl(fd_, DM_DEV_REMOVE, &io)) { in DeleteDevice()
146 if (ioctl(fd_, DM_DEV_REMOVE, &io)) { in DeleteDeviceDeferred()
233 if (ioctl(fd_, DM_DEV_STATUS, &io) < 0) { in GetDeviceUniquePath()
251 if (ioctl(fd_, DM_DEV_STATUS, &io) < 0) { in GetDeviceNameAndUuid()
268 if (ioctl(fd_, DM_DEV_STATUS, &io) < 0) { in GetDetailedInfo()
277 if (ioctl(fd_, DM_DEV_STATUS, &io) < 0) { in GetState()
[all …]
Dloop_control.cpp148 : fd_(fd), owned_fd_(-1) { in LoopDevice()
156 : fd_(-1), owned_fd_(-1) { in LoopDevice()
162 fd_ = owned_fd_; in LoopDevice()
173 valid_ = control_.Attach(fd_.get(), timeout_ms, &device_); in Init()
/system/incremental_delivery/incfs/include/
Dincfs.h65 explicit UniqueFd(int fd) : fd_(fd) {} in UniqueFd()
68 UniqueFd(UniqueFd&& other) noexcept : fd_(other.release()) {} in UniqueFd()
71 fd_ = other.release();
77 ::close(fd_); in close()
78 fd_ = -1; in close()
81 int get() const { return fd_; } in get()
82 [[nodiscard]] bool ok() const { return fd_ >= 0; } in ok()
83 [[nodiscard]] int release() { return std::exchange(fd_, -1); } in release()
86 int fd_;
/system/update_engine/common/
Dutils.h429 explicit ScopedFdCloser(int* fd) : fd_(fd) {} in ScopedFdCloser()
431 if (should_close_ && fd_ && (*fd_ >= 0) && !IGNORE_EINTR(close(*fd_))) in ~ScopedFdCloser()
432 *fd_ = -1; in ~ScopedFdCloser()
437 int* fd_;
470 CHECK(utils::MakeTempFile(pattern, &path_, open_fd ? &fd_ : nullptr));
473 CHECK_GE(fd_, 0);
474 fd_closer_.reset(new ScopedFdCloser(&fd_));
485 return fd_; in fd()
496 int fd_{-1};

123