mira/thesis
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

playing around a bit

Browse source
This commit is contained in:
twoneis 2025-02-27 20:09:14 +01:00
parent 58a4f4761f
commit 3503de83da
33 changed files with 1317 additions and 906 deletions
paper/artifacts/include
pipe_buffer.h

79
paper/artifacts/include/pipe_buffer.h
View file

@ -1,56 +1,63 @@
#pragma once
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>
#include <stdint.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <sys/msg.h>
void alloc_pipes(int *pipefd, int flags)
#include <fcntl.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
void
alloc_pipes(int *pipefd, int flags)
{
int ret = pipe2(pipefd, flags);
if (ret < 0) {
perror("pipe2");
exit(-1);
}
int ret = pipe2(pipefd, flags);
if (ret < 0) {
perror("pipe2");
exit(-1);
}
}
void write_pipe(int fd, char *buf, size_t sz)
void
write_pipe(int fd, char *buf, size_t sz)
{
int ret = write(fd, buf, sz);
if (ret < 0) {
perror("write(pipes)");
exit(-1);
}
int ret = write(fd, buf, sz);
if (ret < 0) {
perror("write(pipes)");
exit(-1);
}
}
void resize_pipe(int fd, size_t nr_slots)
void
resize_pipe(int fd, size_t nr_slots)
{
int ret = fcntl(fd, F_SETPIPE_SZ, nr_slots << 12);
if (ret < 0) {
perror("fcntl(fd, F_SETPIPE_SZ, nr_slots << 12)");
exit(-1);
}
int ret = fcntl(fd, F_SETPIPE_SZ, nr_slots << 12);
if (ret < 0) {
perror("fcntl(fd, F_SETPIPE_SZ, nr_slots << 12)");
exit(-1);
}
}
int write_pipe_no_err(int fd, char *buf, size_t sz)
int
write_pipe_no_err(int fd, char *buf, size_t sz)
{
int ret = write(fd, buf, sz);
return ret;
int ret = write(fd, buf, sz);
return ret;
}
void read_pipe(int fd, char *buf, size_t sz)
void
read_pipe(int fd, char *buf, size_t sz)
{
int ret = read(fd, buf, sz);
if (ret < 0) {
perror("read(pipes)");
exit(-1);
}
int ret = read(fd, buf, sz);
if (ret < 0) {
perror("read(pipes)");
exit(-1);
}
}
int read_pipe_no_err(int fd, char *buf, size_t sz)
int
read_pipe_no_err(int fd, char *buf, size_t sz)
{
int ret = read(fd, buf, sz);
return ret;
}
int ret = read(fd, buf, sz);
return ret;
}