abclinuxu.cz AbcLinuxu.cz itbiz.cz ITBiz.cz HDmag.cz HDmag.cz abcprace.cz AbcPráce.cz
AbcLinuxu hledá autory!
Inzerujte na AbcPráce.cz od 950 Kč
Rozšířené hledání
×

dnes 11:30 | Komunita

Etherpad (Wikipedie), svobodný online webový textový editor umožnující spolupráci v reálném čase, se stal oficiálním projektem organizace Software Freedom Conservancy (Wikipedie). Vývojáři Etherpadu se tak mohou stejně jako vývojáři dalších projektů soustředit pouze na vývoj softwaru a vše kolem zařídí Software Freedom Conservancy. Spuštěna byla instance Etherpadu pad.sfconservancy.org.

Ladislav Hagara | Komentářů: 1
dnes 10:40 | Zajímavý článek

Lukáš Růžička se v článku Workrave ve Fedoře aneb jak si nevytunelovat karpál na MojeFedora.cz věnuje aplikaci Workrave (Wikipedie) na sledování času stráveného na počítači, která může pomoci vyhnout se negativním účinkům práce s počítačem (RSI, CTS), nebo je alespoň výrazně zmírnit.

Ladislav Hagara | Komentářů: 1
dnes 10:00 | Komunita

Na Humble Bundle lze získat počítačovou hru Shadow Warrior: Special Edition běžící také v Linuxu zdarma. Speciální akce končí v sobotu v 19:00.

Ladislav Hagara | Komentářů: 1
včera 23:11 | Nová verze

Byla vydána verze 2.4.0 analyzátoru síťového provozu Wireshark. Jedná se o první stabilní verzi nové řady 2.4. Podrobný přehled novinek v poznámkách k vydání. V červnu proběhla konference SharkFest’17 US věnovaná Wiresharku. Záznamy přednášek jsou k dispozici na YouTube.

Ladislav Hagara | Komentářů: 0
včera 13:11 | Pozvánky

Spolek OpenAlt zve příznivce otevřeného přístupu na 142. brněnský sraz, který proběhne v pátek 21. července od 18:00 hodin ve Sport Centru Srbská (Srbská 4). Od 19:00 je pro zájemce zamluveno hřiště na plážový volejbal.

Ladislav Hagara | Komentářů: 0
včera 12:34 | Bezpečnostní upozornění

V GNOME Soubory, původně Nautilus, konkrétně v generování náhledů exe, msi, dll a lnk souborů byla nalezena a opravena bezpečnostní chyba CVE-2017-11421 s názvem Bad Taste. Při otevření složky obsahující tyto soubory může být spuštěn VBScript obsažen v názvech těchto souborů.

Ladislav Hagara | Komentářů: 2
včera 11:00 | Bezpečnostní upozornění

Společnost Oracle vydala čtvrtletní bezpečnostní aktualizaci svých softwarových produktů (CPU, Critical Patch Update). Opraveno bylo celkově 308 bezpečnostních chyb. V Oracle Java SE je například opraveno 32 bezpečnostních chyb. Vzdáleně zneužitelných bez autentizace je 28 z nich. V Oracle MySQL je opraveno 30 bezpečnostních chyb. Vzdáleně zneužitelných bez autentizace je 9 z nich.

Ladislav Hagara | Komentářů: 0
včera 01:00 | Komunita

Mark Krenz, známý svým twitterovým účtem @climagic (Command Line Magic), kde ukazuje, co vše a jak lze dělat v příkazovém řádku, přednášel včera v Praze. Záznam přednášky je k dispozici na YouTube.

Ladislav Hagara | Komentářů: 1
19.7. 10:00 | Nová verze

Microsoft vydal Skype pro Linux ve verzi 5.4 Beta. Nejnovější Skype pro Linux je postaven na frameworku Electron 1.7.4 a přináší skupinové videohovory.

Ladislav Hagara | Komentářů: 11
19.7. 06:00 | Nová verze

Werner Koch, zakladatel a hlavní vývojář GnuPG, oznámil vydání verze 1.8.0 svobodné kryptografické knihovny Libgcrypt. Jedná se o první stabilní verzi nové řady 1.8. Ta je API i ABI kompatibilní s řadou 1.7. Z novinek vývojáři zdůrazňují podporu kryptografických hašovacích funkcí Blake2 (Wikpedie), šifrovací mód XTS nebo zvýšení výkonu na architektuře ARM.

