| //===--------------------- KQueue.cpp ---------------------------*- C++ -*-===// |
| // |
| // The LLVM Compiler Infrastructure |
| // |
| // This file is distributed under the University of Illinois Open Source |
| // License. See LICENSE.TXT for details. |
| // |
| //===----------------------------------------------------------------------===// |
| |
| #include "KQueue.h" |
| |
| #ifdef LLDB_USE_KQUEUES |
| |
| #include "lldb/Core/Error.h" |
| |
| #include "Utility/TimeSpecTimeout.h" |
| |
| using namespace lldb_private; |
| |
| int |
| KQueue::GetFD (bool can_create) |
| { |
| if (!IsValid () && can_create) |
| m_fd = kqueue(); |
| return m_fd; |
| } |
| |
| int |
| KQueue::Close () |
| { |
| const int fd = m_fd; |
| if (fd >= 0) |
| { |
| m_fd = -1; |
| return close(fd); |
| } |
| return 0; |
| } |
| |
| int |
| KQueue::WaitForEvents (struct kevent *events, int num_events, Error &error, uint32_t timeout_usec) |
| { |
| const int fd_kqueue = GetFD(false); |
| if (fd_kqueue >= 0) |
| { |
| TimeSpecTimeout timeout; |
| const struct timespec *timeout_ptr = timeout.SetRelativeTimeoutMircoSeconds32 (timeout_usec); |
| int result = ::kevent(fd_kqueue, NULL, 0, events, num_events, timeout_ptr); |
| if (result == -1) |
| error.SetErrorToErrno(); |
| else |
| error.Clear(); |
| return result; |
| } |
| else |
| { |
| error.SetErrorString("invalid kqueue fd"); |
| } |
| return 0; |
| } |
| |
| bool |
| KQueue::AddFDEvent (int fd, bool read, bool write, bool vnode) |
| { |
| const int fd_kqueue = GetFD(true); |
| if (fd_kqueue >= 0) |
| { |
| struct kevent event; |
| event.ident = fd; |
| event.filter = 0; |
| if (read) |
| event.filter |= EVFILT_READ; |
| if (write) |
| event.filter |= EVFILT_WRITE; |
| if (vnode) |
| event.filter |= EVFILT_VNODE; |
| event.flags = EV_ADD | EV_CLEAR; |
| event.fflags = 0; |
| event.data = 0; |
| event.udata = NULL; |
| int err = ::kevent(fd_kqueue, &event, 1, NULL, 0, NULL); |
| return err == 0; |
| } |
| return false; |
| } |
| |
| #endif |