aboutsummaryrefslogtreecommitdiff
path: root/sync/sync.c
diff options
context:
space:
mode:
Diffstat (limited to 'sync/sync.c')
-rw-r--r--sync/sync.c118
1 files changed, 0 insertions, 118 deletions
diff --git a/sync/sync.c b/sync/sync.c
deleted file mode 100644
index 23d6ba1..0000000
--- a/sync/sync.c
+++ /dev/null
@@ -1,118 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <sys/ipc.h>
-#include <sys/sem.h>
-#include <sys/shm.h>
-#include <sys/types.h>
-#include <sys/wait.h>
-#include <unistd.h>
-
-#define NSEM 3
-
-union semun {
- int val;
- struct semid_ds *buf;
- ushort *array;
-};
-
-
-int shmid, semid;
-
-void quit(signum)
-int signum;
-{
- shmctl(shmid, IPC_RMID, NULL);
- semctl(semid, IPC_RMID, 0);
-}
-
-
-int main(argc, argv)
-int argc;
-char **argv;
-{
- int i, pid, n_read, n_write, w;
- char *mem, **arg_r, **arg_w;
- union semun semarg;
-
- if (argc < 2) {
- printf("usage: sync [number readers] [number writers]\n");
- exit(1);
- }
- n_read = atoi(argv[1]);
- n_write = atoi(argv[2]);
-
- if ((shmid = shmget(52, 1<<14, IPC_CREAT | 0666)) == -1){
- perror("shmget: shmget failed");
- exit(1);
- }
-
- if ((mem = shmat(shmid, NULL, 0)) == (char *) -1) {
- perror("shmat");
- exit(1);
- }
-printf("Sshmid: %x\n", shmid);
- signal(SIGQUIT, quit);
-
- for (i = 0; i < 1<<14; i++) {
- *(mem + i) = 0x30;
- }
-
- if ((semid = semget(shmid, NSEM, 0666 | IPC_CREAT)) == -1) {
- perror("Ssemget: ");
- exit(1);
- }
-
- semarg.val = 1;
- for (i = 0; i < NSEM; i++) {
- if ((semctl(semid, i, SETVAL, semarg)) == -1) {
- perror("semctl: ");
- exit(1);
- }
- }
-
-
- arg_r = malloc(sizeof(char*) * 3);
- arg_w = malloc(sizeof(char*) * 3);
- *arg_r = malloc(sizeof(char) * 10);
- *arg_w = malloc(sizeof(char) * 10);
-
- *(arg_r + 1) = malloc(sizeof(char) * 50);
- *(arg_w + 1) = malloc(sizeof(char) * 50);
-
- *arg_r = "reader";
- *arg_w = "writer";
-
- *(arg_r + 2) = NULL;
- *(arg_w + 2) = NULL;
-
- for (i = 0; i < n_read; i++){
- sprintf(*(arg_r + 1), "%d", i);
- if (pid = fork()) {
- /* printf("starting reader %d...\n", i); */
- } else {
- int ret = execv("./reader", arg_r);
- printf("exec retern %d", ret);
- }
- }
-
- for (i = 0; i < n_write; i++) {
- sprintf(*(arg_w + 1), "%d", i);
- if (pid = fork()) {
- /* printf("starting writer %d...\n", i); */
- } else {
- execvp("./writer", arg_w);
- }
-
- }
-
- shmdt(mem);
-printf("sync done...\n");
-/* TODO
- * why is this returning 8
- */
- for (i = 0; i < (n_write + n_read); i++) {
- wait(&w);
- printf("\nReturned with code:%d\n", WEXITSTATUS(w));
- }
- quit();
-}