From 8a9208612eec8ddae4c418485d848ecfa0613699 Mon Sep 17 00:00:00 2001
From: Anton Kling <anton@kling.gg>
Date: Mon, 30 Oct 2023 22:12:14 +0100
Subject: Meta: Move kernel and userland to their own folders.

This is to allow both the kernel and the userland to share certain
header files and to make the folder structure a bit more clear.
---
 socket.c | 180 ---------------------------------------------------------------
 1 file changed, 180 deletions(-)
 delete mode 100644 socket.c

(limited to 'socket.c')

diff --git a/socket.c b/socket.c
deleted file mode 100644
index 0519c65..0000000
--- a/socket.c
+++ /dev/null
@@ -1,180 +0,0 @@
-#include <assert.h>
-#include <errno.h>
-#include <fs/devfs.h>
-#include <fs/tmpfs.h>
-#include <poll.h>
-#include <sched/scheduler.h>
-#include <socket.h>
-
-// FIXME: Make these more dynamic
-OPEN_UNIX_SOCKET *un_sockets[100] = {0};
-OPEN_INET_SOCKET *inet_sockets[100] = {0};
-
-OPEN_INET_SOCKET *find_open_udp_port(uint16_t port) {
-  for (int i = 0; i < 100; i++) {
-    if (!inet_sockets[i])
-      continue;
-    if (inet_sockets[i]->port == port)
-      return inet_sockets[i];
-  }
-  return NULL;
-}
-
-int uds_open(const char *path) {
-  // FIXME: This is super ugly
-
-  // Find the socket that path belongs to
-  SOCKET *s = NULL;
-  for (int i = 0; i < 100; i++) {
-    if (!un_sockets[i])
-      continue;
-    const char *p = path;
-    const char *e = p;
-    for (; *e; e++)
-      ;
-    for (; e != p && *e != '/'; e--)
-      ;
-    if (0 == strcmp(e, un_sockets[i]->path)) {
-      s = un_sockets[i]->s;
-      break;
-    }
-  }
-  if (!s) {
-    return -1;
-  }
-
-  // Create a pipe
-  int fd[2];
-  dual_pipe(fd);
-
-  char c = 'i';
-  fifo_object_write((uint8_t *)&c, 1, 0, s->fifo_file);
-  s->ptr_socket_fd->inode->has_data = 1;
-
-  s->incoming_fd = get_current_task()->file_descriptors[fd[1]];
-  // vfs_close(fd[1]);
-  return fd[0];
-}
-
-int accept(int socket, struct sockaddr *address, socklen_t *address_len) {
-  (void)address;
-  (void)address_len;
-  vfs_inode_t *inode = get_current_task()->file_descriptors[socket]->inode;
-  SOCKET *s = (SOCKET *)inode->internal_object;
-
-  if (NULL == s->incoming_fd) {
-    // Wait until we have gotten a connection
-    struct pollfd fds[1];
-    fds[0].fd = socket;
-    fds[0].events = POLLIN;
-    fds[0].revents = 0;
-    poll(fds, 1, 0);
-  }
-
-  int n = 0;
-  for (; get_current_task()->file_descriptors[n]; n++)
-    ;
-  get_current_task()->file_descriptors[n] = s->incoming_fd;
-  get_current_task()->file_descriptors[n]->reference_count++;
-  s->incoming_fd = NULL;
-  //  for (char c; 0 < vfs_pread(s->fifo_fd, &c, 1, 0);)
-  //    ;
-  inode->has_data = 0;
-  //  s->ptr_fifo_fd->inode->has_data = 0;
-
-  return n;
-}
-
-int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen) {
-  (void)addrlen;
-  vfs_fd_t *fd = get_vfs_fd(sockfd);
-  if (!fd)
-    return -EBADF;
-  vfs_inode_t *inode = fd->inode;
-  if (!inode)
-    return -EBADF;
-  SOCKET *s = (SOCKET *)inode->internal_object;
-  if (AF_UNIX == s->domain) {
-    struct sockaddr_un *un = (struct sockaddr_un *)addr;
-    size_t path_len = strlen(un->sun_path);
-    s->path = kmalloc(path_len + 1);
-    memcpy(s->path, un->sun_path, path_len);
-    s->path[path_len] = '\0';
-
-    OPEN_UNIX_SOCKET *us;
-    int i = 0;
-    for (; i < 100; i++)
-      if (!un_sockets[i])
-        break;
-
-    us = un_sockets[i] = kmalloc(sizeof(OPEN_UNIX_SOCKET));
-
-    us->path = s->path;
-    us->s = s;
-    s->child = us;
-    devfs_add_file(us->path, NULL, NULL, NULL, 1, 1, FS_TYPE_UNIX_SOCKET);
-    return 0;
-  }
-  if (AF_INET == s->domain) {
-    struct sockaddr_in *in = (struct sockaddr_in *)addr;
-    assert(in->sin_family == AF_INET); // FIXME: Figure out error value
-    OPEN_INET_SOCKET *inet;
-    int i = 0;
-    for (; i < 100; i++)
-      if (!inet_sockets[i])
-        break;
-
-    inet = inet_sockets[i] = kmalloc(sizeof(OPEN_INET_SOCKET));
-    inet->address = in->sin_addr.s_addr;
-    inet->port = in->sin_port;
-    inet->s = s;
-    s->child = inet;
-    return 0;
-  }
-  return 0;
-}
-
-int socket_write(uint8_t *buffer, uint64_t offset, uint64_t len, vfs_fd_t *fd) {
-  SOCKET *s = (SOCKET *)fd->inode->internal_object;
-  FIFO_FILE *file = s->fifo_file;
-  int rc = fifo_object_write(buffer, 0, len, file);
-  fd->inode->has_data = file->has_data;
-  return rc;
-}
-
-int socket_read(uint8_t *buffer, uint64_t offset, uint64_t len, vfs_fd_t *fd) {
-  SOCKET *s = (SOCKET *)fd->inode->internal_object;
-  FIFO_FILE *file = s->fifo_file;
-  int rc = fifo_object_read(buffer, 0, len, file);
-  fd->inode->has_data = file->has_data;
-  return rc;
-}
-
-void socket_close(vfs_fd_t *fd) { fd->inode->is_open = 0; }
-
-int socket(int domain, int type, int protocol) {
-  if (!(AF_UNIX == domain || AF_INET == domain))
-    return -EINVAL;
-
-  SOCKET *new_socket = kmalloc_eternal(sizeof(SOCKET));
-  vfs_inode_t *inode = vfs_create_inode(
-      0 /*inode_num*/, FS_TYPE_UNIX_SOCKET, 0 /*has_data*/, 1 /*can_write*/,
-      1 /*is_open*/, new_socket /*internal_object*/, 0 /*file_size*/,
-      NULL /*open*/, NULL /*create_file*/, socket_read, socket_write,
-      socket_close, NULL /*create_directory*/, NULL /*get_vm_object*/,
-      NULL /*truncate*/);
-
-  vfs_fd_t *fd;
-  int n = vfs_create_fd(O_RDWR | O_NONBLOCK, 0, inode, &fd);
-
-  new_socket->domain = domain;
-  new_socket->type = type;
-  new_socket->protocol = protocol;
-  new_socket->path = NULL;
-  new_socket->incoming_fd = NULL;
-
-  new_socket->fifo_file = create_fifo_object();
-
-  new_socket->ptr_socket_fd = fd;
-  return n;
-}
-- 
cgit v1.2.3