Ladislav Hagara | Komentářů: 0
Chystáte se pořídit CPU AMD Ryzen?
 (7%)
 (31%)
 (1%)
 (10%)
 (43%)
 (8%)
Celkem 1031 hlasů
 Komentářů: 65, poslední 1.6. 19:16
    Rozcestník

    Dotaz: Prace se soubory

    24.4.2010 14:29 Rogue | skóre: 4
    Prace se soubory
    Přečteno: 734×
    Dobrý den, potřeboval bych od Vás prosím poradit s následujícím problémem:

    Vytvořil jsem si program, který praceje se semafory a sdílenou pamětí, ve kterém mám funkci, čítající jednotlivé akce. Kritická sekce vypadá následovně:
      //*****KS*****
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count ++;
      fprintf(soubor, "%d\n", sharedStuff->count);
      //*****KS*****
    
    V této Kricické Sekci se provádí inkrementaci čítače akcí procesu (count), a výsledek by měl bý pak zapsán do souboru. Problém je v tom, že když do kritické sekce přistoupí procesA, který například vykoná 2 akce, pak procesB, který například vykoná také 2 akce, tak výstup v souboru by měl být například:
    Cislo akce 1 procesA
    Cislo akce 2 procesA
    Cislo akce 3 procesB
    Cislo akce 4 procesB
    
    A v mém souboru je například:
    Cislo akce 1 procesA
    Cislo akce 1 procesA
    Cislo akce 3 procesB
    Cislo akce 4 procesB
    
    Prosím poraďte jak odstranit tento jev, předem děkuji za vaše odpovědi.


    Řešení dotazu:


    Odpovědi

    Fuky avatar 24.4.2010 15:03 Fuky | skóre: 52 | blog: 4u
    Rozbalit Rozbalit vše Re: Prace se soubory
    Přilož celý kód, na kterém to testuješ.
    24.4.2010 15:11 Rogue | skóre: 4
    Rozbalit Rozbalit vše Re: Prace se soubory
    COUNTER je normalni struktura
    Práce se semafory je Ok. 
    Práce s procesy je taky Ok myslím že je zbytečné to sem kopírovat.
    Když je funkce processedEvent zavolána cyklicky nastane problém popsaný víše.
    
    
    
    int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff,)
    {
      int retCode = 0;
      void *sharedMemory = (void *) 0;
      // Zpristupneni sdilene pameti programu
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        return -1;
      }
      // Zablokovani semaforu
      retCode = sem_wait(semId);
      if (retCode == -1)
      {
        return -1;
      }
      //*****KS*****
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count ++;
      fprintf(soubor, "%d\n", sharedStuff->count);
      //*****KS*****
      // Odblokovani semaforu
      retCode = sem_post(semId);
      if (retCode == -1)
      {
        return -1;
      }
      // Zavreni semaforu
      retCode = sem_close(semId);
      if (retCode == -1)
      {
        return -1;
      }
      // Odpojeni sdilene pameti
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        return -1;
      }
      return 0;
    }
    
    Fuky avatar 24.4.2010 16:09 Fuky | skóre: 52 | blog: 4u
    Rozbalit Rozbalit vše Re: Prace se soubory

    Práce se semafory je Ok. Práce s procesy je taky Ok myslím že je zbytečné to sem kopírovat.

    Kdyby to bylo OK, tak ti to funguje. Poskytováním neúplných informací moc rychlému řešení neprospěješ, naopak plno lidí se na to nepodívá, protože nemá čas z tebe tahat informace po kousíčkách.

    Bavíš se tady o proceses, ale používáš semafory určené pro synchronizaci vláken. Jak voláš fci sem_init()? Nezkoumal jsem jak je to nyní, ale dříve Linux podporoval pouze pshared = 0 tj. zamykání vláken v rámci jednoho procesu, ale nepodporoval nenulovou hodnotu pro synchronizaci různých procesů. Takže se pro meziprocesovou synchronizaci používaly semafory převzaté z System V IPC a ostatně odtud pochází i tebou použitá fce shmat(). Příklad:

    static void
    set_semvalue(
        int semid,
        int num)
    {
        union semun sem_union;
    
        sem_union.val = 1;
    
        if (semctl(semid, num, SETVAL, sem_union) == -1) {
            syslog(LOG_ERR, "Failed to initialize semaphore %i\n", semid);
            exit(EXIT_FAILURE);
        }
    }
    
    static void
    del_semvalue(
        int semid,
        int num)
    {
        union semun sem_union;
    
        if (semctl(semid, num, IPC_RMID, sem_union) == -1) {
            syslog(LOG_ERR, "Failed to delete semaphore\n");
        }
    }
    
    void
    lock(
        int semid,
        int num)
    {
        struct sembuf sem_b;
    
        sem_b.sem_num = num;
        sem_b.sem_op = -1;
        sem_b.sem_flg = SEM_UNDO;
    
        if (semop(semid, &sem_b, 1) == -1) {
            syslog(LOG_ERR, "semaphore_p failed\n");
            exit(EXIT_FAILURE);
        }
    }
    
    void
    unlock(
        int semid,
        int num)
    {
        struct sembuf sem_b;
    
        sem_b.sem_num = num;
        sem_b.sem_op = 1;
        sem_b.sem_flg = SEM_UNDO;
    
        if (semop(semid, &sem_b, 1) == -1) {
            syslog(LOG_ERR, "semaphore_v failed\n");
            exit(EXIT_FAILURE);
        }
    }
    
    24.4.2010 16:26 Rogue | skóre: 4
    Rozbalit Rozbalit vše Re: Prace se soubory
    Ok tak pro úplnost:
    typedef struct counter
    {
      int count; 
    } COUNTER;
    
    int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff)
    {
      int retCode = 0;
      void *sharedMemory = (void *) 0;
      // Zpristupneni sdilene pameti programu
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        return -1;
      }
      // Zablokovani semaforu
      retCode = sem_wait(semId);
      if (retCode == -1)
      {
        return -1;
      }
      //*****KS*****
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count ++;
      fprintf(soubor, "%d"\n", sharedStuff->count;
      //*****KS*****
      // Odblokovani semaforu
      retCode = sem_post(semId);
      if (retCode == -1)
      {
        return -1;
      }
      // Zavreni semaforu
      retCode = sem_close(semId);
      if (retCode == -1)
      {
        return -1;
      }
      // Odpojeni sdilene pameti
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        return -1;
      }
      return 0;
    }
    
    int main()
    { 
      pid_t pid;
      sem_t *semIdA;
      
      int retCode = 0;
      int shmid = 0;
      int i = 0;
      int stepsNumber = 0;
      void *sharedMemory = (void *) 0;
      struct counter *sharedStuff;
    
      // Prace se souborem
      FILE *fw;
      fw = fopen("soubor.txt", "w");
      if (fw == NULL)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni sdilene pameti;
      shmid = shmget((key_t)jmeno, N *sizeof(int), 0666 | IPC_CREAT);
      if (shmid == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Zpristupneni sdilene pameti programu;
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count=0;
      printf("Pocet: %d\n", sharedStuff->count);
      
      // Odpojeni sdilene pameti;
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni semaforu;
      semIdA = sem_open(SEM_NAMEa, O_CREAT, 0666, 0);
      if (semIdA == SEM_FAILED)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Odemknuti semaforu;
      retCode = sem_post(semIdA);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni podprocesu;
      for (; i<2; i++)
      {
        pid = fork();
        switch (pid)
        {
          case -1:
    	// Uvolneni prostredku;
    	fprintf(stderr, "Failed...\n");
            exit(EXIT_FAILURE);
    	break;
          case 0:
    	while (stepsNumber != 0)
    	{
    	  processedEvent(semIdA, fw, shmid, sharedStuff, i);
    	  stepsNumber--;
    	}
    	// Uzavreni souboru
    	retCode = fclose(fw);
    	if (retCode == EOF)
    	{
    	  fprintf(stderr, "Failed...\n");
    	  exit(EXIT_FAILURE);
    	}
    	exit(EXIT_SUCCESS);
    	break;
          default:
    	children[i] = pid;
    	break;
        }
      } 
      }
      // Zavreni semaforu;
      retCode = sem_close(semIdA);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Uvolneni porstredku semaforu;
      retCode = sem_unlink(SEM_NAMEa);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Zpristupneni sdilene pameti programu;
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }  
      // Odpojeni sdilene pameti;
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Smazani sdilene pameti;
      retCode = shmctl(shmid, IPC_RMID, 0);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      } 
      
      exit(EXIT_SUCCESS);
    }
    
    Fuky avatar 24.4.2010 18:28 Fuky | skóre: 52 | blog: 4u
    Rozbalit Rozbalit vše Re: Prace se soubory

    Nejsem si tím naprosto jistý, ale myslím, že adresu semaforu vytvořeného pomocí sem_open() nelze sdílet mezi více procesy. Podle mě by bylo korektní řešení nejprve provést fork() a teprve poté volat sem_open() na stejný soubor tj. získá se přístup ke stejnému semaforu. A ne získat přístup k semaforu a poté ho využívat ve více procesech.

    Případně můžeš semafor vytvořit pomocí sem_init(p_sem, pshared=1, value=1) a uložit jeho adresu přímo do struktury, kterou sdílíš. Máš ho pak k dispozici rovnou a nemusíš ho předávat jako argument fce. Navíc slouží k zamykání právě této struktury, tak mi přijde výhodné, aby byl její součástí.

    Jinak volat za sem_open() dekrementaci semaforu sem_post() je zbytečné, stačí využít čtvrtý argument value a nastavit hodnotu semaforu rovnou při jeho vytváření.

    POSIX semaphores and fork() -- when any process exits, they all lose, access

    24.4.2010 19:31 Rogue | skóre: 4
    Rozbalit Rozbalit vše Re: Prace se soubory
    Díky za odpovědi, udělal jsem pár drobných úprav na základě tvého příspěvku, ale pořád se nevyřešil můj původní problém, který jsem uvedl výše.
    24.4.2010 21:29 Sinuhet | skóre: 31
    Rozbalit Rozbalit vše Re: Prace se soubory
    Nemel byste pockat na dobehnuti forknutych potomku pred tim, nez semafor znicite?
    24.4.2010 21:59 Rogue | skóre: 4
    Rozbalit Rozbalit vše Re: Prace se soubory
    Ano rodič na ně samozdřejmě čeká to jsem do toho kodu nenakopíroval. Ale to není až tak důležité zajímá mne především zápis do souboru potřebuji vědět v čem je chyby mám pocit že v ošetření kritické sekce, ale nemám tušení jak to opravit.
    24.4.2010 22:11 Sinuhet | skóre: 31
    Rozbalit Rozbalit vše Re: Prace se soubory

    Mate nejaky zvlastni duvod, proc sem nechcete dat kompletni minimalni zkompilovatelny a spustitelny kod, ktery nefunguje?

    24.4.2010 22:31 Rogue | skóre: 4
    Rozbalit Rozbalit vše Re: Prace se soubory
    Ok tak tady je kompletni minimalni zkompilovatelny kod. Potřebuji poradit jak opravit problém uvedený v prvním příspěvku. Děkuji za Vaš čas a vaše napady.
    #define jmeno 1234
    #define SEM_NAMEa "/mysema"
    typedef struct counter
    {
      int count; 
    } COUNTER;
    
    int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff);
    int main()
    { 
      pid_t pid;
      pid_t children[3];
      sem_t *semIdA;
      
      int retCode = 0;
      int shmid = 0;
      int i = 0;
      int stepsNumber = 0;
      void *sharedMemory = (void *) 0;
      struct counter *sharedStuff;
    
      // Zpracovani parametru programu;
      stepsNumber = 3;
      if (stepsNumber == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      } 
      // Prace se souborem
      FILE *fw;
      fw = fopen("out.txt", "w");
      if (fw == NULL)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni sdilene pameti;
      shmid = shmget((key_t)jmeno, 3 *sizeof(int), 0666 | IPC_CREAT);
      if (shmid == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Zpristupneni sdilene pameti programu;
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count=0;
      printf("Pocet: %d\n", sharedStuff->count);
      
      // Odpojeni sdilene pameti;
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni semaforu;
      semIdA = sem_open(SEM_NAMEa, O_CREAT, 0666, 0);
      if (semIdA == SEM_FAILED)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni podprocesu;
      for (; i<3; i++)
      {
        pid = fork();
        switch (pid)
        {
          case -1:
    	// Uvolneni prostredku;
    	fprintf(stderr, "Failed...\n");
            exit(EXIT_FAILURE);
    	break;
          case 0:
    	while (stepsNumber != 0)
    	{
    	  processedEvent(semIdA, fw, shmid, sharedStuff);
    	  stepsNumber--;
    	}
    	// Uzavreni souboru
    	retCode = fclose(fw);
    	if (retCode == EOF)
    	{
    	  fprintf(stderr, "Failed...\n");
    	  exit(EXIT_FAILURE);
    	}
    	exit(EXIT_SUCCESS);
    	break;
          default:
    	children[i] = pid;
    	break;
        }
      } 
      // Ukonceni potomknu;
      for (i = 0; i<3; i++)
      {
        retCode = waitpid(children[i], NULL, 0);
        if (retCode < 0)
        {
          retCode = kill(children[i], SIGTERM);
          if (retCode == -1)
          {
    	fprintf(stderr, "Failed...\n");
    	exit(EXIT_FAILURE);
          }
        }
      }
      // Zavreni semaforu;
      retCode = sem_close(semIdA);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Uvolneni porstredku semaforu;
      retCode = sem_unlink(SEM_NAMEa);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Zpristupneni sdilene pameti programu;
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      
      printf("Pocet: %d\n", sharedStuff->count);
      
      // Odpojeni sdilene pameti;
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Smazani sdilene pameti;
      retCode = shmctl(shmid, IPC_RMID, 0);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      } 
      
      exit(EXIT_SUCCESS);
    }
    
    int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff)
    {
      int retCode = 0;
      void *sharedMemory = (void *) 0;
      // Zpristupneni sdilene pameti programu
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        return -1;
      }
      // Zablokovani semaforu
      retCode = sem_wait(semId);
      if (retCode == -1)
      {
        return -1;
      }
      //*****KS*****
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count ++;
      fprintf(soubor, "%d\n", sharedStuff->count);
      //*****KS*****
      // Odblokovani semaforu
      retCode = sem_post(semId);
      if (retCode == -1)
      {
        return -1;
      }
      // Zavreni semaforu
      retCode = sem_close(semId);
      if (retCode == -1)
      {
        return -1;
      }
      // Odpojeni sdilene pameti
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        return -1;
      }
      return 0;
    }
    
    24.4.2010 22:34 Rogue | skóre: 4
    Rozbalit Rozbalit vše Re: Prace se soubory

    Tady jsou jeste hlavickove soubory

    #include <stdlib.h>
    #include <stdio.h>
    #include <errno.h>
    #include <unistd.h>
    #include <signal.h>
    #include <semaphore.h>
    #include <fcntl.h>

    #include <sys/types.h>
    #include <sys/wait.h>
    #include <sys/shm.h>
    #include <sys/ipc.h>

    24.4.2010 23:07 Sinuhet | skóre: 31
    Rozbalit Rozbalit vše Re: Prace se soubory

    Todlencto mi funguje.

    #include <stdlib.h>
    #include <stdio.h>
    #include <errno.h>
    #include <unistd.h>
    #include <signal.h>
    #include <semaphore.h>
    #include <fcntl.h>
    
    #include <sys/types.h>
    #include <sys/wait.h>
    #include <sys/shm.h>
    #include <sys/ipc.h>
    
    
    #define jmeno 1234
    #define SEM_NAMEa "/mysema"
    typedef struct counter
    {
      int count; 
    } COUNTER;
    
    int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff);
    int main()
    { 
      pid_t pid;
      pid_t children[3];
      sem_t *semIdA;
      
      int retCode = 0;
      int shmid = 0;
      int i = 0;
      int stepsNumber = 0;
      void *sharedMemory = (void *) 0;
      struct counter *sharedStuff;
    
      // Zpracovani parametru programu;
      stepsNumber = 3;
      if (stepsNumber == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      } 
      // Prace se souborem
      FILE *fw;
      fw = fopen("out.txt", "w");
      if (fw == NULL)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni sdilene pameti;
      shmid = shmget((key_t)jmeno, 3 *sizeof(int), 0666 | IPC_CREAT);
      if (shmid == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Zpristupneni sdilene pameti programu;
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count=0;
      printf("Pocet: %d\n", sharedStuff->count);
      
      // Odpojeni sdilene pameti;
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni semaforu;
      semIdA = sem_open(SEM_NAMEa, O_CREAT, 0666, 0);
      if (semIdA == SEM_FAILED)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Odemknuti semaforu;
      retCode = sem_post(semIdA);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Vytvoreni podprocesu;
      for (; i<3; i++)
      {
        pid = fork();
        switch (pid)
        {
          case -1:
    	// Uvolneni prostredku;
    	fprintf(stderr, "Failed...\n");
            exit(EXIT_FAILURE);
    	break;
          case 0:
    	while (stepsNumber != 0)
    	{
    	  processedEvent(semIdA, fw, shmid, sharedStuff);
    	  stepsNumber--;
    	}
    	// Uzavreni souboru
    	retCode = fclose(fw);
    	if (retCode == EOF)
    	{
    	  fprintf(stderr, "Failed...\n");
    	  exit(EXIT_FAILURE);
    	}
    	  retCode = sem_close(semIdA);
    	  if (retCode == -1)
    	  {
    	    return -1;
    	  }
    	exit(EXIT_SUCCESS);
    	break;
          default:
    	children[i] = pid;
    	break;
        }
      } 
      // Ukonceni potomknu;
      for (i = 0; i<3; i++)
      {
        retCode = waitpid(children[i], NULL, 0);
        if (retCode < 0)
        {
          retCode = kill(children[i], SIGTERM);
          if (retCode == -1)
          {
    	fprintf(stderr, "Failed...\n");
    	exit(EXIT_FAILURE);
          }
        }
      }
      // Zavreni semaforu;
      retCode = sem_close(semIdA);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Uvolneni porstredku semaforu;
      retCode = sem_unlink(SEM_NAMEa);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Zpristupneni sdilene pameti programu;
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      
      printf("Pocet: %d\n", sharedStuff->count);
      
      // Odpojeni sdilene pameti;
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      }
      // Smazani sdilene pameti;
      retCode = shmctl(shmid, IPC_RMID, 0);
      if (retCode == -1)
      {
        fprintf(stderr, "Failed...\n");
        exit(EXIT_FAILURE);
      } 
      
      exit(EXIT_SUCCESS);
    }
    
    int processedEvent(sem_t *semId, FILE* soubor, int shmid, COUNTER *sharedStuff)
    {
      int retCode = 0;
      void *sharedMemory = (void *) 0;
      // Zpristupneni sdilene pameti programu
      sharedMemory = shmat(shmid, (void *) 0, 0);
      if (sharedMemory == (void *) -1)
      {
        return -1;
      }
      // Zablokovani semaforu
      retCode = sem_wait(semId);
      if (retCode == -1)
      {
        return -1;
      }
      //*****KS*****
      sharedStuff = (struct counter *) sharedMemory;
      sharedStuff->count ++;
      fprintf(soubor, "%d\n", sharedStuff->count);
      //*****KS*****
      // Odblokovani semaforu
      retCode = sem_post(semId);
      if (retCode == -1)
      {
        return -1;
      }
      // Zavreni semaforu
    /*  retCode = sem_close(semId);
      if (retCode == -1)
      {
        return -1;
      }
    */
      // Odpojeni sdilene pameti
      retCode = shmdt(sharedMemory);
      if (retCode == -1)
      {
        return -1;
      }
      return 0;
    }
    24.4.2010 23:50 Rogue | skóre: 4
    Rozbalit Rozbalit vše Re: Prace se soubory
    Díky moc. Přesně tohle jsem potřeboval. Musím více trénovat paralelni myšlení. Ještě jednou díky

    Založit nové vláknoNahoru

    Tiskni Sdílej: Linkuj Jaggni to Vybrali.sme.sk Google Del.icio.us Facebook

    ISSN 1214-1267   www.czech-server.cz
    © 1999-2015 Nitemedia s. r. o. Všechna práva vyhrazena.