syscall_darwin.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854
  1. // Copyright 2009,2010 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. // Darwin system calls.
  5. // This file is compiled as ordinary Go code,
  6. // but it is also input to mksyscall,
  7. // which parses the //sys lines and generates system call stubs.
  8. // Note that sometimes we use a lowercase //sys name and wrap
  9. // it in our own nicer implementation, either here or in
  10. // syscall_bsd.go or syscall_unix.go.
  11. package unix
  12. import (
  13. "fmt"
  14. "syscall"
  15. "unsafe"
  16. )
  17. //sys closedir(dir uintptr) (err error)
  18. //sys readdir_r(dir uintptr, entry *Dirent, result **Dirent) (res Errno)
  19. func fdopendir(fd int) (dir uintptr, err error) {
  20. r0, _, e1 := syscall_syscallPtr(libc_fdopendir_trampoline_addr, uintptr(fd), 0, 0)
  21. dir = uintptr(r0)
  22. if e1 != 0 {
  23. err = errnoErr(e1)
  24. }
  25. return
  26. }
  27. var libc_fdopendir_trampoline_addr uintptr
  28. //go:cgo_import_dynamic libc_fdopendir fdopendir "/usr/lib/libSystem.B.dylib"
  29. func Getdirentries(fd int, buf []byte, basep *uintptr) (n int, err error) {
  30. // Simulate Getdirentries using fdopendir/readdir_r/closedir.
  31. // We store the number of entries to skip in the seek
  32. // offset of fd. See issue #31368.
  33. // It's not the full required semantics, but should handle the case
  34. // of calling Getdirentries or ReadDirent repeatedly.
  35. // It won't handle assigning the results of lseek to *basep, or handle
  36. // the directory being edited underfoot.
  37. skip, err := Seek(fd, 0, 1 /* SEEK_CUR */)
  38. if err != nil {
  39. return 0, err
  40. }
  41. // We need to duplicate the incoming file descriptor
  42. // because the caller expects to retain control of it, but
  43. // fdopendir expects to take control of its argument.
  44. // Just Dup'ing the file descriptor is not enough, as the
  45. // result shares underlying state. Use Openat to make a really
  46. // new file descriptor referring to the same directory.
  47. fd2, err := Openat(fd, ".", O_RDONLY, 0)
  48. if err != nil {
  49. return 0, err
  50. }
  51. d, err := fdopendir(fd2)
  52. if err != nil {
  53. Close(fd2)
  54. return 0, err
  55. }
  56. defer closedir(d)
  57. var cnt int64
  58. for {
  59. var entry Dirent
  60. var entryp *Dirent
  61. e := readdir_r(d, &entry, &entryp)
  62. if e != 0 {
  63. return n, errnoErr(e)
  64. }
  65. if entryp == nil {
  66. break
  67. }
  68. if skip > 0 {
  69. skip--
  70. cnt++
  71. continue
  72. }
  73. reclen := int(entry.Reclen)
  74. if reclen > len(buf) {
  75. // Not enough room. Return for now.
  76. // The counter will let us know where we should start up again.
  77. // Note: this strategy for suspending in the middle and
  78. // restarting is O(n^2) in the length of the directory. Oh well.
  79. break
  80. }
  81. // Copy entry into return buffer.
  82. s := unsafe.Slice((*byte)(unsafe.Pointer(&entry)), reclen)
  83. copy(buf, s)
  84. buf = buf[reclen:]
  85. n += reclen
  86. cnt++
  87. }
  88. // Set the seek offset of the input fd to record
  89. // how many files we've already returned.
  90. _, err = Seek(fd, cnt, 0 /* SEEK_SET */)
  91. if err != nil {
  92. return n, err
  93. }
  94. return n, nil
  95. }
  96. // SockaddrDatalink implements the Sockaddr interface for AF_LINK type sockets.
  97. type SockaddrDatalink struct {
  98. Len uint8
  99. Family uint8
  100. Index uint16
  101. Type uint8
  102. Nlen uint8
  103. Alen uint8
  104. Slen uint8
  105. Data [12]int8
  106. raw RawSockaddrDatalink
  107. }
  108. // SockaddrCtl implements the Sockaddr interface for AF_SYSTEM type sockets.
  109. type SockaddrCtl struct {
  110. ID uint32
  111. Unit uint32
  112. raw RawSockaddrCtl
  113. }
  114. func (sa *SockaddrCtl) sockaddr() (unsafe.Pointer, _Socklen, error) {
  115. sa.raw.Sc_len = SizeofSockaddrCtl
  116. sa.raw.Sc_family = AF_SYSTEM
  117. sa.raw.Ss_sysaddr = AF_SYS_CONTROL
  118. sa.raw.Sc_id = sa.ID
  119. sa.raw.Sc_unit = sa.Unit
  120. return unsafe.Pointer(&sa.raw), SizeofSockaddrCtl, nil
  121. }
  122. // SockaddrVM implements the Sockaddr interface for AF_VSOCK type sockets.
  123. // SockaddrVM provides access to Darwin VM sockets: a mechanism that enables
  124. // bidirectional communication between a hypervisor and its guest virtual
  125. // machines.
  126. type SockaddrVM struct {
  127. // CID and Port specify a context ID and port address for a VM socket.
  128. // Guests have a unique CID, and hosts may have a well-known CID of:
  129. // - VMADDR_CID_HYPERVISOR: refers to the hypervisor process.
  130. // - VMADDR_CID_LOCAL: refers to local communication (loopback).
  131. // - VMADDR_CID_HOST: refers to other processes on the host.
  132. CID uint32
  133. Port uint32
  134. raw RawSockaddrVM
  135. }
  136. func (sa *SockaddrVM) sockaddr() (unsafe.Pointer, _Socklen, error) {
  137. sa.raw.Len = SizeofSockaddrVM
  138. sa.raw.Family = AF_VSOCK
  139. sa.raw.Port = sa.Port
  140. sa.raw.Cid = sa.CID
  141. return unsafe.Pointer(&sa.raw), SizeofSockaddrVM, nil
  142. }
  143. func anyToSockaddrGOOS(fd int, rsa *RawSockaddrAny) (Sockaddr, error) {
  144. switch rsa.Addr.Family {
  145. case AF_SYSTEM:
  146. pp := (*RawSockaddrCtl)(unsafe.Pointer(rsa))
  147. if pp.Ss_sysaddr == AF_SYS_CONTROL {
  148. sa := new(SockaddrCtl)
  149. sa.ID = pp.Sc_id
  150. sa.Unit = pp.Sc_unit
  151. return sa, nil
  152. }
  153. case AF_VSOCK:
  154. pp := (*RawSockaddrVM)(unsafe.Pointer(rsa))
  155. sa := &SockaddrVM{
  156. CID: pp.Cid,
  157. Port: pp.Port,
  158. }
  159. return sa, nil
  160. }
  161. return nil, EAFNOSUPPORT
  162. }
  163. // Some external packages rely on SYS___SYSCTL being defined to implement their
  164. // own sysctl wrappers. Provide it here, even though direct syscalls are no
  165. // longer supported on darwin.
  166. const SYS___SYSCTL = SYS_SYSCTL
  167. // Translate "kern.hostname" to []_C_int{0,1,2,3}.
  168. func nametomib(name string) (mib []_C_int, err error) {
  169. const siz = unsafe.Sizeof(mib[0])
  170. // NOTE(rsc): It seems strange to set the buffer to have
  171. // size CTL_MAXNAME+2 but use only CTL_MAXNAME
  172. // as the size. I don't know why the +2 is here, but the
  173. // kernel uses +2 for its own implementation of this function.
  174. // I am scared that if we don't include the +2 here, the kernel
  175. // will silently write 2 words farther than we specify
  176. // and we'll get memory corruption.
  177. var buf [CTL_MAXNAME + 2]_C_int
  178. n := uintptr(CTL_MAXNAME) * siz
  179. p := (*byte)(unsafe.Pointer(&buf[0]))
  180. bytes, err := ByteSliceFromString(name)
  181. if err != nil {
  182. return nil, err
  183. }
  184. // Magic sysctl: "setting" 0.3 to a string name
  185. // lets you read back the array of integers form.
  186. if err = sysctl([]_C_int{0, 3}, p, &n, &bytes[0], uintptr(len(name))); err != nil {
  187. return nil, err
  188. }
  189. return buf[0 : n/siz], nil
  190. }
  191. func direntIno(buf []byte) (uint64, bool) {
  192. return readInt(buf, unsafe.Offsetof(Dirent{}.Ino), unsafe.Sizeof(Dirent{}.Ino))
  193. }
  194. func direntReclen(buf []byte) (uint64, bool) {
  195. return readInt(buf, unsafe.Offsetof(Dirent{}.Reclen), unsafe.Sizeof(Dirent{}.Reclen))
  196. }
  197. func direntNamlen(buf []byte) (uint64, bool) {
  198. return readInt(buf, unsafe.Offsetof(Dirent{}.Namlen), unsafe.Sizeof(Dirent{}.Namlen))
  199. }
  200. func PtraceAttach(pid int) (err error) { return ptrace(PT_ATTACH, pid, 0, 0) }
  201. func PtraceDetach(pid int) (err error) { return ptrace(PT_DETACH, pid, 0, 0) }
  202. func PtraceDenyAttach() (err error) { return ptrace(PT_DENY_ATTACH, 0, 0, 0) }
  203. //sysnb pipe(p *[2]int32) (err error)
  204. func Pipe(p []int) (err error) {
  205. if len(p) != 2 {
  206. return EINVAL
  207. }
  208. var x [2]int32
  209. err = pipe(&x)
  210. if err == nil {
  211. p[0] = int(x[0])
  212. p[1] = int(x[1])
  213. }
  214. return
  215. }
  216. func Getfsstat(buf []Statfs_t, flags int) (n int, err error) {
  217. var _p0 unsafe.Pointer
  218. var bufsize uintptr
  219. if len(buf) > 0 {
  220. _p0 = unsafe.Pointer(&buf[0])
  221. bufsize = unsafe.Sizeof(Statfs_t{}) * uintptr(len(buf))
  222. }
  223. return getfsstat(_p0, bufsize, flags)
  224. }
  225. func xattrPointer(dest []byte) *byte {
  226. // It's only when dest is set to NULL that the OS X implementations of
  227. // getxattr() and listxattr() return the current sizes of the named attributes.
  228. // An empty byte array is not sufficient. To maintain the same behaviour as the
  229. // linux implementation, we wrap around the system calls and pass in NULL when
  230. // dest is empty.
  231. var destp *byte
  232. if len(dest) > 0 {
  233. destp = &dest[0]
  234. }
  235. return destp
  236. }
  237. //sys getxattr(path string, attr string, dest *byte, size int, position uint32, options int) (sz int, err error)
  238. func Getxattr(path string, attr string, dest []byte) (sz int, err error) {
  239. return getxattr(path, attr, xattrPointer(dest), len(dest), 0, 0)
  240. }
  241. func Lgetxattr(link string, attr string, dest []byte) (sz int, err error) {
  242. return getxattr(link, attr, xattrPointer(dest), len(dest), 0, XATTR_NOFOLLOW)
  243. }
  244. //sys fgetxattr(fd int, attr string, dest *byte, size int, position uint32, options int) (sz int, err error)
  245. func Fgetxattr(fd int, attr string, dest []byte) (sz int, err error) {
  246. return fgetxattr(fd, attr, xattrPointer(dest), len(dest), 0, 0)
  247. }
  248. //sys setxattr(path string, attr string, data *byte, size int, position uint32, options int) (err error)
  249. func Setxattr(path string, attr string, data []byte, flags int) (err error) {
  250. // The parameters for the OS X implementation vary slightly compared to the
  251. // linux system call, specifically the position parameter:
  252. //
  253. // linux:
  254. // int setxattr(
  255. // const char *path,
  256. // const char *name,
  257. // const void *value,
  258. // size_t size,
  259. // int flags
  260. // );
  261. //
  262. // darwin:
  263. // int setxattr(
  264. // const char *path,
  265. // const char *name,
  266. // void *value,
  267. // size_t size,
  268. // u_int32_t position,
  269. // int options
  270. // );
  271. //
  272. // position specifies the offset within the extended attribute. In the
  273. // current implementation, only the resource fork extended attribute makes
  274. // use of this argument. For all others, position is reserved. We simply
  275. // default to setting it to zero.
  276. return setxattr(path, attr, xattrPointer(data), len(data), 0, flags)
  277. }
  278. func Lsetxattr(link string, attr string, data []byte, flags int) (err error) {
  279. return setxattr(link, attr, xattrPointer(data), len(data), 0, flags|XATTR_NOFOLLOW)
  280. }
  281. //sys fsetxattr(fd int, attr string, data *byte, size int, position uint32, options int) (err error)
  282. func Fsetxattr(fd int, attr string, data []byte, flags int) (err error) {
  283. return fsetxattr(fd, attr, xattrPointer(data), len(data), 0, 0)
  284. }
  285. //sys removexattr(path string, attr string, options int) (err error)
  286. func Removexattr(path string, attr string) (err error) {
  287. // We wrap around and explicitly zero out the options provided to the OS X
  288. // implementation of removexattr, we do so for interoperability with the
  289. // linux variant.
  290. return removexattr(path, attr, 0)
  291. }
  292. func Lremovexattr(link string, attr string) (err error) {
  293. return removexattr(link, attr, XATTR_NOFOLLOW)
  294. }
  295. //sys fremovexattr(fd int, attr string, options int) (err error)
  296. func Fremovexattr(fd int, attr string) (err error) {
  297. return fremovexattr(fd, attr, 0)
  298. }
  299. //sys listxattr(path string, dest *byte, size int, options int) (sz int, err error)
  300. func Listxattr(path string, dest []byte) (sz int, err error) {
  301. return listxattr(path, xattrPointer(dest), len(dest), 0)
  302. }
  303. func Llistxattr(link string, dest []byte) (sz int, err error) {
  304. return listxattr(link, xattrPointer(dest), len(dest), XATTR_NOFOLLOW)
  305. }
  306. //sys flistxattr(fd int, dest *byte, size int, options int) (sz int, err error)
  307. func Flistxattr(fd int, dest []byte) (sz int, err error) {
  308. return flistxattr(fd, xattrPointer(dest), len(dest), 0)
  309. }
  310. //sys utimensat(dirfd int, path string, times *[2]Timespec, flags int) (err error)
  311. /*
  312. * Wrapped
  313. */
  314. //sys fcntl(fd int, cmd int, arg int) (val int, err error)
  315. //sys kill(pid int, signum int, posix int) (err error)
  316. func Kill(pid int, signum syscall.Signal) (err error) { return kill(pid, int(signum), 1) }
  317. //sys ioctl(fd int, req uint, arg uintptr) (err error)
  318. //sys ioctlPtr(fd int, req uint, arg unsafe.Pointer) (err error) = SYS_IOCTL
  319. func IoctlCtlInfo(fd int, ctlInfo *CtlInfo) error {
  320. return ioctlPtr(fd, CTLIOCGINFO, unsafe.Pointer(ctlInfo))
  321. }
  322. // IfreqMTU is struct ifreq used to get or set a network device's MTU.
  323. type IfreqMTU struct {
  324. Name [IFNAMSIZ]byte
  325. MTU int32
  326. }
  327. // IoctlGetIfreqMTU performs the SIOCGIFMTU ioctl operation on fd to get the MTU
  328. // of the network device specified by ifname.
  329. func IoctlGetIfreqMTU(fd int, ifname string) (*IfreqMTU, error) {
  330. var ifreq IfreqMTU
  331. copy(ifreq.Name[:], ifname)
  332. err := ioctlPtr(fd, SIOCGIFMTU, unsafe.Pointer(&ifreq))
  333. return &ifreq, err
  334. }
  335. // IoctlSetIfreqMTU performs the SIOCSIFMTU ioctl operation on fd to set the MTU
  336. // of the network device specified by ifreq.Name.
  337. func IoctlSetIfreqMTU(fd int, ifreq *IfreqMTU) error {
  338. return ioctlPtr(fd, SIOCSIFMTU, unsafe.Pointer(ifreq))
  339. }
  340. //sys renamexNp(from string, to string, flag uint32) (err error)
  341. func RenamexNp(from string, to string, flag uint32) (err error) {
  342. return renamexNp(from, to, flag)
  343. }
  344. //sys renameatxNp(fromfd int, from string, tofd int, to string, flag uint32) (err error)
  345. func RenameatxNp(fromfd int, from string, tofd int, to string, flag uint32) (err error) {
  346. return renameatxNp(fromfd, from, tofd, to, flag)
  347. }
  348. //sys sysctl(mib []_C_int, old *byte, oldlen *uintptr, new *byte, newlen uintptr) (err error) = SYS_SYSCTL
  349. func Uname(uname *Utsname) error {
  350. mib := []_C_int{CTL_KERN, KERN_OSTYPE}
  351. n := unsafe.Sizeof(uname.Sysname)
  352. if err := sysctl(mib, &uname.Sysname[0], &n, nil, 0); err != nil {
  353. return err
  354. }
  355. mib = []_C_int{CTL_KERN, KERN_HOSTNAME}
  356. n = unsafe.Sizeof(uname.Nodename)
  357. if err := sysctl(mib, &uname.Nodename[0], &n, nil, 0); err != nil {
  358. return err
  359. }
  360. mib = []_C_int{CTL_KERN, KERN_OSRELEASE}
  361. n = unsafe.Sizeof(uname.Release)
  362. if err := sysctl(mib, &uname.Release[0], &n, nil, 0); err != nil {
  363. return err
  364. }
  365. mib = []_C_int{CTL_KERN, KERN_VERSION}
  366. n = unsafe.Sizeof(uname.Version)
  367. if err := sysctl(mib, &uname.Version[0], &n, nil, 0); err != nil {
  368. return err
  369. }
  370. // The version might have newlines or tabs in it, convert them to
  371. // spaces.
  372. for i, b := range uname.Version {
  373. if b == '\n' || b == '\t' {
  374. if i == len(uname.Version)-1 {
  375. uname.Version[i] = 0
  376. } else {
  377. uname.Version[i] = ' '
  378. }
  379. }
  380. }
  381. mib = []_C_int{CTL_HW, HW_MACHINE}
  382. n = unsafe.Sizeof(uname.Machine)
  383. if err := sysctl(mib, &uname.Machine[0], &n, nil, 0); err != nil {
  384. return err
  385. }
  386. return nil
  387. }
  388. func Sendfile(outfd int, infd int, offset *int64, count int) (written int, err error) {
  389. if raceenabled {
  390. raceReleaseMerge(unsafe.Pointer(&ioSync))
  391. }
  392. var length = int64(count)
  393. err = sendfile(infd, outfd, *offset, &length, nil, 0)
  394. written = int(length)
  395. return
  396. }
  397. func GetsockoptIPMreqn(fd, level, opt int) (*IPMreqn, error) {
  398. var value IPMreqn
  399. vallen := _Socklen(SizeofIPMreqn)
  400. errno := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
  401. return &value, errno
  402. }
  403. func SetsockoptIPMreqn(fd, level, opt int, mreq *IPMreqn) (err error) {
  404. return setsockopt(fd, level, opt, unsafe.Pointer(mreq), unsafe.Sizeof(*mreq))
  405. }
  406. // GetsockoptXucred is a getsockopt wrapper that returns an Xucred struct.
  407. // The usual level and opt are SOL_LOCAL and LOCAL_PEERCRED, respectively.
  408. func GetsockoptXucred(fd, level, opt int) (*Xucred, error) {
  409. x := new(Xucred)
  410. vallen := _Socklen(SizeofXucred)
  411. err := getsockopt(fd, level, opt, unsafe.Pointer(x), &vallen)
  412. return x, err
  413. }
  414. func GetsockoptTCPConnectionInfo(fd, level, opt int) (*TCPConnectionInfo, error) {
  415. var value TCPConnectionInfo
  416. vallen := _Socklen(SizeofTCPConnectionInfo)
  417. err := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
  418. return &value, err
  419. }
  420. func SysctlKinfoProc(name string, args ...int) (*KinfoProc, error) {
  421. mib, err := sysctlmib(name, args...)
  422. if err != nil {
  423. return nil, err
  424. }
  425. var kinfo KinfoProc
  426. n := uintptr(SizeofKinfoProc)
  427. if err := sysctl(mib, (*byte)(unsafe.Pointer(&kinfo)), &n, nil, 0); err != nil {
  428. return nil, err
  429. }
  430. if n != SizeofKinfoProc {
  431. return nil, EIO
  432. }
  433. return &kinfo, nil
  434. }
  435. func SysctlKinfoProcSlice(name string, args ...int) ([]KinfoProc, error) {
  436. mib, err := sysctlmib(name, args...)
  437. if err != nil {
  438. return nil, err
  439. }
  440. for {
  441. // Find size.
  442. n := uintptr(0)
  443. if err := sysctl(mib, nil, &n, nil, 0); err != nil {
  444. return nil, err
  445. }
  446. if n == 0 {
  447. return nil, nil
  448. }
  449. if n%SizeofKinfoProc != 0 {
  450. return nil, fmt.Errorf("sysctl() returned a size of %d, which is not a multiple of %d", n, SizeofKinfoProc)
  451. }
  452. // Read into buffer of that size.
  453. buf := make([]KinfoProc, n/SizeofKinfoProc)
  454. if err := sysctl(mib, (*byte)(unsafe.Pointer(&buf[0])), &n, nil, 0); err != nil {
  455. if err == ENOMEM {
  456. // Process table grew. Try again.
  457. continue
  458. }
  459. return nil, err
  460. }
  461. if n%SizeofKinfoProc != 0 {
  462. return nil, fmt.Errorf("sysctl() returned a size of %d, which is not a multiple of %d", n, SizeofKinfoProc)
  463. }
  464. // The actual call may return less than the original reported required
  465. // size so ensure we deal with that.
  466. return buf[:n/SizeofKinfoProc], nil
  467. }
  468. }
  469. //sys pthread_chdir_np(path string) (err error)
  470. func PthreadChdir(path string) (err error) {
  471. return pthread_chdir_np(path)
  472. }
  473. //sys pthread_fchdir_np(fd int) (err error)
  474. func PthreadFchdir(fd int) (err error) {
  475. return pthread_fchdir_np(fd)
  476. }
  477. // Connectx calls connectx(2) to initiate a connection on a socket.
  478. //
  479. // srcIf, srcAddr, and dstAddr are filled into a [SaEndpoints] struct and passed as the endpoints argument.
  480. //
  481. // - srcIf is the optional source interface index. 0 means unspecified.
  482. // - srcAddr is the optional source address. nil means unspecified.
  483. // - dstAddr is the destination address.
  484. //
  485. // On success, Connectx returns the number of bytes enqueued for transmission.
  486. func Connectx(fd int, srcIf uint32, srcAddr, dstAddr Sockaddr, associd SaeAssocID, flags uint32, iov []Iovec, connid *SaeConnID) (n uintptr, err error) {
  487. endpoints := SaEndpoints{
  488. Srcif: srcIf,
  489. }
  490. if srcAddr != nil {
  491. addrp, addrlen, err := srcAddr.sockaddr()
  492. if err != nil {
  493. return 0, err
  494. }
  495. endpoints.Srcaddr = (*RawSockaddr)(addrp)
  496. endpoints.Srcaddrlen = uint32(addrlen)
  497. }
  498. if dstAddr != nil {
  499. addrp, addrlen, err := dstAddr.sockaddr()
  500. if err != nil {
  501. return 0, err
  502. }
  503. endpoints.Dstaddr = (*RawSockaddr)(addrp)
  504. endpoints.Dstaddrlen = uint32(addrlen)
  505. }
  506. err = connectx(fd, &endpoints, associd, flags, iov, &n, connid)
  507. return
  508. }
  509. // sys connectx(fd int, endpoints *SaEndpoints, associd SaeAssocID, flags uint32, iov []Iovec, n *uintptr, connid *SaeConnID) (err error)
  510. const minIovec = 8
  511. func Readv(fd int, iovs [][]byte) (n int, err error) {
  512. if !darwinKernelVersionMin(11, 0, 0) {
  513. return 0, ENOSYS
  514. }
  515. iovecs := make([]Iovec, 0, minIovec)
  516. iovecs = appendBytes(iovecs, iovs)
  517. n, err = readv(fd, iovecs)
  518. readvRacedetect(iovecs, n, err)
  519. return n, err
  520. }
  521. func Preadv(fd int, iovs [][]byte, offset int64) (n int, err error) {
  522. if !darwinKernelVersionMin(11, 0, 0) {
  523. return 0, ENOSYS
  524. }
  525. iovecs := make([]Iovec, 0, minIovec)
  526. iovecs = appendBytes(iovecs, iovs)
  527. n, err = preadv(fd, iovecs, offset)
  528. readvRacedetect(iovecs, n, err)
  529. return n, err
  530. }
  531. func Writev(fd int, iovs [][]byte) (n int, err error) {
  532. if !darwinKernelVersionMin(11, 0, 0) {
  533. return 0, ENOSYS
  534. }
  535. iovecs := make([]Iovec, 0, minIovec)
  536. iovecs = appendBytes(iovecs, iovs)
  537. if raceenabled {
  538. raceReleaseMerge(unsafe.Pointer(&ioSync))
  539. }
  540. n, err = writev(fd, iovecs)
  541. writevRacedetect(iovecs, n)
  542. return n, err
  543. }
  544. func Pwritev(fd int, iovs [][]byte, offset int64) (n int, err error) {
  545. if !darwinKernelVersionMin(11, 0, 0) {
  546. return 0, ENOSYS
  547. }
  548. iovecs := make([]Iovec, 0, minIovec)
  549. iovecs = appendBytes(iovecs, iovs)
  550. if raceenabled {
  551. raceReleaseMerge(unsafe.Pointer(&ioSync))
  552. }
  553. n, err = pwritev(fd, iovecs, offset)
  554. writevRacedetect(iovecs, n)
  555. return n, err
  556. }
  557. func appendBytes(vecs []Iovec, bs [][]byte) []Iovec {
  558. for _, b := range bs {
  559. var v Iovec
  560. v.SetLen(len(b))
  561. if len(b) > 0 {
  562. v.Base = &b[0]
  563. } else {
  564. v.Base = (*byte)(unsafe.Pointer(&_zero))
  565. }
  566. vecs = append(vecs, v)
  567. }
  568. return vecs
  569. }
  570. func writevRacedetect(iovecs []Iovec, n int) {
  571. if !raceenabled {
  572. return
  573. }
  574. for i := 0; n > 0 && i < len(iovecs); i++ {
  575. m := int(iovecs[i].Len)
  576. if m > n {
  577. m = n
  578. }
  579. n -= m
  580. if m > 0 {
  581. raceReadRange(unsafe.Pointer(iovecs[i].Base), m)
  582. }
  583. }
  584. }
  585. func readvRacedetect(iovecs []Iovec, n int, err error) {
  586. if !raceenabled {
  587. return
  588. }
  589. for i := 0; n > 0 && i < len(iovecs); i++ {
  590. m := int(iovecs[i].Len)
  591. if m > n {
  592. m = n
  593. }
  594. n -= m
  595. if m > 0 {
  596. raceWriteRange(unsafe.Pointer(iovecs[i].Base), m)
  597. }
  598. }
  599. if err == nil {
  600. raceAcquire(unsafe.Pointer(&ioSync))
  601. }
  602. }
  603. func darwinMajorMinPatch() (maj, min, patch int, err error) {
  604. var un Utsname
  605. err = Uname(&un)
  606. if err != nil {
  607. return
  608. }
  609. var mmp [3]int
  610. c := 0
  611. Loop:
  612. for _, b := range un.Release[:] {
  613. switch {
  614. case b >= '0' && b <= '9':
  615. mmp[c] = 10*mmp[c] + int(b-'0')
  616. case b == '.':
  617. c++
  618. if c > 2 {
  619. return 0, 0, 0, ENOTSUP
  620. }
  621. case b == 0:
  622. break Loop
  623. default:
  624. return 0, 0, 0, ENOTSUP
  625. }
  626. }
  627. if c != 2 {
  628. return 0, 0, 0, ENOTSUP
  629. }
  630. return mmp[0], mmp[1], mmp[2], nil
  631. }
  632. func darwinKernelVersionMin(maj, min, patch int) bool {
  633. actualMaj, actualMin, actualPatch, err := darwinMajorMinPatch()
  634. if err != nil {
  635. return false
  636. }
  637. return actualMaj > maj || actualMaj == maj && (actualMin > min || actualMin == min && actualPatch >= patch)
  638. }
  639. //sys sendfile(infd int, outfd int, offset int64, len *int64, hdtr unsafe.Pointer, flags int) (err error)
  640. //sys shmat(id int, addr uintptr, flag int) (ret uintptr, err error)
  641. //sys shmctl(id int, cmd int, buf *SysvShmDesc) (result int, err error)
  642. //sys shmdt(addr uintptr) (err error)
  643. //sys shmget(key int, size int, flag int) (id int, err error)
  644. /*
  645. * Exposed directly
  646. */
  647. //sys Access(path string, mode uint32) (err error)
  648. //sys Adjtime(delta *Timeval, olddelta *Timeval) (err error)
  649. //sys Chdir(path string) (err error)
  650. //sys Chflags(path string, flags int) (err error)
  651. //sys Chmod(path string, mode uint32) (err error)
  652. //sys Chown(path string, uid int, gid int) (err error)
  653. //sys Chroot(path string) (err error)
  654. //sys ClockGettime(clockid int32, time *Timespec) (err error)
  655. //sys Close(fd int) (err error)
  656. //sys Clonefile(src string, dst string, flags int) (err error)
  657. //sys Clonefileat(srcDirfd int, src string, dstDirfd int, dst string, flags int) (err error)
  658. //sys Dup(fd int) (nfd int, err error)
  659. //sys Dup2(from int, to int) (err error)
  660. //sys Exchangedata(path1 string, path2 string, options int) (err error)
  661. //sys Exit(code int)
  662. //sys Faccessat(dirfd int, path string, mode uint32, flags int) (err error)
  663. //sys Fchdir(fd int) (err error)
  664. //sys Fchflags(fd int, flags int) (err error)
  665. //sys Fchmod(fd int, mode uint32) (err error)
  666. //sys Fchmodat(dirfd int, path string, mode uint32, flags int) (err error)
  667. //sys Fchown(fd int, uid int, gid int) (err error)
  668. //sys Fchownat(dirfd int, path string, uid int, gid int, flags int) (err error)
  669. //sys Fclonefileat(srcDirfd int, dstDirfd int, dst string, flags int) (err error)
  670. //sys Flock(fd int, how int) (err error)
  671. //sys Fpathconf(fd int, name int) (val int, err error)
  672. //sys Fsync(fd int) (err error)
  673. //sys Ftruncate(fd int, length int64) (err error)
  674. //sys Getcwd(buf []byte) (n int, err error)
  675. //sys Getdtablesize() (size int)
  676. //sysnb Getegid() (egid int)
  677. //sysnb Geteuid() (uid int)
  678. //sysnb Getgid() (gid int)
  679. //sysnb Getpgid(pid int) (pgid int, err error)
  680. //sysnb Getpgrp() (pgrp int)
  681. //sysnb Getpid() (pid int)
  682. //sysnb Getppid() (ppid int)
  683. //sys Getpriority(which int, who int) (prio int, err error)
  684. //sysnb Getrlimit(which int, lim *Rlimit) (err error)
  685. //sysnb Getrusage(who int, rusage *Rusage) (err error)
  686. //sysnb Getsid(pid int) (sid int, err error)
  687. //sysnb Gettimeofday(tp *Timeval) (err error)
  688. //sysnb Getuid() (uid int)
  689. //sysnb Issetugid() (tainted bool)
  690. //sys Kqueue() (fd int, err error)
  691. //sys Lchown(path string, uid int, gid int) (err error)
  692. //sys Link(path string, link string) (err error)
  693. //sys Linkat(pathfd int, path string, linkfd int, link string, flags int) (err error)
  694. //sys Listen(s int, backlog int) (err error)
  695. //sys Mkdir(path string, mode uint32) (err error)
  696. //sys Mkdirat(dirfd int, path string, mode uint32) (err error)
  697. //sys Mkfifo(path string, mode uint32) (err error)
  698. //sys Mknod(path string, mode uint32, dev int) (err error)
  699. //sys Mount(fsType string, dir string, flags int, data unsafe.Pointer) (err error)
  700. //sys Open(path string, mode int, perm uint32) (fd int, err error)
  701. //sys Openat(dirfd int, path string, mode int, perm uint32) (fd int, err error)
  702. //sys Pathconf(path string, name int) (val int, err error)
  703. //sys pread(fd int, p []byte, offset int64) (n int, err error)
  704. //sys pwrite(fd int, p []byte, offset int64) (n int, err error)
  705. //sys read(fd int, p []byte) (n int, err error)
  706. //sys Readlink(path string, buf []byte) (n int, err error)
  707. //sys Readlinkat(dirfd int, path string, buf []byte) (n int, err error)
  708. //sys Rename(from string, to string) (err error)
  709. //sys Renameat(fromfd int, from string, tofd int, to string) (err error)
  710. //sys Revoke(path string) (err error)
  711. //sys Rmdir(path string) (err error)
  712. //sys Seek(fd int, offset int64, whence int) (newoffset int64, err error) = SYS_LSEEK
  713. //sys Select(nfd int, r *FdSet, w *FdSet, e *FdSet, timeout *Timeval) (n int, err error)
  714. //sys Setattrlist(path string, attrlist *Attrlist, attrBuf []byte, options int) (err error)
  715. //sys Setegid(egid int) (err error)
  716. //sysnb Seteuid(euid int) (err error)
  717. //sysnb Setgid(gid int) (err error)
  718. //sys Setlogin(name string) (err error)
  719. //sysnb Setpgid(pid int, pgid int) (err error)
  720. //sys Setpriority(which int, who int, prio int) (err error)
  721. //sys Setprivexec(flag int) (err error)
  722. //sysnb Setregid(rgid int, egid int) (err error)
  723. //sysnb Setreuid(ruid int, euid int) (err error)
  724. //sysnb Setsid() (pid int, err error)
  725. //sysnb Settimeofday(tp *Timeval) (err error)
  726. //sysnb Setuid(uid int) (err error)
  727. //sys Symlink(path string, link string) (err error)
  728. //sys Symlinkat(oldpath string, newdirfd int, newpath string) (err error)
  729. //sys Sync() (err error)
  730. //sys Truncate(path string, length int64) (err error)
  731. //sys Umask(newmask int) (oldmask int)
  732. //sys Undelete(path string) (err error)
  733. //sys Unlink(path string) (err error)
  734. //sys Unlinkat(dirfd int, path string, flags int) (err error)
  735. //sys Unmount(path string, flags int) (err error)
  736. //sys write(fd int, p []byte) (n int, err error)
  737. //sys mmap(addr uintptr, length uintptr, prot int, flag int, fd int, pos int64) (ret uintptr, err error)
  738. //sys munmap(addr uintptr, length uintptr) (err error)
  739. //sys readv(fd int, iovecs []Iovec) (n int, err error)
  740. //sys preadv(fd int, iovecs []Iovec, offset int64) (n int, err error)
  741. //sys writev(fd int, iovecs []Iovec) (n int, err error)
  742. //sys pwritev(fd int, iovecs []Iovec, offset int64) (n int, err error)