Home | History | Annotate | Download | only in payload_consumer

Lines Matching refs:fd_

32   CHECK_EQ(fd_, -1);
33 return ((fd_ = HANDLE_EINTR(open(path, flags, mode))) >= 0);
37 CHECK_EQ(fd_, -1);
38 return ((fd_ = HANDLE_EINTR(open(path, flags))) >= 0);
42 CHECK_GE(fd_, 0);
43 return HANDLE_EINTR(read(fd_, buf, count));
47 CHECK_GE(fd_, 0);
53 ssize_t ret = HANDLE_EINTR(write(fd_, char_buf, count));
66 CHECK_GE(fd_, 0);
67 return lseek64(fd_, offset, whence);
71 if (fd_ < 0)
74 if (fstat(fd_, &stbuf) < 0) {
75 PLOG(ERROR) << "Error stat-ing fd " << fd_;
80 off_t block_size = utils::BlockDevSize(fd_);
99 if (request == BLKZEROOUT && ioctl(fd_, BLKDISCARDZEROES, &arg) == 0 && arg)
102 // Ensure the |fd_| is in O_DIRECT mode during this operation, so the write
105 int flags = fcntl(fd_, F_GETFL, 0);
107 PLOG(WARNING) << "Couldn't get flags on fd " << fd_;
110 if ((flags & O_DIRECT) == 0 && fcntl(fd_, F_SETFL, flags | O_DIRECT) == -1) {
111 PLOG(WARNING) << "Couldn't set O_DIRECT on fd " << fd_;
116 *result = ioctl(fd_, request, range);
118 if ((flags & O_DIRECT) == 0 && fcntl(fd_, F_SETFL, flags) == -1) {
119 PLOG(WARNING) << "Couldn't remove O_DIRECT on fd " << fd_;
127 CHECK_GE(fd_, 0);
132 CHECK_GE(fd_, 0);
133 if (IGNORE_EINTR(close(fd_)))
135 fd_ = -1;