c01194742febbfd715038a55b677aa4d628ce252
[govpp.git] / vendor / golang.org / x / sys / unix / syscall_linux.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 // Linux system calls.
6 // This file is compiled as ordinary Go code,
7 // but it is also input to mksyscall,
8 // which parses the //sys lines and generates system call stubs.
9 // Note that sometimes we use a lowercase //sys name and
10 // wrap it in our own nicer implementation.
11
12 package unix
13
14 import (
15         "syscall"
16         "unsafe"
17 )
18
19 /*
20  * Wrapped
21  */
22
23 func Access(path string, mode uint32) (err error) {
24         return Faccessat(AT_FDCWD, path, mode, 0)
25 }
26
27 func Chmod(path string, mode uint32) (err error) {
28         return Fchmodat(AT_FDCWD, path, mode, 0)
29 }
30
31 func Chown(path string, uid int, gid int) (err error) {
32         return Fchownat(AT_FDCWD, path, uid, gid, 0)
33 }
34
35 func Creat(path string, mode uint32) (fd int, err error) {
36         return Open(path, O_CREAT|O_WRONLY|O_TRUNC, mode)
37 }
38
39 //sys   Linkat(olddirfd int, oldpath string, newdirfd int, newpath string, flags int) (err error)
40
41 func Link(oldpath string, newpath string) (err error) {
42         return Linkat(AT_FDCWD, oldpath, AT_FDCWD, newpath, 0)
43 }
44
45 func Mkdir(path string, mode uint32) (err error) {
46         return Mkdirat(AT_FDCWD, path, mode)
47 }
48
49 func Mknod(path string, mode uint32, dev int) (err error) {
50         return Mknodat(AT_FDCWD, path, mode, dev)
51 }
52
53 func Open(path string, mode int, perm uint32) (fd int, err error) {
54         return openat(AT_FDCWD, path, mode|O_LARGEFILE, perm)
55 }
56
57 //sys   openat(dirfd int, path string, flags int, mode uint32) (fd int, err error)
58
59 func Openat(dirfd int, path string, flags int, mode uint32) (fd int, err error) {
60         return openat(dirfd, path, flags|O_LARGEFILE, mode)
61 }
62
63 //sys   ppoll(fds *PollFd, nfds int, timeout *Timespec, sigmask *Sigset_t) (n int, err error)
64
65 func Ppoll(fds []PollFd, timeout *Timespec, sigmask *Sigset_t) (n int, err error) {
66         if len(fds) == 0 {
67                 return ppoll(nil, 0, timeout, sigmask)
68         }
69         return ppoll(&fds[0], len(fds), timeout, sigmask)
70 }
71
72 //sys   Readlinkat(dirfd int, path string, buf []byte) (n int, err error)
73
74 func Readlink(path string, buf []byte) (n int, err error) {
75         return Readlinkat(AT_FDCWD, path, buf)
76 }
77
78 func Rename(oldpath string, newpath string) (err error) {
79         return Renameat(AT_FDCWD, oldpath, AT_FDCWD, newpath)
80 }
81
82 func Rmdir(path string) error {
83         return Unlinkat(AT_FDCWD, path, AT_REMOVEDIR)
84 }
85
86 //sys   Symlinkat(oldpath string, newdirfd int, newpath string) (err error)
87
88 func Symlink(oldpath string, newpath string) (err error) {
89         return Symlinkat(oldpath, AT_FDCWD, newpath)
90 }
91
92 func Unlink(path string) error {
93         return Unlinkat(AT_FDCWD, path, 0)
94 }
95
96 //sys   Unlinkat(dirfd int, path string, flags int) (err error)
97
98 //sys   utimes(path string, times *[2]Timeval) (err error)
99
100 func Utimes(path string, tv []Timeval) error {
101         if tv == nil {
102                 err := utimensat(AT_FDCWD, path, nil, 0)
103                 if err != ENOSYS {
104                         return err
105                 }
106                 return utimes(path, nil)
107         }
108         if len(tv) != 2 {
109                 return EINVAL
110         }
111         var ts [2]Timespec
112         ts[0] = NsecToTimespec(TimevalToNsec(tv[0]))
113         ts[1] = NsecToTimespec(TimevalToNsec(tv[1]))
114         err := utimensat(AT_FDCWD, path, (*[2]Timespec)(unsafe.Pointer(&ts[0])), 0)
115         if err != ENOSYS {
116                 return err
117         }
118         return utimes(path, (*[2]Timeval)(unsafe.Pointer(&tv[0])))
119 }
120
121 //sys   utimensat(dirfd int, path string, times *[2]Timespec, flags int) (err error)
122
123 func UtimesNano(path string, ts []Timespec) error {
124         if ts == nil {
125                 err := utimensat(AT_FDCWD, path, nil, 0)
126                 if err != ENOSYS {
127                         return err
128                 }
129                 return utimes(path, nil)
130         }
131         if len(ts) != 2 {
132                 return EINVAL
133         }
134         err := utimensat(AT_FDCWD, path, (*[2]Timespec)(unsafe.Pointer(&ts[0])), 0)
135         if err != ENOSYS {
136                 return err
137         }
138         // If the utimensat syscall isn't available (utimensat was added to Linux
139         // in 2.6.22, Released, 8 July 2007) then fall back to utimes
140         var tv [2]Timeval
141         for i := 0; i < 2; i++ {
142                 tv[i] = NsecToTimeval(TimespecToNsec(ts[i]))
143         }
144         return utimes(path, (*[2]Timeval)(unsafe.Pointer(&tv[0])))
145 }
146
147 func UtimesNanoAt(dirfd int, path string, ts []Timespec, flags int) error {
148         if ts == nil {
149                 return utimensat(dirfd, path, nil, flags)
150         }
151         if len(ts) != 2 {
152                 return EINVAL
153         }
154         return utimensat(dirfd, path, (*[2]Timespec)(unsafe.Pointer(&ts[0])), flags)
155 }
156
157 //sys   futimesat(dirfd int, path *byte, times *[2]Timeval) (err error)
158
159 func Futimesat(dirfd int, path string, tv []Timeval) error {
160         pathp, err := BytePtrFromString(path)
161         if err != nil {
162                 return err
163         }
164         if tv == nil {
165                 return futimesat(dirfd, pathp, nil)
166         }
167         if len(tv) != 2 {
168                 return EINVAL
169         }
170         return futimesat(dirfd, pathp, (*[2]Timeval)(unsafe.Pointer(&tv[0])))
171 }
172
173 func Futimes(fd int, tv []Timeval) (err error) {
174         // Believe it or not, this is the best we can do on Linux
175         // (and is what glibc does).
176         return Utimes("/proc/self/fd/"+itoa(fd), tv)
177 }
178
179 const ImplementsGetwd = true
180
181 //sys   Getcwd(buf []byte) (n int, err error)
182
183 func Getwd() (wd string, err error) {
184         var buf [PathMax]byte
185         n, err := Getcwd(buf[0:])
186         if err != nil {
187                 return "", err
188         }
189         // Getcwd returns the number of bytes written to buf, including the NUL.
190         if n < 1 || n > len(buf) || buf[n-1] != 0 {
191                 return "", EINVAL
192         }
193         return string(buf[0 : n-1]), nil
194 }
195
196 func Getgroups() (gids []int, err error) {
197         n, err := getgroups(0, nil)
198         if err != nil {
199                 return nil, err
200         }
201         if n == 0 {
202                 return nil, nil
203         }
204
205         // Sanity check group count.  Max is 1<<16 on Linux.
206         if n < 0 || n > 1<<20 {
207                 return nil, EINVAL
208         }
209
210         a := make([]_Gid_t, n)
211         n, err = getgroups(n, &a[0])
212         if err != nil {
213                 return nil, err
214         }
215         gids = make([]int, n)
216         for i, v := range a[0:n] {
217                 gids[i] = int(v)
218         }
219         return
220 }
221
222 func Setgroups(gids []int) (err error) {
223         if len(gids) == 0 {
224                 return setgroups(0, nil)
225         }
226
227         a := make([]_Gid_t, len(gids))
228         for i, v := range gids {
229                 a[i] = _Gid_t(v)
230         }
231         return setgroups(len(a), &a[0])
232 }
233
234 type WaitStatus uint32
235
236 // Wait status is 7 bits at bottom, either 0 (exited),
237 // 0x7F (stopped), or a signal number that caused an exit.
238 // The 0x80 bit is whether there was a core dump.
239 // An extra number (exit code, signal causing a stop)
240 // is in the high bits.  At least that's the idea.
241 // There are various irregularities.  For example, the
242 // "continued" status is 0xFFFF, distinguishing itself
243 // from stopped via the core dump bit.
244
245 const (
246         mask    = 0x7F
247         core    = 0x80
248         exited  = 0x00
249         stopped = 0x7F
250         shift   = 8
251 )
252
253 func (w WaitStatus) Exited() bool { return w&mask == exited }
254
255 func (w WaitStatus) Signaled() bool { return w&mask != stopped && w&mask != exited }
256
257 func (w WaitStatus) Stopped() bool { return w&0xFF == stopped }
258
259 func (w WaitStatus) Continued() bool { return w == 0xFFFF }
260
261 func (w WaitStatus) CoreDump() bool { return w.Signaled() && w&core != 0 }
262
263 func (w WaitStatus) ExitStatus() int {
264         if !w.Exited() {
265                 return -1
266         }
267         return int(w>>shift) & 0xFF
268 }
269
270 func (w WaitStatus) Signal() syscall.Signal {
271         if !w.Signaled() {
272                 return -1
273         }
274         return syscall.Signal(w & mask)
275 }
276
277 func (w WaitStatus) StopSignal() syscall.Signal {
278         if !w.Stopped() {
279                 return -1
280         }
281         return syscall.Signal(w>>shift) & 0xFF
282 }
283
284 func (w WaitStatus) TrapCause() int {
285         if w.StopSignal() != SIGTRAP {
286                 return -1
287         }
288         return int(w>>shift) >> 8
289 }
290
291 //sys   wait4(pid int, wstatus *_C_int, options int, rusage *Rusage) (wpid int, err error)
292
293 func Wait4(pid int, wstatus *WaitStatus, options int, rusage *Rusage) (wpid int, err error) {
294         var status _C_int
295         wpid, err = wait4(pid, &status, options, rusage)
296         if wstatus != nil {
297                 *wstatus = WaitStatus(status)
298         }
299         return
300 }
301
302 func Mkfifo(path string, mode uint32) (err error) {
303         return Mknod(path, mode|S_IFIFO, 0)
304 }
305
306 func (sa *SockaddrInet4) sockaddr() (unsafe.Pointer, _Socklen, error) {
307         if sa.Port < 0 || sa.Port > 0xFFFF {
308                 return nil, 0, EINVAL
309         }
310         sa.raw.Family = AF_INET
311         p := (*[2]byte)(unsafe.Pointer(&sa.raw.Port))
312         p[0] = byte(sa.Port >> 8)
313         p[1] = byte(sa.Port)
314         for i := 0; i < len(sa.Addr); i++ {
315                 sa.raw.Addr[i] = sa.Addr[i]
316         }
317         return unsafe.Pointer(&sa.raw), SizeofSockaddrInet4, nil
318 }
319
320 func (sa *SockaddrInet6) sockaddr() (unsafe.Pointer, _Socklen, error) {
321         if sa.Port < 0 || sa.Port > 0xFFFF {
322                 return nil, 0, EINVAL
323         }
324         sa.raw.Family = AF_INET6
325         p := (*[2]byte)(unsafe.Pointer(&sa.raw.Port))
326         p[0] = byte(sa.Port >> 8)
327         p[1] = byte(sa.Port)
328         sa.raw.Scope_id = sa.ZoneId
329         for i := 0; i < len(sa.Addr); i++ {
330                 sa.raw.Addr[i] = sa.Addr[i]
331         }
332         return unsafe.Pointer(&sa.raw), SizeofSockaddrInet6, nil
333 }
334
335 func (sa *SockaddrUnix) sockaddr() (unsafe.Pointer, _Socklen, error) {
336         name := sa.Name
337         n := len(name)
338         if n >= len(sa.raw.Path) {
339                 return nil, 0, EINVAL
340         }
341         sa.raw.Family = AF_UNIX
342         for i := 0; i < n; i++ {
343                 sa.raw.Path[i] = int8(name[i])
344         }
345         // length is family (uint16), name, NUL.
346         sl := _Socklen(2)
347         if n > 0 {
348                 sl += _Socklen(n) + 1
349         }
350         if sa.raw.Path[0] == '@' {
351                 sa.raw.Path[0] = 0
352                 // Don't count trailing NUL for abstract address.
353                 sl--
354         }
355
356         return unsafe.Pointer(&sa.raw), sl, nil
357 }
358
359 type SockaddrLinklayer struct {
360         Protocol uint16
361         Ifindex  int
362         Hatype   uint16
363         Pkttype  uint8
364         Halen    uint8
365         Addr     [8]byte
366         raw      RawSockaddrLinklayer
367 }
368
369 func (sa *SockaddrLinklayer) sockaddr() (unsafe.Pointer, _Socklen, error) {
370         if sa.Ifindex < 0 || sa.Ifindex > 0x7fffffff {
371                 return nil, 0, EINVAL
372         }
373         sa.raw.Family = AF_PACKET
374         sa.raw.Protocol = sa.Protocol
375         sa.raw.Ifindex = int32(sa.Ifindex)
376         sa.raw.Hatype = sa.Hatype
377         sa.raw.Pkttype = sa.Pkttype
378         sa.raw.Halen = sa.Halen
379         for i := 0; i < len(sa.Addr); i++ {
380                 sa.raw.Addr[i] = sa.Addr[i]
381         }
382         return unsafe.Pointer(&sa.raw), SizeofSockaddrLinklayer, nil
383 }
384
385 type SockaddrNetlink struct {
386         Family uint16
387         Pad    uint16
388         Pid    uint32
389         Groups uint32
390         raw    RawSockaddrNetlink
391 }
392
393 func (sa *SockaddrNetlink) sockaddr() (unsafe.Pointer, _Socklen, error) {
394         sa.raw.Family = AF_NETLINK
395         sa.raw.Pad = sa.Pad
396         sa.raw.Pid = sa.Pid
397         sa.raw.Groups = sa.Groups
398         return unsafe.Pointer(&sa.raw), SizeofSockaddrNetlink, nil
399 }
400
401 type SockaddrHCI struct {
402         Dev     uint16
403         Channel uint16
404         raw     RawSockaddrHCI
405 }
406
407 func (sa *SockaddrHCI) sockaddr() (unsafe.Pointer, _Socklen, error) {
408         sa.raw.Family = AF_BLUETOOTH
409         sa.raw.Dev = sa.Dev
410         sa.raw.Channel = sa.Channel
411         return unsafe.Pointer(&sa.raw), SizeofSockaddrHCI, nil
412 }
413
414 // SockaddrCAN implements the Sockaddr interface for AF_CAN type sockets.
415 // The RxID and TxID fields are used for transport protocol addressing in
416 // (CAN_TP16, CAN_TP20, CAN_MCNET, and CAN_ISOTP), they can be left with
417 // zero values for CAN_RAW and CAN_BCM sockets as they have no meaning.
418 //
419 // The SockaddrCAN struct must be bound to the socket file descriptor
420 // using Bind before the CAN socket can be used.
421 //
422 //      // Read one raw CAN frame
423 //      fd, _ := Socket(AF_CAN, SOCK_RAW, CAN_RAW)
424 //      addr := &SockaddrCAN{Ifindex: index}
425 //      Bind(fd, addr)
426 //      frame := make([]byte, 16)
427 //      Read(fd, frame)
428 //
429 // The full SocketCAN documentation can be found in the linux kernel
430 // archives at: https://www.kernel.org/doc/Documentation/networking/can.txt
431 type SockaddrCAN struct {
432         Ifindex int
433         RxID    uint32
434         TxID    uint32
435         raw     RawSockaddrCAN
436 }
437
438 func (sa *SockaddrCAN) sockaddr() (unsafe.Pointer, _Socklen, error) {
439         if sa.Ifindex < 0 || sa.Ifindex > 0x7fffffff {
440                 return nil, 0, EINVAL
441         }
442         sa.raw.Family = AF_CAN
443         sa.raw.Ifindex = int32(sa.Ifindex)
444         rx := (*[4]byte)(unsafe.Pointer(&sa.RxID))
445         for i := 0; i < 4; i++ {
446                 sa.raw.Addr[i] = rx[i]
447         }
448         tx := (*[4]byte)(unsafe.Pointer(&sa.TxID))
449         for i := 0; i < 4; i++ {
450                 sa.raw.Addr[i+4] = tx[i]
451         }
452         return unsafe.Pointer(&sa.raw), SizeofSockaddrCAN, nil
453 }
454
455 // SockaddrALG implements the Sockaddr interface for AF_ALG type sockets.
456 // SockaddrALG enables userspace access to the Linux kernel's cryptography
457 // subsystem. The Type and Name fields specify which type of hash or cipher
458 // should be used with a given socket.
459 //
460 // To create a file descriptor that provides access to a hash or cipher, both
461 // Bind and Accept must be used. Once the setup process is complete, input
462 // data can be written to the socket, processed by the kernel, and then read
463 // back as hash output or ciphertext.
464 //
465 // Here is an example of using an AF_ALG socket with SHA1 hashing.
466 // The initial socket setup process is as follows:
467 //
468 //      // Open a socket to perform SHA1 hashing.
469 //      fd, _ := unix.Socket(unix.AF_ALG, unix.SOCK_SEQPACKET, 0)
470 //      addr := &unix.SockaddrALG{Type: "hash", Name: "sha1"}
471 //      unix.Bind(fd, addr)
472 //      // Note: unix.Accept does not work at this time; must invoke accept()
473 //      // manually using unix.Syscall.
474 //      hashfd, _, _ := unix.Syscall(unix.SYS_ACCEPT, uintptr(fd), 0, 0)
475 //
476 // Once a file descriptor has been returned from Accept, it may be used to
477 // perform SHA1 hashing. The descriptor is not safe for concurrent use, but
478 // may be re-used repeatedly with subsequent Write and Read operations.
479 //
480 // When hashing a small byte slice or string, a single Write and Read may
481 // be used:
482 //
483 //      // Assume hashfd is already configured using the setup process.
484 //      hash := os.NewFile(hashfd, "sha1")
485 //      // Hash an input string and read the results. Each Write discards
486 //      // previous hash state. Read always reads the current state.
487 //      b := make([]byte, 20)
488 //      for i := 0; i < 2; i++ {
489 //          io.WriteString(hash, "Hello, world.")
490 //          hash.Read(b)
491 //          fmt.Println(hex.EncodeToString(b))
492 //      }
493 //      // Output:
494 //      // 2ae01472317d1935a84797ec1983ae243fc6aa28
495 //      // 2ae01472317d1935a84797ec1983ae243fc6aa28
496 //
497 // For hashing larger byte slices, or byte streams such as those read from
498 // a file or socket, use Sendto with MSG_MORE to instruct the kernel to update
499 // the hash digest instead of creating a new one for a given chunk and finalizing it.
500 //
501 //      // Assume hashfd and addr are already configured using the setup process.
502 //      hash := os.NewFile(hashfd, "sha1")
503 //      // Hash the contents of a file.
504 //      f, _ := os.Open("/tmp/linux-4.10-rc7.tar.xz")
505 //      b := make([]byte, 4096)
506 //      for {
507 //          n, err := f.Read(b)
508 //          if err == io.EOF {
509 //              break
510 //          }
511 //          unix.Sendto(hashfd, b[:n], unix.MSG_MORE, addr)
512 //      }
513 //      hash.Read(b)
514 //      fmt.Println(hex.EncodeToString(b))
515 //      // Output: 85cdcad0c06eef66f805ecce353bec9accbeecc5
516 //
517 // For more information, see: http://www.chronox.de/crypto-API/crypto/userspace-if.html.
518 type SockaddrALG struct {
519         Type    string
520         Name    string
521         Feature uint32
522         Mask    uint32
523         raw     RawSockaddrALG
524 }
525
526 func (sa *SockaddrALG) sockaddr() (unsafe.Pointer, _Socklen, error) {
527         // Leave room for NUL byte terminator.
528         if len(sa.Type) > 13 {
529                 return nil, 0, EINVAL
530         }
531         if len(sa.Name) > 63 {
532                 return nil, 0, EINVAL
533         }
534
535         sa.raw.Family = AF_ALG
536         sa.raw.Feat = sa.Feature
537         sa.raw.Mask = sa.Mask
538
539         typ, err := ByteSliceFromString(sa.Type)
540         if err != nil {
541                 return nil, 0, err
542         }
543         name, err := ByteSliceFromString(sa.Name)
544         if err != nil {
545                 return nil, 0, err
546         }
547
548         copy(sa.raw.Type[:], typ)
549         copy(sa.raw.Name[:], name)
550
551         return unsafe.Pointer(&sa.raw), SizeofSockaddrALG, nil
552 }
553
554 func anyToSockaddr(rsa *RawSockaddrAny) (Sockaddr, error) {
555         switch rsa.Addr.Family {
556         case AF_NETLINK:
557                 pp := (*RawSockaddrNetlink)(unsafe.Pointer(rsa))
558                 sa := new(SockaddrNetlink)
559                 sa.Family = pp.Family
560                 sa.Pad = pp.Pad
561                 sa.Pid = pp.Pid
562                 sa.Groups = pp.Groups
563                 return sa, nil
564
565         case AF_PACKET:
566                 pp := (*RawSockaddrLinklayer)(unsafe.Pointer(rsa))
567                 sa := new(SockaddrLinklayer)
568                 sa.Protocol = pp.Protocol
569                 sa.Ifindex = int(pp.Ifindex)
570                 sa.Hatype = pp.Hatype
571                 sa.Pkttype = pp.Pkttype
572                 sa.Halen = pp.Halen
573                 for i := 0; i < len(sa.Addr); i++ {
574                         sa.Addr[i] = pp.Addr[i]
575                 }
576                 return sa, nil
577
578         case AF_UNIX:
579                 pp := (*RawSockaddrUnix)(unsafe.Pointer(rsa))
580                 sa := new(SockaddrUnix)
581                 if pp.Path[0] == 0 {
582                         // "Abstract" Unix domain socket.
583                         // Rewrite leading NUL as @ for textual display.
584                         // (This is the standard convention.)
585                         // Not friendly to overwrite in place,
586                         // but the callers below don't care.
587                         pp.Path[0] = '@'
588                 }
589
590                 // Assume path ends at NUL.
591                 // This is not technically the Linux semantics for
592                 // abstract Unix domain sockets--they are supposed
593                 // to be uninterpreted fixed-size binary blobs--but
594                 // everyone uses this convention.
595                 n := 0
596                 for n < len(pp.Path) && pp.Path[n] != 0 {
597                         n++
598                 }
599                 bytes := (*[10000]byte)(unsafe.Pointer(&pp.Path[0]))[0:n]
600                 sa.Name = string(bytes)
601                 return sa, nil
602
603         case AF_INET:
604                 pp := (*RawSockaddrInet4)(unsafe.Pointer(rsa))
605                 sa := new(SockaddrInet4)
606                 p := (*[2]byte)(unsafe.Pointer(&pp.Port))
607                 sa.Port = int(p[0])<<8 + int(p[1])
608                 for i := 0; i < len(sa.Addr); i++ {
609                         sa.Addr[i] = pp.Addr[i]
610                 }
611                 return sa, nil
612
613         case AF_INET6:
614                 pp := (*RawSockaddrInet6)(unsafe.Pointer(rsa))
615                 sa := new(SockaddrInet6)
616                 p := (*[2]byte)(unsafe.Pointer(&pp.Port))
617                 sa.Port = int(p[0])<<8 + int(p[1])
618                 sa.ZoneId = pp.Scope_id
619                 for i := 0; i < len(sa.Addr); i++ {
620                         sa.Addr[i] = pp.Addr[i]
621                 }
622                 return sa, nil
623         }
624         return nil, EAFNOSUPPORT
625 }
626
627 func Accept(fd int) (nfd int, sa Sockaddr, err error) {
628         var rsa RawSockaddrAny
629         var len _Socklen = SizeofSockaddrAny
630         nfd, err = accept(fd, &rsa, &len)
631         if err != nil {
632                 return
633         }
634         sa, err = anyToSockaddr(&rsa)
635         if err != nil {
636                 Close(nfd)
637                 nfd = 0
638         }
639         return
640 }
641
642 func Accept4(fd int, flags int) (nfd int, sa Sockaddr, err error) {
643         var rsa RawSockaddrAny
644         var len _Socklen = SizeofSockaddrAny
645         nfd, err = accept4(fd, &rsa, &len, flags)
646         if err != nil {
647                 return
648         }
649         if len > SizeofSockaddrAny {
650                 panic("RawSockaddrAny too small")
651         }
652         sa, err = anyToSockaddr(&rsa)
653         if err != nil {
654                 Close(nfd)
655                 nfd = 0
656         }
657         return
658 }
659
660 func Getsockname(fd int) (sa Sockaddr, err error) {
661         var rsa RawSockaddrAny
662         var len _Socklen = SizeofSockaddrAny
663         if err = getsockname(fd, &rsa, &len); err != nil {
664                 return
665         }
666         return anyToSockaddr(&rsa)
667 }
668
669 func GetsockoptInet4Addr(fd, level, opt int) (value [4]byte, err error) {
670         vallen := _Socklen(4)
671         err = getsockopt(fd, level, opt, unsafe.Pointer(&value[0]), &vallen)
672         return value, err
673 }
674
675 func GetsockoptIPMreq(fd, level, opt int) (*IPMreq, error) {
676         var value IPMreq
677         vallen := _Socklen(SizeofIPMreq)
678         err := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
679         return &value, err
680 }
681
682 func GetsockoptIPMreqn(fd, level, opt int) (*IPMreqn, error) {
683         var value IPMreqn
684         vallen := _Socklen(SizeofIPMreqn)
685         err := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
686         return &value, err
687 }
688
689 func GetsockoptIPv6Mreq(fd, level, opt int) (*IPv6Mreq, error) {
690         var value IPv6Mreq
691         vallen := _Socklen(SizeofIPv6Mreq)
692         err := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
693         return &value, err
694 }
695
696 func GetsockoptIPv6MTUInfo(fd, level, opt int) (*IPv6MTUInfo, error) {
697         var value IPv6MTUInfo
698         vallen := _Socklen(SizeofIPv6MTUInfo)
699         err := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
700         return &value, err
701 }
702
703 func GetsockoptICMPv6Filter(fd, level, opt int) (*ICMPv6Filter, error) {
704         var value ICMPv6Filter
705         vallen := _Socklen(SizeofICMPv6Filter)
706         err := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
707         return &value, err
708 }
709
710 func GetsockoptUcred(fd, level, opt int) (*Ucred, error) {
711         var value Ucred
712         vallen := _Socklen(SizeofUcred)
713         err := getsockopt(fd, level, opt, unsafe.Pointer(&value), &vallen)
714         return &value, err
715 }
716
717 func SetsockoptIPMreqn(fd, level, opt int, mreq *IPMreqn) (err error) {
718         return setsockopt(fd, level, opt, unsafe.Pointer(mreq), unsafe.Sizeof(*mreq))
719 }
720
721 func Recvmsg(fd int, p, oob []byte, flags int) (n, oobn int, recvflags int, from Sockaddr, err error) {
722         var msg Msghdr
723         var rsa RawSockaddrAny
724         msg.Name = (*byte)(unsafe.Pointer(&rsa))
725         msg.Namelen = uint32(SizeofSockaddrAny)
726         var iov Iovec
727         if len(p) > 0 {
728                 iov.Base = (*byte)(unsafe.Pointer(&p[0]))
729                 iov.SetLen(len(p))
730         }
731         var dummy byte
732         if len(oob) > 0 {
733                 // receive at least one normal byte
734                 if len(p) == 0 {
735                         iov.Base = &dummy
736                         iov.SetLen(1)
737                 }
738                 msg.Control = (*byte)(unsafe.Pointer(&oob[0]))
739                 msg.SetControllen(len(oob))
740         }
741         msg.Iov = &iov
742         msg.Iovlen = 1
743         if n, err = recvmsg(fd, &msg, flags); err != nil {
744                 return
745         }
746         oobn = int(msg.Controllen)
747         recvflags = int(msg.Flags)
748         // source address is only specified if the socket is unconnected
749         if rsa.Addr.Family != AF_UNSPEC {
750                 from, err = anyToSockaddr(&rsa)
751         }
752         return
753 }
754
755 func Sendmsg(fd int, p, oob []byte, to Sockaddr, flags int) (err error) {
756         _, err = SendmsgN(fd, p, oob, to, flags)
757         return
758 }
759
760 func SendmsgN(fd int, p, oob []byte, to Sockaddr, flags int) (n int, err error) {
761         var ptr unsafe.Pointer
762         var salen _Socklen
763         if to != nil {
764                 var err error
765                 ptr, salen, err = to.sockaddr()
766                 if err != nil {
767                         return 0, err
768                 }
769         }
770         var msg Msghdr
771         msg.Name = (*byte)(unsafe.Pointer(ptr))
772         msg.Namelen = uint32(salen)
773         var iov Iovec
774         if len(p) > 0 {
775                 iov.Base = (*byte)(unsafe.Pointer(&p[0]))
776                 iov.SetLen(len(p))
777         }
778         var dummy byte
779         if len(oob) > 0 {
780                 // send at least one normal byte
781                 if len(p) == 0 {
782                         iov.Base = &dummy
783                         iov.SetLen(1)
784                 }
785                 msg.Control = (*byte)(unsafe.Pointer(&oob[0]))
786                 msg.SetControllen(len(oob))
787         }
788         msg.Iov = &iov
789         msg.Iovlen = 1
790         if n, err = sendmsg(fd, &msg, flags); err != nil {
791                 return 0, err
792         }
793         if len(oob) > 0 && len(p) == 0 {
794                 n = 0
795         }
796         return n, nil
797 }
798
799 // BindToDevice binds the socket associated with fd to device.
800 func BindToDevice(fd int, device string) (err error) {
801         return SetsockoptString(fd, SOL_SOCKET, SO_BINDTODEVICE, device)
802 }
803
804 //sys   ptrace(request int, pid int, addr uintptr, data uintptr) (err error)
805
806 func ptracePeek(req int, pid int, addr uintptr, out []byte) (count int, err error) {
807         // The peek requests are machine-size oriented, so we wrap it
808         // to retrieve arbitrary-length data.
809
810         // The ptrace syscall differs from glibc's ptrace.
811         // Peeks returns the word in *data, not as the return value.
812
813         var buf [sizeofPtr]byte
814
815         // Leading edge.  PEEKTEXT/PEEKDATA don't require aligned
816         // access (PEEKUSER warns that it might), but if we don't
817         // align our reads, we might straddle an unmapped page
818         // boundary and not get the bytes leading up to the page
819         // boundary.
820         n := 0
821         if addr%sizeofPtr != 0 {
822                 err = ptrace(req, pid, addr-addr%sizeofPtr, uintptr(unsafe.Pointer(&buf[0])))
823                 if err != nil {
824                         return 0, err
825                 }
826                 n += copy(out, buf[addr%sizeofPtr:])
827                 out = out[n:]
828         }
829
830         // Remainder.
831         for len(out) > 0 {
832                 // We use an internal buffer to guarantee alignment.
833                 // It's not documented if this is necessary, but we're paranoid.
834                 err = ptrace(req, pid, addr+uintptr(n), uintptr(unsafe.Pointer(&buf[0])))
835                 if err != nil {
836                         return n, err
837                 }
838                 copied := copy(out, buf[0:])
839                 n += copied
840                 out = out[copied:]
841         }
842
843         return n, nil
844 }
845
846 func PtracePeekText(pid int, addr uintptr, out []byte) (count int, err error) {
847         return ptracePeek(PTRACE_PEEKTEXT, pid, addr, out)
848 }
849
850 func PtracePeekData(pid int, addr uintptr, out []byte) (count int, err error) {
851         return ptracePeek(PTRACE_PEEKDATA, pid, addr, out)
852 }
853
854 func ptracePoke(pokeReq int, peekReq int, pid int, addr uintptr, data []byte) (count int, err error) {
855         // As for ptracePeek, we need to align our accesses to deal
856         // with the possibility of straddling an invalid page.
857
858         // Leading edge.
859         n := 0
860         if addr%sizeofPtr != 0 {
861                 var buf [sizeofPtr]byte
862                 err = ptrace(peekReq, pid, addr-addr%sizeofPtr, uintptr(unsafe.Pointer(&buf[0])))
863                 if err != nil {
864                         return 0, err
865                 }
866                 n += copy(buf[addr%sizeofPtr:], data)
867                 word := *((*uintptr)(unsafe.Pointer(&buf[0])))
868                 err = ptrace(pokeReq, pid, addr-addr%sizeofPtr, word)
869                 if err != nil {
870                         return 0, err
871                 }
872                 data = data[n:]
873         }
874
875         // Interior.
876         for len(data) > sizeofPtr {
877                 word := *((*uintptr)(unsafe.Pointer(&data[0])))
878                 err = ptrace(pokeReq, pid, addr+uintptr(n), word)
879                 if err != nil {
880                         return n, err
881                 }
882                 n += sizeofPtr
883                 data = data[sizeofPtr:]
884         }
885
886         // Trailing edge.
887         if len(data) > 0 {
888                 var buf [sizeofPtr]byte
889                 err = ptrace(peekReq, pid, addr+uintptr(n), uintptr(unsafe.Pointer(&buf[0])))
890                 if err != nil {
891                         return n, err
892                 }
893                 copy(buf[0:], data)
894                 word := *((*uintptr)(unsafe.Pointer(&buf[0])))
895                 err = ptrace(pokeReq, pid, addr+uintptr(n), word)
896                 if err != nil {
897                         return n, err
898                 }
899                 n += len(data)
900         }
901
902         return n, nil
903 }
904
905 func PtracePokeText(pid int, addr uintptr, data []byte) (count int, err error) {
906         return ptracePoke(PTRACE_POKETEXT, PTRACE_PEEKTEXT, pid, addr, data)
907 }
908
909 func PtracePokeData(pid int, addr uintptr, data []byte) (count int, err error) {
910         return ptracePoke(PTRACE_POKEDATA, PTRACE_PEEKDATA, pid, addr, data)
911 }
912
913 func PtraceGetRegs(pid int, regsout *PtraceRegs) (err error) {
914         return ptrace(PTRACE_GETREGS, pid, 0, uintptr(unsafe.Pointer(regsout)))
915 }
916
917 func PtraceSetRegs(pid int, regs *PtraceRegs) (err error) {
918         return ptrace(PTRACE_SETREGS, pid, 0, uintptr(unsafe.Pointer(regs)))
919 }
920
921 func PtraceSetOptions(pid int, options int) (err error) {
922         return ptrace(PTRACE_SETOPTIONS, pid, 0, uintptr(options))
923 }
924
925 func PtraceGetEventMsg(pid int) (msg uint, err error) {
926         var data _C_long
927         err = ptrace(PTRACE_GETEVENTMSG, pid, 0, uintptr(unsafe.Pointer(&data)))
928         msg = uint(data)
929         return
930 }
931
932 func PtraceCont(pid int, signal int) (err error) {
933         return ptrace(PTRACE_CONT, pid, 0, uintptr(signal))
934 }
935
936 func PtraceSyscall(pid int, signal int) (err error) {
937         return ptrace(PTRACE_SYSCALL, pid, 0, uintptr(signal))
938 }
939
940 func PtraceSingleStep(pid int) (err error) { return ptrace(PTRACE_SINGLESTEP, pid, 0, 0) }
941
942 func PtraceAttach(pid int) (err error) { return ptrace(PTRACE_ATTACH, pid, 0, 0) }
943
944 func PtraceDetach(pid int) (err error) { return ptrace(PTRACE_DETACH, pid, 0, 0) }
945
946 //sys   reboot(magic1 uint, magic2 uint, cmd int, arg string) (err error)
947
948 func Reboot(cmd int) (err error) {
949         return reboot(LINUX_REBOOT_MAGIC1, LINUX_REBOOT_MAGIC2, cmd, "")
950 }
951
952 func clen(n []byte) int {
953         for i := 0; i < len(n); i++ {
954                 if n[i] == 0 {
955                         return i
956                 }
957         }
958         return len(n)
959 }
960
961 func ReadDirent(fd int, buf []byte) (n int, err error) {
962         return Getdents(fd, buf)
963 }
964
965 func ParseDirent(buf []byte, max int, names []string) (consumed int, count int, newnames []string) {
966         origlen := len(buf)
967         count = 0
968         for max != 0 && len(buf) > 0 {
969                 dirent := (*Dirent)(unsafe.Pointer(&buf[0]))
970                 buf = buf[dirent.Reclen:]
971                 if dirent.Ino == 0 { // File absent in directory.
972                         continue
973                 }
974                 bytes := (*[10000]byte)(unsafe.Pointer(&dirent.Name[0]))
975                 var name = string(bytes[0:clen(bytes[:])])
976                 if name == "." || name == ".." { // Useless names
977                         continue
978                 }
979                 max--
980                 count++
981                 names = append(names, name)
982         }
983         return origlen - len(buf), count, names
984 }
985
986 //sys   mount(source string, target string, fstype string, flags uintptr, data *byte) (err error)
987
988 func Mount(source string, target string, fstype string, flags uintptr, data string) (err error) {
989         // Certain file systems get rather angry and EINVAL if you give
990         // them an empty string of data, rather than NULL.
991         if data == "" {
992                 return mount(source, target, fstype, flags, nil)
993         }
994         datap, err := BytePtrFromString(data)
995         if err != nil {
996                 return err
997         }
998         return mount(source, target, fstype, flags, datap)
999 }
1000
1001 // Sendto
1002 // Recvfrom
1003 // Socketpair
1004
1005 /*
1006  * Direct access
1007  */
1008 //sys   Acct(path string) (err error)
1009 //sys   Adjtimex(buf *Timex) (state int, err error)
1010 //sys   Chdir(path string) (err error)
1011 //sys   Chroot(path string) (err error)
1012 //sys   ClockGettime(clockid int32, time *Timespec) (err error)
1013 //sys   Close(fd int) (err error)
1014 //sys   Dup(oldfd int) (fd int, err error)
1015 //sys   Dup3(oldfd int, newfd int, flags int) (err error)
1016 //sysnb EpollCreate(size int) (fd int, err error)
1017 //sysnb EpollCreate1(flag int) (fd int, err error)
1018 //sysnb EpollCtl(epfd int, op int, fd int, event *EpollEvent) (err error)
1019 //sys   Exit(code int) = SYS_EXIT_GROUP
1020 //sys   Faccessat(dirfd int, path string, mode uint32, flags int) (err error)
1021 //sys   Fallocate(fd int, mode uint32, off int64, len int64) (err error)
1022 //sys   Fchdir(fd int) (err error)
1023 //sys   Fchmod(fd int, mode uint32) (err error)
1024 //sys   Fchmodat(dirfd int, path string, mode uint32, flags int) (err error)
1025 //sys   Fchownat(dirfd int, path string, uid int, gid int, flags int) (err error)
1026 //sys   fcntl(fd int, cmd int, arg int) (val int, err error)
1027 //sys   Fdatasync(fd int) (err error)
1028 //sys   Flock(fd int, how int) (err error)
1029 //sys   Fsync(fd int) (err error)
1030 //sys   Getdents(fd int, buf []byte) (n int, err error) = SYS_GETDENTS64
1031 //sysnb Getpgid(pid int) (pgid int, err error)
1032
1033 func Getpgrp() (pid int) {
1034         pid, _ = Getpgid(0)
1035         return
1036 }
1037
1038 //sysnb Getpid() (pid int)
1039 //sysnb Getppid() (ppid int)
1040 //sys   Getpriority(which int, who int) (prio int, err error)
1041 //sys   Getrandom(buf []byte, flags int) (n int, err error)
1042 //sysnb Getrusage(who int, rusage *Rusage) (err error)
1043 //sysnb Getsid(pid int) (sid int, err error)
1044 //sysnb Gettid() (tid int)
1045 //sys   Getxattr(path string, attr string, dest []byte) (sz int, err error)
1046 //sys   InotifyAddWatch(fd int, pathname string, mask uint32) (watchdesc int, err error)
1047 //sysnb InotifyInit1(flags int) (fd int, err error)
1048 //sysnb InotifyRmWatch(fd int, watchdesc uint32) (success int, err error)
1049 //sysnb Kill(pid int, sig syscall.Signal) (err error)
1050 //sys   Klogctl(typ int, buf []byte) (n int, err error) = SYS_SYSLOG
1051 //sys   Listxattr(path string, dest []byte) (sz int, err error)
1052 //sys   Mkdirat(dirfd int, path string, mode uint32) (err error)
1053 //sys   Mknodat(dirfd int, path string, mode uint32, dev int) (err error)
1054 //sys   Nanosleep(time *Timespec, leftover *Timespec) (err error)
1055 //sys   PivotRoot(newroot string, putold string) (err error) = SYS_PIVOT_ROOT
1056 //sysnb prlimit(pid int, resource int, newlimit *Rlimit, old *Rlimit) (err error) = SYS_PRLIMIT64
1057 //sys   Prctl(option int, arg2 uintptr, arg3 uintptr, arg4 uintptr, arg5 uintptr) (err error)
1058 //sys   read(fd int, p []byte) (n int, err error)
1059 //sys   Removexattr(path string, attr string) (err error)
1060 //sys   Renameat(olddirfd int, oldpath string, newdirfd int, newpath string) (err error)
1061 //sys   Setdomainname(p []byte) (err error)
1062 //sys   Sethostname(p []byte) (err error)
1063 //sysnb Setpgid(pid int, pgid int) (err error)
1064 //sysnb Setsid() (pid int, err error)
1065 //sysnb Settimeofday(tv *Timeval) (err error)
1066 //sys   Setns(fd int, nstype int) (err error)
1067
1068 // issue 1435.
1069 // On linux Setuid and Setgid only affects the current thread, not the process.
1070 // This does not match what most callers expect so we must return an error
1071 // here rather than letting the caller think that the call succeeded.
1072
1073 func Setuid(uid int) (err error) {
1074         return EOPNOTSUPP
1075 }
1076
1077 func Setgid(uid int) (err error) {
1078         return EOPNOTSUPP
1079 }
1080
1081 //sys   Setpriority(which int, who int, prio int) (err error)
1082 //sys   Setxattr(path string, attr string, data []byte, flags int) (err error)
1083 //sys   Sync()
1084 //sysnb Sysinfo(info *Sysinfo_t) (err error)
1085 //sys   Tee(rfd int, wfd int, len int, flags int) (n int64, err error)
1086 //sysnb Tgkill(tgid int, tid int, sig syscall.Signal) (err error)
1087 //sysnb Times(tms *Tms) (ticks uintptr, err error)
1088 //sysnb Umask(mask int) (oldmask int)
1089 //sysnb Uname(buf *Utsname) (err error)
1090 //sys   Unmount(target string, flags int) (err error) = SYS_UMOUNT2
1091 //sys   Unshare(flags int) (err error)
1092 //sys   Ustat(dev int, ubuf *Ustat_t) (err error)
1093 //sys   write(fd int, p []byte) (n int, err error)
1094 //sys   exitThread(code int) (err error) = SYS_EXIT
1095 //sys   readlen(fd int, p *byte, np int) (n int, err error) = SYS_READ
1096 //sys   writelen(fd int, p *byte, np int) (n int, err error) = SYS_WRITE
1097
1098 // mmap varies by architecture; see syscall_linux_*.go.
1099 //sys   munmap(addr uintptr, length uintptr) (err error)
1100
1101 var mapper = &mmapper{
1102         active: make(map[*byte][]byte),
1103         mmap:   mmap,
1104         munmap: munmap,
1105 }
1106
1107 func Mmap(fd int, offset int64, length int, prot int, flags int) (data []byte, err error) {
1108         return mapper.Mmap(fd, offset, length, prot, flags)
1109 }
1110
1111 func Munmap(b []byte) (err error) {
1112         return mapper.Munmap(b)
1113 }
1114
1115 //sys   Madvise(b []byte, advice int) (err error)
1116 //sys   Mprotect(b []byte, prot int) (err error)
1117 //sys   Mlock(b []byte) (err error)
1118 //sys   Munlock(b []byte) (err error)
1119 //sys   Mlockall(flags int) (err error)
1120 //sys   Munlockall() (err error)
1121
1122 // Vmsplice splices user pages from a slice of Iovecs into a pipe specified by fd,
1123 // using the specified flags.
1124 func Vmsplice(fd int, iovs []Iovec, flags int) (int, error) {
1125         n, _, errno := Syscall6(
1126                 SYS_VMSPLICE,
1127                 uintptr(fd),
1128                 uintptr(unsafe.Pointer(&iovs[0])),
1129                 uintptr(len(iovs)),
1130                 uintptr(flags),
1131                 0,
1132                 0,
1133         )
1134         if errno != 0 {
1135                 return 0, syscall.Errno(errno)
1136         }
1137
1138         return int(n), nil
1139 }
1140
1141 /*
1142  * Unimplemented
1143  */
1144 // AddKey
1145 // AfsSyscall
1146 // Alarm
1147 // ArchPrctl
1148 // Brk
1149 // Capget
1150 // Capset
1151 // ClockGetres
1152 // ClockNanosleep
1153 // ClockSettime
1154 // Clone
1155 // CreateModule
1156 // DeleteModule
1157 // EpollCtlOld
1158 // EpollPwait
1159 // EpollWaitOld
1160 // Eventfd
1161 // Execve
1162 // Fgetxattr
1163 // Flistxattr
1164 // Fork
1165 // Fremovexattr
1166 // Fsetxattr
1167 // Futex
1168 // GetKernelSyms
1169 // GetMempolicy
1170 // GetRobustList
1171 // GetThreadArea
1172 // Getitimer
1173 // Getpmsg
1174 // IoCancel
1175 // IoDestroy
1176 // IoGetevents
1177 // IoSetup
1178 // IoSubmit
1179 // Ioctl
1180 // IoprioGet
1181 // IoprioSet
1182 // KexecLoad
1183 // Keyctl
1184 // Lgetxattr
1185 // Llistxattr
1186 // LookupDcookie
1187 // Lremovexattr
1188 // Lsetxattr
1189 // Mbind
1190 // MigratePages
1191 // Mincore
1192 // ModifyLdt
1193 // Mount
1194 // MovePages
1195 // Mprotect
1196 // MqGetsetattr
1197 // MqNotify
1198 // MqOpen
1199 // MqTimedreceive
1200 // MqTimedsend
1201 // MqUnlink
1202 // Mremap
1203 // Msgctl
1204 // Msgget
1205 // Msgrcv
1206 // Msgsnd
1207 // Msync
1208 // Newfstatat
1209 // Nfsservctl
1210 // Personality
1211 // Pselect6
1212 // Ptrace
1213 // Putpmsg
1214 // QueryModule
1215 // Quotactl
1216 // Readahead
1217 // Readv
1218 // RemapFilePages
1219 // RequestKey
1220 // RestartSyscall
1221 // RtSigaction
1222 // RtSigpending
1223 // RtSigprocmask
1224 // RtSigqueueinfo
1225 // RtSigreturn
1226 // RtSigsuspend
1227 // RtSigtimedwait
1228 // SchedGetPriorityMax
1229 // SchedGetPriorityMin
1230 // SchedGetaffinity
1231 // SchedGetparam
1232 // SchedGetscheduler
1233 // SchedRrGetInterval
1234 // SchedSetaffinity
1235 // SchedSetparam
1236 // SchedYield
1237 // Security
1238 // Semctl
1239 // Semget
1240 // Semop
1241 // Semtimedop
1242 // SetMempolicy
1243 // SetRobustList
1244 // SetThreadArea
1245 // SetTidAddress
1246 // Shmat
1247 // Shmctl
1248 // Shmdt
1249 // Shmget
1250 // Sigaltstack
1251 // Signalfd
1252 // Swapoff
1253 // Swapon
1254 // Sysfs
1255 // TimerCreate
1256 // TimerDelete
1257 // TimerGetoverrun
1258 // TimerGettime
1259 // TimerSettime
1260 // Timerfd
1261 // Tkill (obsolete)
1262 // Tuxcall
1263 // Umount2
1264 // Uselib
1265 // Utimensat
1266 // Vfork
1267 // Vhangup
1268 // Vserver
1269 // Waitid
1270 // _Sysctl