2020-06-15 14:18:57 +00:00
|
|
|
#ifndef COSMOPOLITAN_LIBC_SOCK_INTERNAL_H_
|
|
|
|
|
#define COSMOPOLITAN_LIBC_SOCK_INTERNAL_H_
|
2022-08-13 20:11:56 +00:00
|
|
|
#include "libc/calls/struct/iovec.h"
|
2023-05-14 16:32:15 +00:00
|
|
|
#include "libc/calls/struct/sigset.h"
|
2022-04-15 06:39:48 +00:00
|
|
|
#include "libc/nt/struct/overlapped.h"
|
2021-02-06 07:45:34 +00:00
|
|
|
#include "libc/nt/thunk/msabi.h"
|
2020-06-15 14:18:57 +00:00
|
|
|
#include "libc/nt/winsock.h"
|
2020-11-28 20:01:51 +00:00
|
|
|
#include "libc/sock/select.h"
|
2020-06-15 14:18:57 +00:00
|
|
|
#include "libc/sock/sock.h"
|
2022-08-13 20:11:56 +00:00
|
|
|
#include "libc/sock/struct/sockaddr.h"
|
2020-06-15 14:18:57 +00:00
|
|
|
#if !(__ASSEMBLER__ + __LINKER__ + 0)
|
|
|
|
|
COSMOPOLITAN_C_START_
|
|
|
|
|
|
Support non-blocking i/o across platforms
This change introduces new tests for `O_NONBLOCK` and `SOCK_NONBLOCK` to
confirm that non-blocking i/o is now working on all supported platforms,
including Windows. For example, you can now say on Windows, MacOS, etc.:
socket(AF_INET, SOCK_STREAM | SOCK_NONBLOCK, IPPROTO_TCP);
To create a non-blocking IPv4 TCP socket. Or you can enable non-blocking
i/o on an existing socket / pipe / etc. file descriptor by calling fcntl
fcntl(fd, F_SETFL, fcntl(fd, F_GETFL) | O_NONBLOCK);
This functionality is polyfilled on older Linux kernels too, e.g. RHEL5.
Now that fcntl() support is much better the FIOCLEX / FIONCLEX polyfills
for ioctl() have been removed since they're ugly non-POSIX diameond APIs
This change fixes a weakness in kprintf() that was causing Windows trace
tools to frequently crash.
2023-07-23 09:56:47 +00:00
|
|
|
#define kNtFdRead 1
|
|
|
|
|
#define kNtFdWrite 2
|
|
|
|
|
#define kNtFdOob 4
|
|
|
|
|
#define kNtFdAccept 8
|
|
|
|
|
#define kNtFdConnect 16
|
|
|
|
|
#define kNtFdClose 32
|
|
|
|
|
#define kNtFdQos 64
|
|
|
|
|
#define kNtFdGroupQos 128
|
|
|
|
|
#define kNtFdRoutingInterfaceChange 256
|
|
|
|
|
#define kNtFdAddressListChange 512
|
2020-06-15 14:18:57 +00:00
|
|
|
|
2021-06-24 17:53:27 +00:00
|
|
|
/* ------------------------------------------------------------------------------------*/
|
|
|
|
|
|
2022-04-15 06:39:48 +00:00
|
|
|
#define SOCKFD_OVERLAP_BUFSIZ 128
|
|
|
|
|
|
2023-07-24 15:31:54 +00:00
|
|
|
errno_t __dos2errno(uint32_t);
|
2020-11-28 20:01:51 +00:00
|
|
|
|
2023-09-06 10:54:42 +00:00
|
|
|
int32_t __sys_accept(int32_t, void *, uint32_t *, int) __wur;
|
|
|
|
|
int32_t __sys_accept4(int32_t, void *, uint32_t *, int) __wur;
|
2023-07-24 15:31:54 +00:00
|
|
|
int32_t __sys_bind(int32_t, const void *, uint32_t);
|
|
|
|
|
int32_t __sys_connect(int32_t, const void *, uint32_t);
|
|
|
|
|
int32_t __sys_getpeername(int32_t, void *, uint32_t *);
|
|
|
|
|
int32_t __sys_getsockname(int32_t, void *, uint32_t *);
|
|
|
|
|
int32_t __sys_socket(int32_t, int32_t, int32_t);
|
|
|
|
|
int32_t __sys_socketpair(int32_t, int32_t, int32_t, int32_t[2]);
|
2020-06-15 14:18:57 +00:00
|
|
|
|
2023-09-06 10:54:42 +00:00
|
|
|
int32_t sys_accept4(int32_t, struct sockaddr_storage *, int) __wur;
|
2023-07-24 15:31:54 +00:00
|
|
|
int32_t sys_bind(int32_t, const void *, uint32_t);
|
|
|
|
|
int32_t sys_connect(int32_t, const void *, uint32_t);
|
|
|
|
|
int32_t sys_getsockopt(int32_t, int32_t, int32_t, void *, uint32_t *);
|
|
|
|
|
int32_t sys_listen(int32_t, int32_t);
|
|
|
|
|
int32_t sys_getsockname(int32_t, void *, uint32_t *);
|
|
|
|
|
int32_t sys_getpeername(int32_t, void *, uint32_t *);
|
|
|
|
|
int32_t sys_shutdown(int32_t, int32_t);
|
|
|
|
|
int32_t sys_socket(int32_t, int32_t, int32_t);
|
|
|
|
|
int32_t sys_socketpair(int32_t, int32_t, int32_t, int32_t[2]);
|
|
|
|
|
ssize_t sys_recvfrom(int, void *, size_t, int, void *, uint32_t *);
|
|
|
|
|
ssize_t sys_sendto(int, const void *, size_t, int, const void *, uint32_t);
|
|
|
|
|
int32_t sys_select(int32_t, fd_set *, fd_set *, fd_set *, struct timeval *);
|
2022-08-16 02:52:00 +00:00
|
|
|
int sys_pselect(int, fd_set *, fd_set *, fd_set *, struct timespec *,
|
2023-07-24 15:31:54 +00:00
|
|
|
const void *);
|
|
|
|
|
int sys_setsockopt(int, int, int, const void *, uint32_t);
|
|
|
|
|
int32_t sys_epoll_create(int32_t);
|
|
|
|
|
int32_t sys_epoll_ctl(int32_t, int32_t, int32_t, void *);
|
|
|
|
|
int32_t sys_epoll_wait(int32_t, void *, int32_t, int32_t);
|
2023-05-14 16:32:15 +00:00
|
|
|
int32_t sys_epoll_pwait(int32_t, void *, int32_t, int32_t, const sigset_t *,
|
|
|
|
|
size_t);
|
2020-06-15 14:18:57 +00:00
|
|
|
|
2023-07-24 15:31:54 +00:00
|
|
|
int sys_socket_nt(int, int, int);
|
2022-08-13 20:11:56 +00:00
|
|
|
|
2021-03-17 05:05:59 +00:00
|
|
|
/*
|
2023-07-24 15:31:54 +00:00
|
|
|
int sys_socketpair_nt_stream(int, int, int, int[2]) ;
|
|
|
|
|
int sys_socketpair_nt_dgram(int, int, int, int[2]) ;
|
2021-03-17 05:05:59 +00:00
|
|
|
*/
|
2023-07-24 15:31:54 +00:00
|
|
|
int sys_socketpair_nt(int, int, int, int[2]);
|
2022-08-15 22:18:37 +00:00
|
|
|
int sys_select_nt(int, fd_set *, fd_set *, fd_set *, struct timeval *,
|
2023-07-24 15:31:54 +00:00
|
|
|
const sigset_t *);
|
2020-06-15 14:18:57 +00:00
|
|
|
|
2023-07-24 15:31:54 +00:00
|
|
|
size_t __iovec2nt(struct NtIovec[hasatleast 16], const struct iovec *, size_t);
|
2020-06-15 14:18:57 +00:00
|
|
|
|
Make improvements
- We now serialize the file descriptor table when spawning / executing
processes on Windows. This means you can now inherit more stuff than
just standard i/o. It's needed by bash, which duplicates the console
to file descriptor #255. We also now do a better job serializing the
environment variables, so you're less likely to encounter E2BIG when
using your bash shell. We also no longer coerce environ to uppercase
- execve() on Windows now remotely controls its parent process to make
them spawn a replacement for itself. Then it'll be able to terminate
immediately once the spawn succeeds, without having to linger around
for the lifetime as a shell process for proxying the exit code. When
process worker thread running in the parent sees the child die, it's
given a handle to the new child, to replace it in the process table.
- execve() and posix_spawn() on Windows will now provide CreateProcess
an explicit handle list. This allows us to remove handle locks which
enables better fork/spawn concurrency, with seriously correct thread
safety. Other codebases like Go use the same technique. On the other
hand fork() still favors the conventional WIN32 inheritence approach
which can be a little bit messy, but is *controlled* by guaranteeing
perfectly clean slates at both the spawning and execution boundaries
- sigset_t is now 64 bits. Having it be 128 bits was a mistake because
there's no reason to use that and it's only supported by FreeBSD. By
using the system word size, signal mask manipulation on Windows goes
very fast. Furthermore @asyncsignalsafe funcs have been rewritten on
Windows to take advantage of signal masking, now that it's much more
pleasant to use.
- All the overlapped i/o code on Windows has been rewritten for pretty
good signal and cancelation safety. We're now able to ensure overlap
data structures are cleaned up so long as you don't longjmp() out of
out of a signal handler that interrupted an i/o operation. Latencies
are also improved thanks to the removal of lots of "busy wait" code.
Waits should be optimal for everything except poll(), which shall be
the last and final demon we slay in the win32 i/o horror show.
- getrusage() on Windows is now able to report RUSAGE_CHILDREN as well
as RUSAGE_SELF, thanks to aggregation in the process manager thread.
2023-10-08 12:36:18 +00:00
|
|
|
ssize_t __winsock_block(int64_t, uint32_t, bool, uint32_t, uint64_t,
|
|
|
|
|
int (*)(int64_t, struct NtOverlapped *, uint32_t *,
|
|
|
|
|
void *),
|
|
|
|
|
void *);
|
|
|
|
|
|
2023-07-24 15:31:54 +00:00
|
|
|
void WinSockInit(void);
|
2023-07-30 11:26:34 +00:00
|
|
|
int64_t __winsockerr(void);
|
2023-07-24 15:31:54 +00:00
|
|
|
int __fixupnewsockfd(int, int);
|
|
|
|
|
int64_t GetNtBaseSocket(int64_t);
|
|
|
|
|
int sys_close_epoll(int);
|
2020-11-28 20:01:51 +00:00
|
|
|
|
2020-06-15 14:18:57 +00:00
|
|
|
COSMOPOLITAN_C_END_
|
|
|
|
|
#endif /* !(__ASSEMBLER__ + __LINKER__ + 0) */
|
|
|
|
|
#endif /* COSMOPOLITAN_LIBC_SOCK_INTERNAL_H_ */
|
