syscall_aix.go 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562
  1. // Copyright 2018 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. // +build aix
  5. // Aix 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. package unix
  12. import (
  13. "syscall"
  14. "unsafe"
  15. )
  16. /*
  17. * Wrapped
  18. */
  19. //sys utimes(path string, times *[2]Timeval) (err error)
  20. func Utimes(path string, tv []Timeval) error {
  21. if len(tv) != 2 {
  22. return EINVAL
  23. }
  24. return utimes(path, (*[2]Timeval)(unsafe.Pointer(&tv[0])))
  25. }
  26. //sys utimensat(dirfd int, path string, times *[2]Timespec, flag int) (err error)
  27. func UtimesNano(path string, ts []Timespec) error {
  28. if len(ts) != 2 {
  29. return EINVAL
  30. }
  31. return utimensat(AT_FDCWD, path, (*[2]Timespec)(unsafe.Pointer(&ts[0])), 0)
  32. }
  33. func UtimesNanoAt(dirfd int, path string, ts []Timespec, flags int) error {
  34. if ts == nil {
  35. return utimensat(dirfd, path, nil, flags)
  36. }
  37. if len(ts) != 2 {
  38. return EINVAL
  39. }
  40. return utimensat(dirfd, path, (*[2]Timespec)(unsafe.Pointer(&ts[0])), flags)
  41. }
  42. func (sa *SockaddrInet4) sockaddr() (unsafe.Pointer, _Socklen, error) {
  43. if sa.Port < 0 || sa.Port > 0xFFFF {
  44. return nil, 0, EINVAL
  45. }
  46. sa.raw.Family = AF_INET
  47. p := (*[2]byte)(unsafe.Pointer(&sa.raw.Port))
  48. p[0] = byte(sa.Port >> 8)
  49. p[1] = byte(sa.Port)
  50. for i := 0; i < len(sa.Addr); i++ {
  51. sa.raw.Addr[i] = sa.Addr[i]
  52. }
  53. return unsafe.Pointer(&sa.raw), SizeofSockaddrInet4, nil
  54. }
  55. func (sa *SockaddrInet6) sockaddr() (unsafe.Pointer, _Socklen, error) {
  56. if sa.Port < 0 || sa.Port > 0xFFFF {
  57. return nil, 0, EINVAL
  58. }
  59. sa.raw.Family = AF_INET6
  60. p := (*[2]byte)(unsafe.Pointer(&sa.raw.Port))
  61. p[0] = byte(sa.Port >> 8)
  62. p[1] = byte(sa.Port)
  63. sa.raw.Scope_id = sa.ZoneId
  64. for i := 0; i < len(sa.Addr); i++ {
  65. sa.raw.Addr[i] = sa.Addr[i]
  66. }
  67. return unsafe.Pointer(&sa.raw), SizeofSockaddrInet6, nil
  68. }
  69. func (sa *SockaddrUnix) sockaddr() (unsafe.Pointer, _Socklen, error) {
  70. name := sa.Name
  71. n := len(name)
  72. if n > len(sa.raw.Path) {
  73. return nil, 0, EINVAL
  74. }
  75. if n == len(sa.raw.Path) && name[0] != '@' {
  76. return nil, 0, EINVAL
  77. }
  78. sa.raw.Family = AF_UNIX
  79. for i := 0; i < n; i++ {
  80. sa.raw.Path[i] = uint8(name[i])
  81. }
  82. // length is family (uint16), name, NUL.
  83. sl := _Socklen(2)
  84. if n > 0 {
  85. sl += _Socklen(n) + 1
  86. }
  87. if sa.raw.Path[0] == '@' {
  88. sa.raw.Path[0] = 0
  89. // Don't count trailing NUL for abstract address.
  90. sl--
  91. }
  92. return unsafe.Pointer(&sa.raw), sl, nil
  93. }
  94. func Getsockname(fd int) (sa Sockaddr, err error) {
  95. var rsa RawSockaddrAny
  96. var len _Socklen = SizeofSockaddrAny
  97. if err = getsockname(fd, &rsa, &len); err != nil {
  98. return
  99. }
  100. return anyToSockaddr(fd, &rsa)
  101. }
  102. //sys getcwd(buf []byte) (err error)
  103. const ImplementsGetwd = true
  104. func Getwd() (ret string, err error) {
  105. for len := uint64(4096); ; len *= 2 {
  106. b := make([]byte, len)
  107. err := getcwd(b)
  108. if err == nil {
  109. i := 0
  110. for b[i] != 0 {
  111. i++
  112. }
  113. return string(b[0:i]), nil
  114. }
  115. if err != ERANGE {
  116. return "", err
  117. }
  118. }
  119. }
  120. func Getcwd(buf []byte) (n int, err error) {
  121. err = getcwd(buf)
  122. if err == nil {
  123. i := 0
  124. for buf[i] != 0 {
  125. i++
  126. }
  127. n = i + 1
  128. }
  129. return
  130. }
  131. func Getgroups() (gids []int, err error) {
  132. n, err := getgroups(0, nil)
  133. if err != nil {
  134. return nil, err
  135. }
  136. if n == 0 {
  137. return nil, nil
  138. }
  139. // Sanity check group count. Max is 16 on BSD.
  140. if n < 0 || n > 1000 {
  141. return nil, EINVAL
  142. }
  143. a := make([]_Gid_t, n)
  144. n, err = getgroups(n, &a[0])
  145. if err != nil {
  146. return nil, err
  147. }
  148. gids = make([]int, n)
  149. for i, v := range a[0:n] {
  150. gids[i] = int(v)
  151. }
  152. return
  153. }
  154. func Setgroups(gids []int) (err error) {
  155. if len(gids) == 0 {
  156. return setgroups(0, nil)
  157. }
  158. a := make([]_Gid_t, len(gids))
  159. for i, v := range gids {
  160. a[i] = _Gid_t(v)
  161. }
  162. return setgroups(len(a), &a[0])
  163. }
  164. /*
  165. * Socket
  166. */
  167. //sys accept(s int, rsa *RawSockaddrAny, addrlen *_Socklen) (fd int, err error)
  168. func Accept(fd int) (nfd int, sa Sockaddr, err error) {
  169. var rsa RawSockaddrAny
  170. var len _Socklen = SizeofSockaddrAny
  171. nfd, err = accept(fd, &rsa, &len)
  172. if nfd == -1 {
  173. return
  174. }
  175. sa, err = anyToSockaddr(fd, &rsa)
  176. if err != nil {
  177. Close(nfd)
  178. nfd = 0
  179. }
  180. return
  181. }
  182. func Recvmsg(fd int, p, oob []byte, flags int) (n, oobn int, recvflags int, from Sockaddr, err error) {
  183. // Recvmsg not implemented on AIX
  184. sa := new(SockaddrUnix)
  185. return -1, -1, -1, sa, ENOSYS
  186. }
  187. func Sendmsg(fd int, p, oob []byte, to Sockaddr, flags int) (err error) {
  188. _, err = SendmsgN(fd, p, oob, to, flags)
  189. return
  190. }
  191. func SendmsgN(fd int, p, oob []byte, to Sockaddr, flags int) (n int, err error) {
  192. // SendmsgN not implemented on AIX
  193. return -1, ENOSYS
  194. }
  195. func anyToSockaddr(fd int, rsa *RawSockaddrAny) (Sockaddr, error) {
  196. switch rsa.Addr.Family {
  197. case AF_UNIX:
  198. pp := (*RawSockaddrUnix)(unsafe.Pointer(rsa))
  199. sa := new(SockaddrUnix)
  200. // Some versions of AIX have a bug in getsockname (see IV78655).
  201. // We can't rely on sa.Len being set correctly.
  202. n := SizeofSockaddrUnix - 3 // substract leading Family, Len, terminating NUL.
  203. for i := 0; i < n; i++ {
  204. if pp.Path[i] == 0 {
  205. n = i
  206. break
  207. }
  208. }
  209. bytes := (*[10000]byte)(unsafe.Pointer(&pp.Path[0]))[0:n]
  210. sa.Name = string(bytes)
  211. return sa, nil
  212. case AF_INET:
  213. pp := (*RawSockaddrInet4)(unsafe.Pointer(rsa))
  214. sa := new(SockaddrInet4)
  215. p := (*[2]byte)(unsafe.Pointer(&pp.Port))
  216. sa.Port = int(p[0])<<8 + int(p[1])
  217. for i := 0; i < len(sa.Addr); i++ {
  218. sa.Addr[i] = pp.Addr[i]
  219. }
  220. return sa, nil
  221. case AF_INET6:
  222. pp := (*RawSockaddrInet6)(unsafe.Pointer(rsa))
  223. sa := new(SockaddrInet6)
  224. p := (*[2]byte)(unsafe.Pointer(&pp.Port))
  225. sa.Port = int(p[0])<<8 + int(p[1])
  226. sa.ZoneId = pp.Scope_id
  227. for i := 0; i < len(sa.Addr); i++ {
  228. sa.Addr[i] = pp.Addr[i]
  229. }
  230. return sa, nil
  231. }
  232. return nil, EAFNOSUPPORT
  233. }
  234. func Gettimeofday(tv *Timeval) (err error) {
  235. err = gettimeofday(tv, nil)
  236. return
  237. }
  238. // TODO
  239. func sendfile(outfd int, infd int, offset *int64, count int) (written int, err error) {
  240. return -1, ENOSYS
  241. }
  242. //sys getdirent(fd int, buf []byte) (n int, err error)
  243. func ReadDirent(fd int, buf []byte) (n int, err error) {
  244. return getdirent(fd, buf)
  245. }
  246. //sys wait4(pid Pid_t, status *_C_int, options int, rusage *Rusage) (wpid Pid_t, err error)
  247. func Wait4(pid int, wstatus *WaitStatus, options int, rusage *Rusage) (wpid int, err error) {
  248. var status _C_int
  249. var r Pid_t
  250. err = ERESTART
  251. // AIX wait4 may return with ERESTART errno, while the processus is still
  252. // active.
  253. for err == ERESTART {
  254. r, err = wait4(Pid_t(pid), &status, options, rusage)
  255. }
  256. wpid = int(r)
  257. if wstatus != nil {
  258. *wstatus = WaitStatus(status)
  259. }
  260. return
  261. }
  262. /*
  263. * Wait
  264. */
  265. type WaitStatus uint32
  266. func (w WaitStatus) Stopped() bool { return w&0x40 != 0 }
  267. func (w WaitStatus) StopSignal() syscall.Signal {
  268. if !w.Stopped() {
  269. return -1
  270. }
  271. return syscall.Signal(w>>8) & 0xFF
  272. }
  273. func (w WaitStatus) Exited() bool { return w&0xFF == 0 }
  274. func (w WaitStatus) ExitStatus() int {
  275. if !w.Exited() {
  276. return -1
  277. }
  278. return int((w >> 8) & 0xFF)
  279. }
  280. func (w WaitStatus) Signaled() bool { return w&0x40 == 0 && w&0xFF != 0 }
  281. func (w WaitStatus) Signal() syscall.Signal {
  282. if !w.Signaled() {
  283. return -1
  284. }
  285. return syscall.Signal(w>>16) & 0xFF
  286. }
  287. func (w WaitStatus) Continued() bool { return w&0x01000000 != 0 }
  288. func (w WaitStatus) CoreDump() bool { return w&0x200 != 0 }
  289. func (w WaitStatus) TrapCause() int { return -1 }
  290. //sys ioctl(fd int, req uint, arg uintptr) (err error)
  291. // ioctl itself should not be exposed directly, but additional get/set
  292. // functions for specific types are permissible.
  293. // IoctlSetInt performs an ioctl operation which sets an integer value
  294. // on fd, using the specified request number.
  295. func IoctlSetInt(fd int, req uint, value int) error {
  296. return ioctl(fd, req, uintptr(value))
  297. }
  298. func IoctlSetWinsize(fd int, req uint, value *Winsize) error {
  299. return ioctl(fd, req, uintptr(unsafe.Pointer(value)))
  300. }
  301. func IoctlSetTermios(fd int, req uint, value *Termios) error {
  302. return ioctl(fd, req, uintptr(unsafe.Pointer(value)))
  303. }
  304. // IoctlGetInt performs an ioctl operation which gets an integer value
  305. // from fd, using the specified request number.
  306. func IoctlGetInt(fd int, req uint) (int, error) {
  307. var value int
  308. err := ioctl(fd, req, uintptr(unsafe.Pointer(&value)))
  309. return value, err
  310. }
  311. func IoctlGetWinsize(fd int, req uint) (*Winsize, error) {
  312. var value Winsize
  313. err := ioctl(fd, req, uintptr(unsafe.Pointer(&value)))
  314. return &value, err
  315. }
  316. func IoctlGetTermios(fd int, req uint) (*Termios, error) {
  317. var value Termios
  318. err := ioctl(fd, req, uintptr(unsafe.Pointer(&value)))
  319. return &value, err
  320. }
  321. // fcntl must never be called with cmd=F_DUP2FD because it doesn't work on AIX
  322. // There is no way to create a custom fcntl and to keep //sys fcntl easily,
  323. // Therefore, the programmer must call dup2 instead of fcntl in this case.
  324. // FcntlInt performs a fcntl syscall on fd with the provided command and argument.
  325. //sys FcntlInt(fd uintptr, cmd int, arg int) (r int,err error) = fcntl
  326. // FcntlFlock performs a fcntl syscall for the F_GETLK, F_SETLK or F_SETLKW command.
  327. //sys FcntlFlock(fd uintptr, cmd int, lk *Flock_t) (err error) = fcntl
  328. func Flock(fd int, how int) (err error) {
  329. return syscall.Flock(fd, how)
  330. }
  331. /*
  332. * Direct access
  333. */
  334. //sys Acct(path string) (err error)
  335. //sys Chdir(path string) (err error)
  336. //sys Chroot(path string) (err error)
  337. //sys Close(fd int) (err error)
  338. //sys Dup(oldfd int) (fd int, err error)
  339. //sys Dup3(oldfd int, newfd int, flags int) (err error)
  340. //sys Exit(code int)
  341. //sys Faccessat(dirfd int, path string, mode uint32, flags int) (err error)
  342. //sys Fallocate(fd int, mode uint32, off int64, len int64) (err error)
  343. //sys Fchdir(fd int) (err error)
  344. //sys Fchmod(fd int, mode uint32) (err error)
  345. //sys Fchmodat(dirfd int, path string, mode uint32, flags int) (err error)
  346. //sys Fchownat(dirfd int, path string, uid int, gid int, flags int) (err error)
  347. //sys fcntl(fd int, cmd int, arg int) (val int, err error)
  348. //sys Fdatasync(fd int) (err error)
  349. //sys Fsync(fd int) (err error)
  350. // readdir_r
  351. //sysnb Getpgid(pid int) (pgid int, err error)
  352. //sys Getpgrp() (pid int)
  353. //sysnb Getpid() (pid int)
  354. //sysnb Getppid() (ppid int)
  355. //sys Getpriority(which int, who int) (prio int, err error)
  356. //sysnb Getrusage(who int, rusage *Rusage) (err error)
  357. //sysnb Getsid(pid int) (sid int, err error)
  358. //sysnb Kill(pid int, sig syscall.Signal) (err error)
  359. //sys Klogctl(typ int, buf []byte) (n int, err error) = syslog
  360. //sys Mkdirat(dirfd int, path string, mode uint32) (err error)
  361. //sys Mkfifo(path string, mode uint32) (err error)
  362. //sys Mknodat(dirfd int, path string, mode uint32, dev int) (err error)
  363. //sys Nanosleep(time *Timespec, leftover *Timespec) (err error)
  364. //sys Open(path string, mode int, perm uint32) (fd int, err error) = open64
  365. //sys Openat(dirfd int, path string, flags int, mode uint32) (fd int, err error)
  366. //sys read(fd int, p []byte) (n int, err error)
  367. //sys Readlink(path string, buf []byte) (n int, err error)
  368. //sys Removexattr(path string, attr string) (err error)
  369. //sys Renameat(olddirfd int, oldpath string, newdirfd int, newpath string) (err error)
  370. //sys Setdomainname(p []byte) (err error)
  371. //sys Sethostname(p []byte) (err error)
  372. //sysnb Setpgid(pid int, pgid int) (err error)
  373. //sysnb Setsid() (pid int, err error)
  374. //sysnb Settimeofday(tv *Timeval) (err error)
  375. //sys Setuid(uid int) (err error)
  376. //sys Setgid(uid int) (err error)
  377. //sys Setpriority(which int, who int, prio int) (err error)
  378. //sys Statx(dirfd int, path string, flags int, mask int, stat *Statx_t) (err error)
  379. //sys Sync()
  380. //sys Tee(rfd int, wfd int, len int, flags int) (n int64, err error)
  381. //sysnb Times(tms *Tms) (ticks uintptr, err error)
  382. //sysnb Umask(mask int) (oldmask int)
  383. //sysnb Uname(buf *Utsname) (err error)
  384. //TODO umount
  385. // //sys Unmount(target string, flags int) (err error) = umount
  386. //sys Unlink(path string) (err error)
  387. //sys Unlinkat(dirfd int, path string, flags int) (err error)
  388. //sys Unshare(flags int) (err error)
  389. //sys Ustat(dev int, ubuf *Ustat_t) (err error)
  390. //sys write(fd int, p []byte) (n int, err error)
  391. //sys readlen(fd int, p *byte, np int) (n int, err error) = read
  392. //sys writelen(fd int, p *byte, np int) (n int, err error) = write
  393. //sys Dup2(oldfd int, newfd int) (err error)
  394. //sys Fadvise(fd int, offset int64, length int64, advice int) (err error) = posix_fadvise64
  395. //sys Fchown(fd int, uid int, gid int) (err error)
  396. //sys Fstat(fd int, stat *Stat_t) (err error)
  397. //sys Fstatat(dirfd int, path string, stat *Stat_t, flags int) (err error) = fstatat
  398. //sys Fstatfs(fd int, buf *Statfs_t) (err error)
  399. //sys Ftruncate(fd int, length int64) (err error)
  400. //sysnb Getegid() (egid int)
  401. //sysnb Geteuid() (euid int)
  402. //sysnb Getgid() (gid int)
  403. //sysnb Getuid() (uid int)
  404. //sys Lchown(path string, uid int, gid int) (err error)
  405. //sys Listen(s int, n int) (err error)
  406. //sys Lstat(path string, stat *Stat_t) (err error)
  407. //sys Pause() (err error)
  408. //sys Pread(fd int, p []byte, offset int64) (n int, err error) = pread64
  409. //sys Pwrite(fd int, p []byte, offset int64) (n int, err error) = pwrite64
  410. //TODO Select
  411. // //sys Select(nfd int, r *FdSet, w *FdSet, e *FdSet, timeout *Timeval) (n int, err error)
  412. //sys Pselect(nfd int, r *FdSet, w *FdSet, e *FdSet, timeout *Timespec, sigmask *Sigset_t) (n int, err error)
  413. //sysnb Setregid(rgid int, egid int) (err error)
  414. //sysnb Setreuid(ruid int, euid int) (err error)
  415. //sys Shutdown(fd int, how int) (err error)
  416. //sys Splice(rfd int, roff *int64, wfd int, woff *int64, len int, flags int) (n int64, err error)
  417. //sys Stat(path string, stat *Stat_t) (err error)
  418. //sys Statfs(path string, buf *Statfs_t) (err error)
  419. //sys Truncate(path string, length int64) (err error)
  420. //sys bind(s int, addr unsafe.Pointer, addrlen _Socklen) (err error)
  421. //sys connect(s int, addr unsafe.Pointer, addrlen _Socklen) (err error)
  422. //sysnb getgroups(n int, list *_Gid_t) (nn int, err error)
  423. //sysnb setgroups(n int, list *_Gid_t) (err error)
  424. //sys getsockopt(s int, level int, name int, val unsafe.Pointer, vallen *_Socklen) (err error)
  425. //sys setsockopt(s int, level int, name int, val unsafe.Pointer, vallen uintptr) (err error)
  426. //sysnb socket(domain int, typ int, proto int) (fd int, err error)
  427. //sysnb socketpair(domain int, typ int, proto int, fd *[2]int32) (err error)
  428. //sysnb getpeername(fd int, rsa *RawSockaddrAny, addrlen *_Socklen) (err error)
  429. //sysnb getsockname(fd int, rsa *RawSockaddrAny, addrlen *_Socklen) (err error)
  430. //sys recvfrom(fd int, p []byte, flags int, from *RawSockaddrAny, fromlen *_Socklen) (n int, err error)
  431. //sys sendto(s int, buf []byte, flags int, to unsafe.Pointer, addrlen _Socklen) (err error)
  432. //sys recvmsg(s int, msg *Msghdr, flags int) (n int, err error)
  433. //sys sendmsg(s int, msg *Msghdr, flags int) (n int, err error)
  434. //sys munmap(addr uintptr, length uintptr) (err error)
  435. var mapper = &mmapper{
  436. active: make(map[*byte][]byte),
  437. mmap: mmap,
  438. munmap: munmap,
  439. }
  440. func Mmap(fd int, offset int64, length int, prot int, flags int) (data []byte, err error) {
  441. return mapper.Mmap(fd, offset, length, prot, flags)
  442. }
  443. func Munmap(b []byte) (err error) {
  444. return mapper.Munmap(b)
  445. }
  446. //sys Madvise(b []byte, advice int) (err error)
  447. //sys Mprotect(b []byte, prot int) (err error)
  448. //sys Mlock(b []byte) (err error)
  449. //sys Mlockall(flags int) (err error)
  450. //sys Msync(b []byte, flags int) (err error)
  451. //sys Munlock(b []byte) (err error)
  452. //sys Munlockall() (err error)
  453. //sysnb pipe(p *[2]_C_int) (err error)
  454. func Pipe(p []int) (err error) {
  455. if len(p) != 2 {
  456. return EINVAL
  457. }
  458. var pp [2]_C_int
  459. err = pipe(&pp)
  460. p[0] = int(pp[0])
  461. p[1] = int(pp[1])
  462. return
  463. }
  464. //sysnb pipe2(p *[2]_C_int, flags int) (err error)
  465. func Pipe2(p []int, flags int) (err error) {
  466. if len(p) != 2 {
  467. return EINVAL
  468. }
  469. var pp [2]_C_int
  470. err = pipe2(&pp, flags)
  471. p[0] = int(pp[0])
  472. p[1] = int(pp[1])
  473. return
  474. }
  475. //sys poll(fds *PollFd, nfds int, timeout int) (n int, err error)
  476. func Poll(fds []PollFd, timeout int) (n int, err error) {
  477. if len(fds) == 0 {
  478. return poll(nil, 0, timeout)
  479. }
  480. return poll(&fds[0], len(fds), timeout)
  481. }
  482. //sys gettimeofday(tv *Timeval, tzp *Timezone) (err error)
  483. //sysnb Time(t *Time_t) (tt Time_t, err error)
  484. //sys Utime(path string, buf *Utimbuf) (err error)