Klagarge/MSE-CSEL
1
0
Fork 0
Code Activity

feat(lab04): exercise 1

Browse Source
This commit is contained in:
fastium
2026-05-08 15:26:31 +02:00
parent e04bf05b1a
commit 70a07f11bb
5 changed files with 150 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -58,3 +58,4 @@ doc/**/*.pdf
build build
src/03-led-controller/led-controller src/03-led-controller/led-controller
src/04-multiprocessing/multiprocessing

2
src/04-multiprocessing/Makefile
View File

@@ -1,5 +1,5 @@
EXE=multiprocessing EXE=multiprocessing
SRCS=$(wildcard *.c) SRCS=process.c
# Include the standard application Makefile for the CSEL1 labs # Include the standard application Makefile for the CSEL1 labs
include ../appl.mk include ../appl.mk

100
src/04-multiprocessing/main.c
View File

@@ -1,100 +0,0 @@
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <unistd.h>
#include <sys/types.h>
#include <unistd.h>
#include <sys/socket.h>
#include <syslog.h>
#include <string.h>
#include <signal.h>
const char * MSG = "Nique ta mère !!\0";
static void catch_signal(int signal) {
switch (signal) {
case SIGHUP:
printf("SIGHUP received\n");
break;
case SIGINT:
printf("SIGINT received\n");
break;
case SIGQUIT:
printf("SIGQUIT received\n");
break;
case SIGTERM:
printf("SIGTERM received\n");
break;
case SIGABRT:
printf("SIGABRT received\n");
break;
}
}
static void install_catch_signal()
{
struct sigaction act = {
.sa_handler = catch_signal,
};
sigemptyset(&act.sa_mask);
sigaction(SIGHUP, &act, 0);
sigaction(SIGINT, &act, 0);
sigaction(SIGQUIT, &act, 0);
sigaction(SIGTERM, &act, 0);
sigaction(SIGABRT, &act, 0);
}
int main(int argc, char* argv[]) {
install_catch_signal();
/* Setup socket for inter-process communication */
int fd[2];
int err = socketpair(AF_UNIX, SOCK_STREAM, 0, fd);
if (err == -1) {
perror("socketpair fail");
exit(1);
}
/* Fork a child process */
pid_t pid = fork();
if (pid == 0) {
/* Parent processus */
printf("Parent processus: pid=%d\n", pid);
while(1) {
write(fd[0], MSG, strlen(MSG));
sleep(1);
}
} else if (pid > 0) {
/* Child processus */
printf("Child processus: pid=%d\n", pid);
char buffer[strlen(MSG)];
while(1) {
read(fd[1], buffer, strlen(MSG));
printf("%s\n", buffer);
sleep(1);
}
} else {
/* error */
perror("fork fail");
exit(1);
}
return 0;
}

BIN
src/04-multiprocessing/multiprocessing
View File

Binary file not shown.

148
src/04-multiprocessing/process.c Normal file
View File

@@ -0,0 +1,148 @@
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <unistd.h>
#include <sys/wait.h>
#include <signal.h>
#include <sys/types.h>
#include <unistd.h>
#include <sys/socket.h>
#include <syslog.h>
#include <string.h>
#define __USE_GNU // not the define from the professor !!!!!!!!!!!!!!!!!!!!!
#include <sched.h>
#include <sys/resource.h>
const int NBR_MSG = 5;
const char * MSG[] = {
"Hallo, hallo !\0",
"ça geht !\0",
"Comment vont les olives ?\0",
"Sacré trucs tes trucs là.\0",
"Ta où les vaches !!!!!\0"
};
static void catch_signal(int signal) {
switch (signal) {
case SIGHUP:
printf("SIGHUP received\n");
break;
case SIGINT:
printf("SIGINT received\n");
exit(EXIT_SUCCESS);
break;
case SIGQUIT:
printf("SIGQUIT received\n");
break;
case SIGTERM:
printf("SIGTERM received\n");
break;
case SIGABRT:
printf("SIGABRT received\n");
break;
}
}
static void install_catch_signal()
{
struct sigaction act = {
.sa_handler = catch_signal,
};
sigemptyset(&act.sa_mask);
sigaction(SIGHUP, &act, 0);
sigaction(SIGINT, &act, 0);
sigaction(SIGQUIT, &act, 0);
sigaction(SIGTERM, &act, 0);
sigaction(SIGABRT, &act, 0);
}
int main(int argc, char* argv[]) {
install_catch_signal();
/* Setup socket for inter-process communication */
int fd[2];
int err = socketpair(AF_UNIX, SOCK_STREAM, 0, fd);
if (err == -1) {
perror("socketpair fail");
exit(1);
}
/* Fork a child process */
pid_t pid = fork();
if (pid == 0) {
cpu_set_t set;
CPU_ZERO(&set);
CPU_SET(0, &set);
int ret = sched_setaffinity(pid, sizeof(set), &set);
if (ret == -1) {
perror("sched_setaffinity");
exit(1);
}
/* Parent processus */
printf("Parent processus: pid=%d\n", pid);
pid_t child_pid = getpid();
char buffer[100];
for (int i = 0; i < 7; i++) {
read(fd[1], buffer, strlen(MSG[i]));
printf("%s\n", buffer);
memset(buffer, 0, sizeof(buffer));
}
int status = 0;
int waited_pid = waitpid(pid, &status, 0);
if (waited_pid == -1) {
perror("waitpid");
} else {
if (WIFEXITED(status)) {
printf("Child exited with status %d\n",
WEXITSTATUS(status));
} else if (WIFSIGNALED(status)) {
printf("Child killed by signal %d\n",
WTERMSIG(status));
}
}
} else if (pid > 0) {
cpu_set_t set;
CPU_ZERO(&set);
CPU_SET(1, &set);
int ret = sched_setaffinity(pid, sizeof(set), &set);
if (ret == -1) {
perror("sched_setaffinity");
exit(1);
}
/* Child processus */
printf("Child processus: pid=%d\n", pid);
for (int i = 0; i < NBR_MSG; i++) {
if(i==2) sleep(2);
write(fd[0], MSG[i], strlen(MSG[i]));
}
exit(EXIT_SUCCESS);
} else {
/* error */
perror("fork fail");
exit(EXIT_FAILURE);
}
/* Test signal handling */
kill(getpid(), SIGHUP);
kill(getpid(), SIGQUIT);
kill(getpid(), SIGTERM);
kill(getpid(), SIGABRT);
kill(getpid(), SIGINT);
return 0;
}