cubefs

1
// Copyright 2021 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
//go:build linux && ppc
6
// +build linux,ppc
7

8
package unix
9

10
import (
11
	"syscall"
12
	"unsafe"
13
)
14

15
//sys	EpollWait(epfd int, events []EpollEvent, msec int) (n int, err error)
16
//sys	Fchown(fd int, uid int, gid int) (err error)
17
//sys	Fstat(fd int, stat *Stat_t) (err error) = SYS_FSTAT64
18
//sys	Fstatat(dirfd int, path string, stat *Stat_t, flags int) (err error) = SYS_FSTATAT64
19
//sys	Ftruncate(fd int, length int64) (err error) = SYS_FTRUNCATE64
20
//sysnb	Getegid() (egid int)
21
//sysnb	Geteuid() (euid int)
22
//sysnb	Getgid() (gid int)
23
//sysnb	Getuid() (uid int)
24
//sys	Ioperm(from int, num int, on int) (err error)
25
//sys	Iopl(level int) (err error)
26
//sys	Lchown(path string, uid int, gid int) (err error)
27
//sys	Listen(s int, n int) (err error)
28
//sys	Lstat(path string, stat *Stat_t) (err error) = SYS_LSTAT64
29
//sys	Pause() (err error)
30
//sys	pread(fd int, p []byte, offset int64) (n int, err error) = SYS_PREAD64
31
//sys	pwrite(fd int, p []byte, offset int64) (n int, err error) = SYS_PWRITE64
32
//sys	Renameat(olddirfd int, oldpath string, newdirfd int, newpath string) (err error)
33
//sys	Select(nfd int, r *FdSet, w *FdSet, e *FdSet, timeout *Timeval) (n int, err error) = SYS__NEWSELECT
34
//sys	sendfile(outfd int, infd int, offset *int64, count int) (written int, err error) = SYS_SENDFILE64
35
//sys	setfsgid(gid int) (prev int, err error)
36
//sys	setfsuid(uid int) (prev int, err error)
37
//sys	Shutdown(fd int, how int) (err error)
38
//sys	Splice(rfd int, roff *int64, wfd int, woff *int64, len int, flags int) (n int, err error)
39
//sys	Stat(path string, stat *Stat_t) (err error) = SYS_STAT64
40
//sys	Truncate(path string, length int64) (err error) = SYS_TRUNCATE64
41
//sys	Ustat(dev int, ubuf *Ustat_t) (err error)
42
//sys	accept4(s int, rsa *RawSockaddrAny, addrlen *_Socklen, flags int) (fd int, err error)
43
//sys	bind(s int, addr unsafe.Pointer, addrlen _Socklen) (err error)
44
//sys	connect(s int, addr unsafe.Pointer, addrlen _Socklen) (err error)
45
//sysnb	getgroups(n int, list *_Gid_t) (nn int, err error)
46
//sysnb	setgroups(n int, list *_Gid_t) (err error)
47
//sys	getsockopt(s int, level int, name int, val unsafe.Pointer, vallen *_Socklen) (err error)
48
//sys	setsockopt(s int, level int, name int, val unsafe.Pointer, vallen uintptr) (err error)
49
//sysnb	socket(domain int, typ int, proto int) (fd int, err error)
50
//sysnb	socketpair(domain int, typ int, proto int, fd *[2]int32) (err error)
51
//sysnb	getpeername(fd int, rsa *RawSockaddrAny, addrlen *_Socklen) (err error)
52
//sysnb	getsockname(fd int, rsa *RawSockaddrAny, addrlen *_Socklen) (err error)
53
//sys	recvfrom(fd int, p []byte, flags int, from *RawSockaddrAny, fromlen *_Socklen) (n int, err error)
54
//sys	sendto(s int, buf []byte, flags int, to unsafe.Pointer, addrlen _Socklen) (err error)
55
//sys	recvmsg(s int, msg *Msghdr, flags int) (n int, err error)
56
//sys	sendmsg(s int, msg *Msghdr, flags int) (n int, err error)
57

58
//sys	futimesat(dirfd int, path string, times *[2]Timeval) (err error)
59
//sysnb	Gettimeofday(tv *Timeval) (err error)
60
//sysnb	Time(t *Time_t) (tt Time_t, err error)
61
//sys	Utime(path string, buf *Utimbuf) (err error)
62
//sys	utimes(path string, times *[2]Timeval) (err error)
63

64
func Fadvise(fd int, offset int64, length int64, advice int) (err error) {
65
	_, _, e1 := Syscall6(SYS_FADVISE64_64, uintptr(fd), uintptr(advice), uintptr(offset>>32), uintptr(offset), uintptr(length>>32), uintptr(length))
66
	if e1 != 0 {
67
		err = errnoErr(e1)
68
	}
69
	return
70
}
71

72
func seek(fd int, offset int64, whence int) (int64, syscall.Errno) {
73
	var newoffset int64
74
	offsetLow := uint32(offset & 0xffffffff)
75
	offsetHigh := uint32((offset >> 32) & 0xffffffff)
76
	_, _, err := Syscall6(SYS__LLSEEK, uintptr(fd), uintptr(offsetHigh), uintptr(offsetLow), uintptr(unsafe.Pointer(&newoffset)), uintptr(whence), 0)
77
	return newoffset, err
78
}
79

