Bugfix de documentación.

[z.facultad/75.74/practicos.git] / practicas / practica2 / P02e1201.cpp

diff --git a/practicas/practica2/P02e1201.cpp b/practicas/practica2/P02e1201.cpp
index 24e3f6329a09698fa12fd4f71a553a2d5cc8aa3a..c730202c2f63e8beb04bd04fd7209bd2bb9afc6c 100644 (file)
--- a/practicas/practica2/P02e1201.cpp
+++ b/practicas/practica2/P02e1201.cpp
@@ -1,8 +1,8 @@
 /**
  * Leandro Lucarella (77891)
  *
 /**
  * Leandro Lucarella (77891)
  *

- * Ejercicio 1.1. Implementa problema del museo usando solamente variables
- * (shared memory)
+ * Ejercicio 1.2. Implementa problema del museo usando variables (shared memory)
+ * y semaforos.

  */
 
 #include <iostream>
  */
 
 #include <iostream>


@@ -21,109 +21,124 @@
 /// Ahora el contador es un simple unsigned
 typedef unsigned Molinete;
 
 /// Ahora el contador es un simple unsigned
 typedef unsigned Molinete;
 

-/// Union para utilizar semaforo
-union semun
+/// Hace un wait (P) al semaforo (devuelve false si hubo error).
+void sem_wait(int sem_id)

 {
 {

-       int val;
-       struct semid_ds* buf;
-       unsigned short* array;
-};
+    struct sembuf op;
+    op.sem_op = -1; // sacar 1
+    op.sem_num = 0; // al semaforo 1
+    op.sem_flg = 0; // esperando
+    if (semop(sem_id, &op, 1) < 0)
+    {
+        std::cerr << "No se pudo sacar al semaforo.\n";
+        exit(100);
+    }
+}
+
+/// Hace un signal (V) al semaforo (devuelve false si hubo error).
+void sem_signal(int sem_id)
+{
+    struct sembuf op;
+    op.sem_op =  1; // agregar 1
+    op.sem_num = 0; // al semaforo 1
+    op.sem_flg = 0; // esperando
+    if (semop(sem_id, &op, 1) < 0)
+    {
+        std::cerr << "No se pudo poner en el semaforo.\n";
+        exit(101);
+    }
+}

 
 int main(int argc, char *argv[])
 {
 
 int main(int argc, char *argv[])
 {

-       using std::cerr;
-       using std::cout;
-
-       if (argc < 2)
-       {
-               cerr << "Faltan parametros: " << argv[0] << " N [max_iter]\n";
-               return 1;
-       }
-       int proc = atoi(argv[1]);
-
-       // Shared memory
-       int shm_id = shmget(SHM_KEY, sizeof(Molinete), IPC_CREAT | 0666);
-       if (shm_id == -1)
-       {
-               cerr << "Error al crea/obtener shared memory.\n";
-               return 2;
-       }
-       Molinete* molinete = (Molinete*) shmat(shm_id, NULL, 0);
-       if (molinete == (Molinete*) -1)
-       {
-               cerr << "Error al attachear shared memory.\n";
-               return 3;
-       }
-       cout << "Shared memory id = " << shm_id << "\n";
-
-       // Semaforo
-       int sem_id = semget(SEM_KEY, 1, 0666 | IPC_CREAT);
-       if (sem_id == -1)
-       {
-               cerr << "Error al crea/obtener semaforo.\n";
-               return 4;
-       }
-       semun sem_arg;
-       sem_arg.val = 0;
-       if (semctl(sem_id, 0, SETVAL, sem_arg) < 0)
-       {
-               cerr << "No se pudo inicializar semaforo.\n";
-               return 5;
-       }
-       struct sembuf ops; 
-       ops.sem_op = 1; // agregar 1
-       ops.sem_num = 0; // al semaforo 1
-       ops.sem_flg = 0; // esperando
-       if (semop(sem_id, &ops, 1) < 0)
-       {
-               cerr << "No se pudo agregar al semaforo.\n";
-               return 6;
-       }
-       cout << "Semaforo inicializado id = " << sem_id << "\n";
-
-       // Si somos el primer proceso inicializamos el molinete
-       if (!proc) *molinete = 0;
-
-       // Maxima cantidad de iteraciones (puede venir por parametro)
-       int max_iter = 100000;
-       if (argc > 2)
-               max_iter = atoi(argv[2]);
-
-       // Loop principal
-       for (int i = 0; i < max_iter; ++i)
-       {
-               bool dec = rand() % 2;
-               int count;
-               // lock
-               ops.sem_op = -1; // saco 1 (== adquirir el mutex)
-               if (semop(sem_id, &ops, 1) < 0)
-               {
-                       cerr << "No se pudo sacar al semaforo.\n";
-                       return 6;
-               }
-               if (dec && molinete) // Decremento sólo si no es 0
-                       count = --*molinete;
-               else
-                       count = ++*molinete;
-               // unlock
-               ops.sem_op = 1; // pongo 1 (== liberar el mutex)
-               if (semop(sem_id, &ops, 1) < 0)
-               {
-                       cerr << "No se pudo sacar al semaforo.\n";
-                       return 6;
-               }
-               // Uso cout directamente porque es line-buffered, mientras que
-               // no use threads no es problema el buffer de cout. Y de todas
-               // formas pongo un flush (el endl es \n+flush) por las dudas.
-               cout << "Proceso " << proc << ": molinete = " << count << std::endl;
-               //sched_yield(); // Para ver como se entrelazan mejor
-       }
-
-       if (shmdt(molinete) == -1)
-       {
-               cerr << "Error al detachear shared memory.\n";
-               return -1;
-       }
-
-       return 0;
+    using std::cerr;
+    using std::cout;
+
+    if (argc < 2)
+    {
+        cerr << "Faltan parametros: " << argv[0] << " N [max_iter]\n";
+        return 1;
+    }
+    int proc = atoi(argv[1]);
+
+    // Shared memory
+    int shm_id;
+    do
+    {
+        shm_id = shmget(SHM_KEY, sizeof(Molinete),
+            (proc ? 0 : IPC_CREAT) | 0666); // crea solo si es el proceso 0
+    }
+    while (proc != 0 && shm_id == -1);
+    Molinete* molinete = (Molinete*) shmat(shm_id, NULL, 0);
+    if (molinete == (Molinete*) -1)
+    {
+        cerr << "Error al attachear shared memory.\n";
+        return 3;
+    }
+
+    // Semaforo
+    int sem_id;
+    do
+    {
+        sem_id = semget(SEM_KEY, 1,
+            (proc ? 0 : IPC_CREAT) | 0666); // crea solo si es el proceso 0
+    }
+    while (proc != 0 && sem_id == -1);
+
+    // Si es el primero, inicializo
+    if (proc == 0)
+    {
+        *molinete = 0;
+        if (semctl(sem_id, 0, SETVAL, 1) < 0) // pongo 1 en el sem
+        {
+            cerr << "No se pudo inicializar semaforo.\n";
+            return 5;
+        }
+        cout << "Semaforo inicializado id = " << sem_id << "\n";
+    }
+
+    srand(getpid());
+
+    // Maxima cantidad de iteraciones (puede venir por parametro)
+    int max_iter = 100;
+    if (argc > 2)
+        max_iter = atoi(argv[2]);
+
+    // Loop principal
+    for (int i = 0; i < max_iter; ++i)
+    {
+        char sdec[] = "sale";
+        char sinc[] = "entra";
+        char* s;
+        bool dec = rand() % 2;
+        int count;
+        sem_wait(sem_id); // lock
+        if (dec && *molinete) // Decremento sólo si no es 0
+        {
+            s = sdec;
+            count = --*molinete;
+        }
+        else
+        {
+            s = sinc;
+            count = ++*molinete;
+        }
+        sem_signal(sem_id); // unlock
+        // Uso cout directamente porque es line-buffered, mientras que
+        // no use threads no es problema el buffer de cout. Y de todas
+        // formas pongo un flush (el endl es \n+flush) por las dudas.
+        cout << "Proceso " << proc << " (" << s << "): molinete = " << count
+                << std::endl;
+        sched_yield(); // Para ver como se entrelazan mejor
+    }
+
+    if (shmdt(molinete) == -1)
+    {
+        cerr << "Error al detachear shared memory.\n";
+        return -1;
+    }
+
+    return 0;

 }
 }

+
+// vim: set et sw=4 sts=4 :