diff options
author | Tianon Gravi <admwiggin@gmail.com> | 2015-01-15 11:54:00 -0700 |
---|---|---|
committer | Tianon Gravi <admwiggin@gmail.com> | 2015-01-15 11:54:00 -0700 |
commit | f154da9e12608589e8d5f0508f908a0c3e88a1bb (patch) | |
tree | f8255d51e10c6f1e0ed69702200b966c9556a431 /src/pkg/net/fd_poll_nacl.go | |
parent | 8d8329ed5dfb9622c82a9fbec6fd99a580f9c9f6 (diff) | |
download | golang-upstream/1.4.tar.gz |
Imported Upstream version 1.4upstream/1.4
Diffstat (limited to 'src/pkg/net/fd_poll_nacl.go')
-rw-r--r-- | src/pkg/net/fd_poll_nacl.go | 94 |
1 files changed, 0 insertions, 94 deletions
diff --git a/src/pkg/net/fd_poll_nacl.go b/src/pkg/net/fd_poll_nacl.go deleted file mode 100644 index a3701f876..000000000 --- a/src/pkg/net/fd_poll_nacl.go +++ /dev/null @@ -1,94 +0,0 @@ -// Copyright 2013 The Go Authors. All rights reserved. -// Use of this source code is governed by a BSD-style -// license that can be found in the LICENSE file. - -package net - -import ( - "syscall" - "time" -) - -type pollDesc struct { - fd *netFD - closing bool -} - -func (pd *pollDesc) Init(fd *netFD) error { pd.fd = fd; return nil } - -func (pd *pollDesc) Close() {} - -func (pd *pollDesc) Lock() {} - -func (pd *pollDesc) Unlock() {} - -func (pd *pollDesc) Wakeup() {} - -func (pd *pollDesc) Evict() bool { - pd.closing = true - if pd.fd != nil { - syscall.StopIO(pd.fd.sysfd) - } - return false -} - -func (pd *pollDesc) Prepare(mode int) error { - if pd.closing { - return errClosing - } - return nil -} - -func (pd *pollDesc) PrepareRead() error { return pd.Prepare('r') } - -func (pd *pollDesc) PrepareWrite() error { return pd.Prepare('w') } - -func (pd *pollDesc) Wait(mode int) error { - if pd.closing { - return errClosing - } - return errTimeout -} - -func (pd *pollDesc) WaitRead() error { return pd.Wait('r') } - -func (pd *pollDesc) WaitWrite() error { return pd.Wait('w') } - -func (pd *pollDesc) WaitCanceled(mode int) {} - -func (pd *pollDesc) WaitCanceledRead() {} - -func (pd *pollDesc) WaitCanceledWrite() {} - -func (fd *netFD) setDeadline(t time.Time) error { - return setDeadlineImpl(fd, t, 'r'+'w') -} - -func (fd *netFD) setReadDeadline(t time.Time) error { - return setDeadlineImpl(fd, t, 'r') -} - -func (fd *netFD) setWriteDeadline(t time.Time) error { - return setDeadlineImpl(fd, t, 'w') -} - -func setDeadlineImpl(fd *netFD, t time.Time, mode int) error { - d := t.UnixNano() - if t.IsZero() { - d = 0 - } - if err := fd.incref(); err != nil { - return err - } - switch mode { - case 'r': - syscall.SetReadDeadline(fd.sysfd, d) - case 'w': - syscall.SetWriteDeadline(fd.sysfd, d) - case 'r' + 'w': - syscall.SetReadDeadline(fd.sysfd, d) - syscall.SetWriteDeadline(fd.sysfd, d) - } - fd.decref() - return nil -} |