Searched refs:fd_ (Results 1 – 10 of 10) sorted by relevance
| /device/google/cuttlefish/common/libs/fs/ |
| D | shared_fd.cpp | 122 pollfds[IN].fd = in.fd_; in CopyFrom()
125 pollfds[OUT].fd = fd_; in CopyFrom()
129 pollfds[STOP].fd = stop->fd_; in CopyFrom()
181 if (fd_ == -1) { in Close()
183 } else if (close(fd_) == -1) { in Close()
197 fd_ = -1; in Close()
202 int ret = fchmod(fd_, mode); in Chmod()
244 FD_SET(fd_, &fdset); in ConnectWithTimeout()
246 int select_res = select(fd_ + 1, nullptr, &fdset, nullptr, timeout); in ConnectWithTimeout()
275 if (IsOpen() && FD_ISSET(fd_, in)) { in IsSet()
[all …]
|
| D | epoll.cpp | 80 event.data.fd = fd->fd_; in Add()
81 int success = epoll_ctl(epoll_fd_->fd_, EPOLL_CTL_ADD, fd->fd_, &event); in Add()
100 event.data.fd = fd->fd_; in AddOrModify()
102 int success = epoll_ctl(epoll_fd_->fd_, operation, fd->fd_, &event); in AddOrModify()
122 event.data.fd = fd->fd_; in Modify()
123 int success = epoll_ctl(epoll_fd_->fd_, EPOLL_CTL_MOD, fd->fd_, &event); in Modify()
139 int success = epoll_ctl(epoll_fd_->fd_, EPOLL_CTL_DEL, fd->fd_, nullptr); in Delete()
153 success = TEMP_FAILURE_RETRY(epoll_wait(epoll_fd_->fd_, &event, 1, -1)); in Wait()
166 if (watched->fd_ == event.data.fd) { in Wait()
|
| D | shared_fd.h | 330 bool IsOpen() const { return fd_ != -1; } in IsOpen()
363 android::base::Append(fds, std::forward<int>(sent_fds->fd_)...); in SendFileDescriptors()
365 auto ret = android::base::SendFileDescriptorVector(fd_, buf, len, fds); in SendFileDescriptors()
406 int fd_; variable
|
| /device/google/cuttlefish/common/libs/utils/ |
| D | vsock_connection.cpp | 58 LOG(INFO) << "Disconnecting with fd status:" << fd_->StrError(); in Disconnect()
59 fd_->Shutdown(SHUT_RDWR); in Disconnect()
63 fd_->Close(); in Disconnect()
75 return fd_->IsOpen(); in IsConnected()
85 read_set.Set(fd_); in DataAvailable()
93 if (ReadExactBinary(fd_, &result) != sizeof(result)) { in Read()
102 return ReadExact(fd_, &data) == data.size(); in Read()
111 if (ReadExact(fd_, &result) != size) { in Read()
166 if (WriteAllBinary(fd_, &data) != sizeof(data)) { in Write()
175 if (WriteAll(fd_, data, size) != size) { in Write()
[all …]
|
| D | tcp_socket.cpp | 34 : fd_(SharedFD::SocketLocalClient(port, SOCK_STREAM)) {} in ClientSocket()
38 auto read_count = fd_->Read(buf.data(), buf.size()); in RecvAny()
55 auto just_read = fd_->Read(&buf[total_read], buf.size() - total_read); in Recv()
76 if (!fd_->IsOpen()) { in SendNoSignal()
79 auto just_written = fd_->Send(data + written, size - written, MSG_NOSIGNAL); in SendNoSignal()
98 : fd_{SharedFD::SocketLocalServer(port, SOCK_STREAM)} { in ServerSocket()
99 if (!fd_->IsOpen()) {
105 SharedFD client = SharedFD::Accept(*fd_); in Accept()
|
| D | tcp_socket.h | 36 ClientSocket(ClientSocket&& other) : fd_{other.fd_} {} in ClientSocket()
39 fd_ = other.fd_;
65 explicit ClientSocket(SharedFD fd) : fd_(fd) {} in ClientSocket()
67 SharedFD fd_; variable
83 SharedFD fd_;
|
| D | vsock_connection.h | 68 SharedFD fd_; variable
|
| /device/google/cuttlefish/guest/commands/bt_vhci_forwarder/ |
| D | main.cpp | 47 ssize_t send(int fd_, uint8_t type, const uint8_t* data, size_t length) { in send() argument
52 ret = TEMP_FAILURE_RETRY(writev(fd_, iov, sizeof(iov) / sizeof(iov[0]))); in send()
83 int setTerminalRaw(int fd_) { in setTerminalRaw() argument
85 int rval = tcgetattr(fd_, &terminal_settings); in setTerminalRaw()
90 rval = tcsetattr(fd_, TCSANOW, &terminal_settings); in setTerminalRaw()
|
| /device/google/cuttlefish/common/frontend/socket_vsock_proxy/ |
| D | server.cpp | 94 DupServer::DupServer(int fd) : fd_(fd), sfd_(SharedFD::Dup(fd_)) { in DupServer()
104 return fmt::format("fd: {}", fd_); in Describe()
|
| D | server.h | 64 int fd_;
|