1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
|
// Copyright 2020 The Libc Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
//go:build linux || darwin || freebsd
// +build linux darwin freebsd
package libc // import "modernc.org/libc"
import (
"os"
gosignal "os/signal"
"reflect"
"syscall"
"unsafe"
"golang.org/x/sys/unix"
"modernc.org/libc/errno"
"modernc.org/libc/poll"
"modernc.org/libc/signal"
"modernc.org/libc/stdio"
"modernc.org/libc/sys/types"
)
// sighandler_t signal(int signum, sighandler_t handler);
func Xsignal(t *TLS, signum int32, handler uintptr) uintptr { //TODO use sigaction?
signalsMu.Lock()
defer signalsMu.Unlock()
r := signals[signum]
signals[signum] = handler
switch handler {
case signal.SIG_DFL:
panic(todo("%v %#x", syscall.Signal(signum), handler))
case signal.SIG_IGN:
switch r {
case signal.SIG_DFL:
gosignal.Ignore(syscall.Signal(signum)) //TODO
case signal.SIG_IGN:
gosignal.Ignore(syscall.Signal(signum))
default:
panic(todo("%v %#x", syscall.Signal(signum), handler))
}
default:
switch r {
case signal.SIG_DFL:
c := make(chan os.Signal, 1)
gosignal.Notify(c, syscall.Signal(signum))
go func() { //TODO mechanism to stop/cancel
for {
<-c
var f func(*TLS, int32)
*(*uintptr)(unsafe.Pointer(&f)) = handler
tls := NewTLS()
f(tls, signum)
tls.Close()
}
}()
case signal.SIG_IGN:
panic(todo("%v %#x", syscall.Signal(signum), handler))
default:
panic(todo("%v %#x", syscall.Signal(signum), handler))
}
}
return r
}
// void rewind(FILE *stream);
func Xrewind(t *TLS, stream uintptr) {
Xfseek(t, stream, 0, stdio.SEEK_SET)
}
// int putchar(int c);
func Xputchar(t *TLS, c int32) int32 {
if _, err := write([]byte{byte(c)}); err != nil {
return stdio.EOF
}
return int32(c)
}
// int gethostname(char *name, size_t len);
func Xgethostname(t *TLS, name uintptr, slen types.Size_t) int32 {
if slen < 0 {
t.setErrno(errno.EINVAL)
return -1
}
if slen == 0 {
return 0
}
s, err := os.Hostname()
if err != nil {
panic(todo(""))
}
n := len(s)
if len(s) >= int(slen) {
n = int(slen) - 1
}
sh := (*reflect.StringHeader)(unsafe.Pointer(&s))
copy((*RawMem)(unsafe.Pointer(name))[:n:n], (*RawMem)(unsafe.Pointer(sh.Data))[:n:n])
*(*byte)(unsafe.Pointer(name + uintptr(n))) = 0
return 0
}
// int remove(const char *pathname);
func Xremove(t *TLS, pathname uintptr) int32 {
panic(todo(""))
}
// long pathconf(const char *path, int name);
func Xpathconf(t *TLS, path uintptr, name int32) long {
panic(todo(""))
}
// ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);
func Xrecvfrom(t *TLS, sockfd int32, buf uintptr, len types.Size_t, flags int32, src_addr, addrlen uintptr) types.Ssize_t {
panic(todo(""))
}
// ssize_t sendto(int sockfd, const void *buf, size_t len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen);
func Xsendto(t *TLS, sockfd int32, buf uintptr, len types.Size_t, flags int32, src_addr uintptr, addrlen socklen_t) types.Ssize_t {
panic(todo(""))
}
// void srand48(long int seedval);
func Xsrand48(t *TLS, seedval long) {
panic(todo(""))
}
// long int lrand48(void);
func Xlrand48(t *TLS) long {
panic(todo(""))
}
// ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags);
func Xsendmsg(t *TLS, sockfd int32, msg uintptr, flags int32) types.Ssize_t {
panic(todo(""))
}
// int poll(struct pollfd *fds, nfds_t nfds, int timeout);
func Xpoll(t *TLS, fds uintptr, nfds poll.Nfds_t, timeout int32) int32 {
if nfds == 0 {
panic(todo(""))
}
// if dmesgs {
// dmesg("%v: %#x %v %v, %+v", origin(1), fds, nfds, timeout, (*[1000]unix.PollFd)(unsafe.Pointer(fds))[:nfds:nfds])
// }
n, err := unix.Poll((*[1000]unix.PollFd)(unsafe.Pointer(fds))[:nfds:nfds], int(timeout))
// if dmesgs {
// dmesg("%v: %v %v", origin(1), n, err)
// }
if err != nil {
t.setErrno(err)
return -1
}
return int32(n)
}
// ssize_t recvmsg(int sockfd, struct msghdr *msg, int flags);
func Xrecvmsg(t *TLS, sockfd int32, msg uintptr, flags int32) types.Ssize_t {
n, _, err := unix.Syscall(unix.SYS_RECVMSG, uintptr(sockfd), msg, uintptr(flags))
if err != 0 {
t.setErrno(err)
return -1
}
return types.Ssize_t(n)
}
// struct cmsghdr *CMSG_NXTHDR(struct msghdr *msgh, struct cmsghdr *cmsg);
func X__cmsg_nxthdr(t *TLS, msgh, cmsg uintptr) uintptr {
panic(todo(""))
}
// wchar_t *wcschr(const wchar_t *wcs, wchar_t wc);
func Xwcschr(t *TLS, wcs uintptr, wc wchar_t) wchar_t {
panic(todo(""))
}
// gid_t getegid(void);
func Xgetegid(t *TLS) types.Gid_t {
panic(todo(""))
}
// gid_t getgid(void);
func Xgetgid(t *TLS) types.Gid_t {
panic(todo(""))
}
// void *shmat(int shmid, const void *shmaddr, int shmflg);
func Xshmat(t *TLS, shmid int32, shmaddr uintptr, shmflg int32) uintptr {
panic(todo(""))
}
// int shmctl(int shmid, int cmd, struct shmid_ds *buf);
func Xshmctl(t *TLS, shmid, cmd int32, buf uintptr) int32 {
panic(todo(""))
}
// int shmdt(const void *shmaddr);
func Xshmdt(t *TLS, shmaddr uintptr) int32 {
panic(todo(""))
}
// int getresuid(uid_t *ruid, uid_t *euid, uid_t *suid);
func Xgetresuid(t *TLS, ruid, euid, suid uintptr) int32 {
panic(todo(""))
}
// int getresgid(gid_t *rgid, gid_t *egid, gid_t *sgid);
func Xgetresgid(t *TLS, rgid, egid, sgid uintptr) int32 {
panic(todo(""))
}
|
