Subversion Repositories openrisc

// Copyright 2010 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 (
        "os"
        "syscall"
)

func selfConnectedTCPSocket() (pr, pw *os.File, err error) {
        // See ../syscall/exec.go for description of ForkLock.
        syscall.ForkLock.RLock()
        sockfd, e := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, 0)
        if e != 0 {
                syscall.ForkLock.RUnlock()
                return nil, nil, os.Errno(e)
        }
        syscall.CloseOnExec(sockfd)
        syscall.ForkLock.RUnlock()

        // Allow reuse of recently-used addresses.
        syscall.SetsockoptInt(sockfd, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)

        var laTCP *TCPAddr
        var la syscall.Sockaddr
        if laTCP, err = ResolveTCPAddr("127.0.0.1:0"); err != nil {
        Error:
                return nil, nil, err
        }
        if la, err = laTCP.sockaddr(syscall.AF_INET); err != nil {
                goto Error
        }
        e = syscall.Bind(sockfd, la)
        if e != 0 {
        Errno:
                syscall.Close(sockfd)
                return nil, nil, os.Errno(e)
        }

        laddr, _ := syscall.Getsockname(sockfd)
        e = syscall.Connect(sockfd, laddr)
        if e != 0 {
                goto Errno
        }

        fd := os.NewFile(sockfd, "wakeupSocket")
        return fd, fd, nil
}

func newPollServer() (s *pollServer, err error) {
        s = new(pollServer)
        s.cr = make(chan *netFD, 1)
        s.cw = make(chan *netFD, 1)
        // s.pr and s.pw are indistinguishable.
        if s.pr, s.pw, err = selfConnectedTCPSocket(); err != nil {
                return nil, err
        }
        var e int
        if e = syscall.SetNonblock(s.pr.Fd(), true); e != 0 {
        Errno:
                err = &os.PathError{"setnonblock", s.pr.Name(), os.Errno(e)}
        Error:
                s.pr.Close()
                return nil, err
        }
        if s.poll, err = newpollster(); err != nil {
                goto Error
        }
        if _, err = s.poll.AddFD(s.pr.Fd(), 'r', true); err != nil {
                s.poll.Close()
                goto Error
        }
        s.pending = make(map[int]*netFD)
        go s.Run()
        return s, nil
}