diff options
Diffstat (limited to 'lldb/source/Utility/KQueue.cpp')
-rw-r--r-- | lldb/source/Utility/KQueue.cpp | 105 |
1 files changed, 47 insertions, 58 deletions
diff --git a/lldb/source/Utility/KQueue.cpp b/lldb/source/Utility/KQueue.cpp index c0aace44895..56c0d1b1e3f 100644 --- a/lldb/source/Utility/KQueue.cpp +++ b/lldb/source/Utility/KQueue.cpp @@ -17,71 +17,60 @@ using namespace lldb_private; -int -KQueue::GetFD (bool can_create) -{ - if (!IsValid () && can_create) - m_fd = kqueue(); - return m_fd; +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::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; - } +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.SetErrorString("invalid kqueue fd"); - } - return 0; + 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; +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 |