diff options
Diffstat (limited to 'socket.c')
| -rw-r--r-- | socket.c | 180 |
1 files changed, 0 insertions, 180 deletions
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; -} |