80
func Seek(fd int, offset int64, whence int) (newoffset int64, err error) {
81
	newoffset, errno := seek(fd, offset, whence)
82
	if errno != 0 {
83
		return 0, errno
84
	}
85
	return newoffset, nil
86
}
87

88
func Fstatfs(fd int, buf *Statfs_t) (err error) {
89
	_, _, e := Syscall(SYS_FSTATFS64, uintptr(fd), unsafe.Sizeof(*buf), uintptr(unsafe.Pointer(buf)))
90
	if e != 0 {
91
		err = e
92
	}
93
	return
94
}
95

96
func Statfs(path string, buf *Statfs_t) (err error) {
97
	pathp, err := BytePtrFromString(path)
98
	if err != nil {
99
		return err
100
	}
101
	_, _, e := Syscall(SYS_STATFS64, uintptr(unsafe.Pointer(pathp)), unsafe.Sizeof(*buf), uintptr(unsafe.Pointer(buf)))
102
	if e != 0 {
103
		err = e
104
	}
105
	return
106
}
107

108
//sys	mmap2(addr uintptr, length uintptr, prot int, flags int, fd int, pageOffset uintptr) (xaddr uintptr, err error)
109

110
func mmap(addr uintptr, length uintptr, prot int, flags int, fd int, offset int64) (xaddr uintptr, err error) {
111
	page := uintptr(offset / 4096)
112
	if offset != int64(page)*4096 {
113
		return 0, EINVAL
114
	}
115
	return mmap2(addr, length, prot, flags, fd, page)
116
}
117

118
func setTimespec(sec, nsec int64) Timespec {
119
	return Timespec{Sec: int32(sec), Nsec: int32(nsec)}
120
}
121

122
func setTimeval(sec, usec int64) Timeval {
123
	return Timeval{Sec: int32(sec), Usec: int32(usec)}
124
}
125

126
type rlimit32 struct {
127
	Cur uint32
128
	Max uint32
129
}
130

131
//sysnb	getrlimit(resource int, rlim *rlimit32) (err error) = SYS_UGETRLIMIT
132

133
const rlimInf32 = ^uint32(0)
134
const rlimInf64 = ^uint64(0)
135

136
func Getrlimit(resource int, rlim *Rlimit) (err error) {
137
	err = Prlimit(0, resource, nil, rlim)
138
	if err != ENOSYS {
139
		return err
140
	}
141

142
	rl := rlimit32{}
143
	err = getrlimit(resource, &rl)
144
	if err != nil {
145
		return
146
	}
147

148
	if rl.Cur == rlimInf32 {
149
		rlim.Cur = rlimInf64
150
	} else {
151
		rlim.Cur = uint64(rl.Cur)
152
	}
153

154
	if rl.Max == rlimInf32 {
155
		rlim.Max = rlimInf64
156
	} else {
157
		rlim.Max = uint64(rl.Max)
158
	}
159
	return
160
}
161

162
func (r *PtraceRegs) PC() uint32 { return r.Nip }
163

164
func (r *PtraceRegs) SetPC(pc uint32) { r.Nip = pc }
165

166
func (iov *Iovec) SetLen(length int) {
167
	iov.Len = uint32(length)
168
}
169

170
func (msghdr *Msghdr) SetControllen(length int) {
171
	msghdr.Controllen = uint32(length)
172
}
173

174
func (msghdr *Msghdr) SetIovlen(length int) {
175
	msghdr.Iovlen = uint32(length)
176
}
177

178
func (cmsg *Cmsghdr) SetLen(length int) {
179
	cmsg.Len = uint32(length)
180
}
181

182
func (rsa *RawSockaddrNFCLLCP) SetServiceNameLen(length int) {
183
	rsa.Service_name_len = uint32(length)
184
}
185

186
//sys	syncFileRange2(fd int, flags int, off int64, n int64) (err error) = SYS_SYNC_FILE_RANGE2
187

188
func SyncFileRange(fd int, off int64, n int64, flags int) error {
189
	// The sync_file_range and sync_file_range2 syscalls differ only in the
190
	// order of their arguments.
191
	return syncFileRange2(fd, flags, off, n)
192
}
193

194
//sys	kexecFileLoad(kernelFd int, initrdFd int, cmdlineLen int, cmdline string, flags int) (err error)
195

196
func KexecFileLoad(kernelFd int, initrdFd int, cmdline string, flags int) error {
197
	cmdlineLen := len(cmdline)
198
	if cmdlineLen > 0 {
199
		// Account for the additional NULL byte added by
200
		// BytePtrFromString in kexecFileLoad. The kexec_file_load
201
		// syscall expects a NULL-terminated string.
202
		cmdlineLen++
203
	}
204
	return kexecFileLoad(kernelFd, initrdFd, cmdlineLen, cmdline, flags)
205
}
206