mirrors/Astral
1
0
Fork 0
mirror of https://github.com/Mathewnd/Astral.git synced 2026-11-01 23:18:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

socketpair: support flags

Browse Source
This commit is contained in:
Matheus
2026-04-23 12:09:55 -03:00
parent d46ee0f4ec
commit 8b41077128
1 changed files with 19 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kernel-src/sys/syscalls/socketpair.c
+19 -5
View File
@@ -1,12 +1,26 @@
#include <kernel/syscalls.h> #include <kernel/syscalls.h>
#include <kernel/sock.h> #include <kernel/sock.h>
#define SOCK_CLOEXEC 0x80000
#define SOCK_NONBLOCK 0x800
syscallret_t syscall_socketpair(context_t *, int domain, int type, int protocol) { syscallret_t syscall_socketpair(context_t *, int domain, int type, int protocol) {
syscallret_t ret = { syscallret_t ret = {
.ret = -1 .ret = -1
}; };
// TODO flags could be OR in with type bool non_blocking = false, close_exec = false;
if (type & SOCK_NONBLOCK) {
non_blocking = true;
type &= ~SOCK_NONBLOCK;
}
if (type & SOCK_CLOEXEC) {
close_exec = true;
type &= ~SOCK_CLOEXEC;
}
// we will only support pairs of local sockets // we will only support pairs of local sockets
if (domain != AF_LOCAL || type != SOCK_STREAM) { if (domain != AF_LOCAL || type != SOCK_STREAM) {
ret.errno = EOPNOTSUPP; ret.errno = EOPNOTSUPP;
@@ -36,21 +50,21 @@ syscallret_t syscall_socketpair(context_t *, int domain, int type, int protocol)
goto error; goto error;
// create fds // create fds
ret.errno = fd_new(0, &file1, &fd1); ret.errno = fd_new(close_exec ? O_CLOEXEC : 0, &file1, &fd1);
if (ret.errno) if (ret.errno)
goto error; goto error;
file1->vnode = node1; file1->vnode = node1;
file1->flags = FILE_WRITE | FILE_READ; file1->flags = FILE_WRITE | FILE_READ | (non_blocking ? O_NONBLOCK : 0);
file1->offset = 0; file1->offset = 0;
file1->mode = 0777; file1->mode = 0777;
ret.errno = fd_new(0, &file2, &fd2); ret.errno = fd_new(close_exec ? O_CLOEXEC : 0, &file2, &fd2);
if (ret.errno) if (ret.errno)
goto error; goto error;
file2->vnode = node2; file2->vnode = node2;
file2->flags = FILE_WRITE | FILE_READ; file2->flags = FILE_WRITE | FILE_READ | (non_blocking ? O_NONBLOCK : 0);
file2->offset = 0; file2->offset = 0;
file2->mode = 0777; file2->mode = 0777;