libgo/go/net/sock_posix.go

   1 // Copyright 2009 The Go Authors.  All rights reserved.
   2 // Use of this source code is governed by a BSD-style
   3 // license that can be found in the LICENSE file.
   4
   5 // +build darwin freebsd linux netbsd openbsd windows
   6
   7 // Sockets
   8
   9 package net
  10
  11 import (
  12         "syscall"
  13         "time"
  14 )
  15
  16 var listenerBacklog = maxListenerBacklog()
  17
  18 // Generic socket creation.
  19 func socket(net string, f, t, p int, ipv6only bool, ulsa, ursa syscall.Sockaddr, deadline time.Time, toAddr func(syscall.Sockaddr) Addr) (fd *netFD, err error) {
  20         s, err := sysSocket(f, t, p)
  21         if err != nil {
  22                 return nil, err
  23         }
  24
  25         if err = setDefaultSockopts(s, f, t, ipv6only); err != nil {
  26                 closesocket(s)
  27                 return nil, err
  28         }
  29
  30         if ulsa != nil {
  31                 // We provide a socket that listens to a wildcard
  32                 // address with reusable UDP port when the given ulsa
  33                 // is an appropriate UDP multicast address prefix.
  34                 // This makes it possible for a single UDP listener
  35                 // to join multiple different group addresses, for
  36                 // multiple UDP listeners that listen on the same UDP
  37                 // port to join the same group address.
  38                 if ulsa, err = listenerSockaddr(s, f, ulsa, toAddr); err != nil {
  39                         closesocket(s)
  40                         return nil, err
  41                 }
  42                 if err = syscall.Bind(s, ulsa); err != nil {
  43                         closesocket(s)
  44                         return nil, err
  45                 }
  46         }
  47
  48         if fd, err = newFD(s, f, t, net); err != nil {
  49                 closesocket(s)
  50                 return nil, err
  51         }
  52
  53         if ursa != nil {
  54                 fd.wdeadline.setTime(deadline)
  55                 if err = fd.connect(ursa); err != nil {
  56                         closesocket(s)
  57                         return nil, err
  58                 }
  59                 fd.isConnected = true
  60                 fd.wdeadline.set(0)
  61         }
  62
  63         lsa, _ := syscall.Getsockname(s)
  64         laddr := toAddr(lsa)
  65         rsa, _ := syscall.Getpeername(s)
  66         raddr := toAddr(rsa)
  67         fd.setAddr(laddr, raddr)
  68         return fd, nil
  69 }