diff options
Diffstat (limited to 'Year_2/OS/auction-house.c')
| -rw-r--r-- | Year_2/OS/auction-house.c | 259 |
1 files changed, 259 insertions, 0 deletions
diff --git a/Year_2/OS/auction-house.c b/Year_2/OS/auction-house.c new file mode 100644 index 0000000..770f2ca --- /dev/null +++ b/Year_2/OS/auction-house.c @@ -0,0 +1,259 @@ +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <sys/ipc.h> +#include <sys/sem.h> +#include <sys/shm.h> +#include <sys/types.h> +#include <time.h> +#include <unistd.h> +#include <wait.h> + +int +WAIT(int id_sem, int n) +{ + struct sembuf sops[1] = { { n, -1, 0 } }; + return semop(id_sem, sops, 1); +} + +int +SIGNAL(int id_sem, int n) +{ + struct sembuf sops[1] = { { n, 1, 0 } }; + return semop(id_sem, sops, 1); +} + +void +judge(int id_sem, int id_shm, char* auctionfile, int n_bidders) +{ + FILE* f; + char buffer[1024]; + char ch; + int i; + int counter; + char* token; + char ob_de[1024]; + int off_min; + int off_max; + char* msg; + int value; + int bid; + + int rel_valid; + int rel_max; + int rel_winner; + + int abs_valid; + int total; + + rel_valid = abs_valid = total = 0; + + if ((f = fopen(auctionfile, "r")) == NULL) { + perror("fopen"); + exit(1); + } + + if ((msg = (char*)shmat(id_shm, NULL, 0)) == (char*)-1) { + perror("shmat"); + exit(1); + } + + i = 0; + counter = 1; + while ((ch = fgetc(f)) != EOF) { + buffer[i++] = ch; + if (ch == '\n') { + rel_valid = 0; + rel_max = rel_winner = -1; + buffer[i - 1] = '\0'; + + /* Parse the string */ + token = strtok(buffer, ","); + strcpy(ob_de, token); + + token = strtok(NULL, ","); + off_min = atoi(token); + + token = strtok(NULL, ","); + off_max = atoi(token); + + WAIT(id_sem, 0); + sprintf(msg, "%s,%d,%d,%d", ob_de, counter, off_min, off_max); + printf("J: lancio asta n.%d per %s con offerta minima di %d EUR e massima di %d EUR\n", + counter, ob_de, off_min, off_max); + SIGNAL(id_sem, 1); + for (i = 0; i < n_bidders; ++i) { + WAIT(id_sem, 0); + strcpy(buffer, msg); + strtok(buffer, ","); // ob_de + strtok(NULL, ","); // counter + off_min = atoi(strtok(NULL, ",")); + off_max = atoi(strtok(NULL, ",")); + bid = atoi(strtok(NULL, ",")); + value = atoi(strtok(NULL, ",")); + printf("J: ricevuta offerta da B%d\n", bid); + + if (value >= off_min && value <= off_max) { + if (value > rel_max) { + rel_max = value; + rel_winner = bid; + } + + rel_valid++; + } + + if (i == n_bidders - 1) + strcpy(msg, "skip"); + SIGNAL(id_sem, 1); + } + + if (rel_winner != -1) { + printf("J: l'asta n.%d per %s si è conclusa con %d offerte valide su %d; il vincitore è B%d che si aggiudica l'oggetto per %d EUR\n", + counter, ob_de, rel_valid, n_bidders, rel_winner, rel_max); + total += rel_max; + abs_valid++; + } else { + printf("J: l'asta n.%d per %s si è conclusa senza alcuna offerta valida pertanto l'oggetto non risulta assegnato\n", + counter, ob_de); + } + + counter++; + + i = 0; + + printf("\n"); + } + } + + WAIT(id_sem, 0); + strncpy(msg, "", 2); + semctl(id_sem, 1, SETVAL, n_bidders); + + counter--; + printf("J: sono state svolte %d aste di cui %d andate assegnate e %d andate a vuoto; il totale raccolto è di %d EUR\n", + counter, abs_valid, (counter - abs_valid), total); + + fclose(f); +} + +void +bidder(int id_sem, int id_shm, int i, int n) +{ + char* msg; + char ob_de[1024]; + char* token; + int off_min, off_max, counter; + int value; + char buffer[1024]; + + if ((msg = (char*)shmat(id_shm, NULL, 0)) == (char*)-1) { + perror("shmat"); + exit(1); + } + + while (1) { + WAIT(id_sem, 1); + if (strcmp(msg, "") == 0) { + break; + } + if (strcmp(msg, "skip") != 0) { + /* Parse the string */ + strcpy(buffer, msg); + token = strtok(buffer, ","); + strcpy(ob_de, token); + + token = strtok(NULL, ","); + counter = atoi(token); + + token = strtok(NULL, ","); + off_min = atoi(token); + + token = strtok(NULL, ","); + off_max = atoi(token); + + value = rand() % off_max; + + printf("B%d: invio offerta di %d EUR per asta n.%d\n", i, value, counter); + sprintf(msg, "%s,%d,%d,%d,%d,%d", ob_de, counter, off_min, off_max, i, value); + } + SIGNAL(id_sem, 0); + } +} + +int +main(int argc, char* argv[]) +{ + int id_sem; + int id_shm; + pid_t pid_judge; + int n; + pid_t* pid_bidders; + int i; + + srand(time(NULL)); + n = atoi(argv[2]); + if (n < 1) { + fprintf(stderr, "<num-bidders> must be greater than 0\n"); + exit(1); + } + + pid_bidders = malloc(sizeof(pid_t) * n); + + if (argc < 3) { + fprintf(stderr, "Usage: %s <auction-file> <num-bidders>", argv[0]); + exit(1); + } + + if ((id_shm = shmget(IPC_PRIVATE, 2048, IPC_CREAT | IPC_EXCL | 0644)) == -1) { + perror("shmget"); + exit(1); + } + + if ((id_sem = semget(IPC_PRIVATE, 2, IPC_CREAT | IPC_EXCL | 0644)) == -1) { + perror("semget"); + exit(1); + } + + semctl(id_sem, 0, SETVAL, 1); + semctl(id_sem, 1, SETVAL, 0); + + pid_judge = fork(); + if (pid_judge == -1) { + perror("fork"); + exit(1); + } + + if (pid_judge == 0) { + judge(id_sem, id_shm, argv[1], n); + exit(0); + } + + for (i = 0; i < n; ++i) { + pid_bidders[i] = fork(); + if (pid_bidders[i] == -1) { + perror("fork"); + exit(1); + } + + if (pid_bidders[i] == 0) { + bidder(id_sem, id_shm, i + 1, n); + exit(0); + } + } + + for (i = 0; i <= n; ++i) + wait(NULL); // n+1, where 1 is `judge` + + if (shmctl(id_shm, IPC_RMID, NULL) == -1) { + perror("shmctl"); + exit(1); + } + + if (semctl(id_sem, 2, IPC_RMID) == -1) { + perror("semctl"); + exit(1); + } + + free(pid_bidders); + return 0; +} |