From 5f5503afa8c8b9cf2bc2bbe5a3a588e68eae15ef Mon Sep 17 00:00:00 2001 From: "Jason A. Donenfeld" Date: Mon, 14 May 2018 03:55:46 +0200 Subject: Add rwcancelation to darwin --- rwcancel/rwcancel_unix.go | 4 ++-- rwcancel/select_darwin.go | 12 ++++++++++++ rwcancel/select_linux.go | 13 +++++++++++++ 3 files changed, 27 insertions(+), 2 deletions(-) create mode 100644 rwcancel/select_darwin.go create mode 100644 rwcancel/select_linux.go (limited to 'rwcancel') diff --git a/rwcancel/rwcancel_unix.go b/rwcancel/rwcancel_unix.go index cd3661f..7f2c9e0 100644 --- a/rwcancel/rwcancel_unix.go +++ b/rwcancel/rwcancel_unix.go @@ -77,7 +77,7 @@ func (rw *RWCancel) ReadyRead() bool { fdset := fdSet{} fdset.set(rw.fd) fdset.set(closeFd) - _, err := unix.Select(max(rw.fd, closeFd)+1, &fdset.fdset, nil, nil, nil) + err := unixSelect(max(rw.fd, closeFd)+1, &fdset.fdset, nil, nil, nil) if err != nil { return false } @@ -92,7 +92,7 @@ func (rw *RWCancel) ReadyWrite() bool { fdset := fdSet{} fdset.set(rw.fd) fdset.set(closeFd) - _, err := unix.Select(max(rw.fd, closeFd)+1, nil, &fdset.fdset, nil, nil) + err := unixSelect(max(rw.fd, closeFd)+1, nil, &fdset.fdset, nil, nil) if err != nil { return false } diff --git a/rwcancel/select_darwin.go b/rwcancel/select_darwin.go new file mode 100644 index 0000000..d14edc8 --- /dev/null +++ b/rwcancel/select_darwin.go @@ -0,0 +1,12 @@ +/* SPDX-License-Identifier: GPL-2.0 + * + * Copyright (C) 2017-2018 Jason A. Donenfeld . All Rights Reserved. + */ + +package rwcancel + +import "golang.org/x/sys/unix" + +func unixSelect(nfd int, r *unix.FdSet, w *unix.FdSet, e *unix.FdSet, timeout *unix.Timeval) error { + return unix.Select(nfd, r, w, e, timeout) +} diff --git a/rwcancel/select_linux.go b/rwcancel/select_linux.go new file mode 100644 index 0000000..c3d4e27 --- /dev/null +++ b/rwcancel/select_linux.go @@ -0,0 +1,13 @@ +/* SPDX-License-Identifier: GPL-2.0 + * + * Copyright (C) 2017-2018 Jason A. Donenfeld . All Rights Reserved. + */ + +package rwcancel + +import "golang.org/x/sys/unix" + +func unixSelect(nfd int, r *unix.FdSet, w *unix.FdSet, e *unix.FdSet, timeout *unix.Timeval) (err error) { + _, err = unix.Select(nfd, r, w, e, timeout) + return +} -- cgit v1.2.3-59-g8ed1b