summaryrefslogtreecommitdiffstats
path: root/lldb/source/Utility/KQueue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'lldb/source/Utility/KQueue.cpp')
-rw-r--r--lldb/source/Utility/KQueue.cpp105
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
OpenPOWER on IntegriCloud