Linux за българи: Форуми

Здравейте! Опитвам се да съставя програма, която създава два процеса: единият чете, другият извежда. Проблемът е, че  увисва още при започване. Ето го кодът, ако някой може да ми каже какъв е проблема:

GeSHi (C):
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
struct point {
  int ID;
  char* text;
  int lock;
  int readed;
}*p;
 
extern getmem(int memory);
extern testandset(int *lock);
 
char *messages[] = {
  "Segmantation Fault",
  "Unhandled Exception",
  "Stack Overflow",
  "Core Dump",
  "General Protection Fault",
  "Page Fault",
  "Storage Violation",
  "Bounds Check Fault",
  "Null Pointer Exception",
  "Divide Fault",
  "NMI Interrupt",
  "Overflow Trap",
  "Invalid Opcode Fault",
  "Runtime Error",
  "Unspecified Fatal Error",
  "Nuff said",
  "Invalid Task State Segment Fault",
  "Not Present Fault",
  "Access Violation",
  "Invalid Option",
  "" /* The last message will never got read, so put it empty string is used */
};
 
int main(void) {
  int pid, id=-1;
 
  p = (struct point *)getmem(666);
  p->readed = 1;
  p->lock = 0;
  p->ID = 0;
 
  switch(fork()) {
    case -1: /* Error */
      printf("Fork error! Exiting...\n");
      return 1;
      break;
    case 0: /* Child -  Reading Messages */
      while(messages[id+1]!=NULL) {
      while (testandset(&(p->lock))) {}
      if(p->ID!=id) {
        printf("%s\n", p->text);
        if(id==-1) sleep(3);
        else sleep(1);
        id = p->ID;
      }
      p->readed = 1;
      p->lock = 0;
      }
      printf("\n\tEnd of child process\n");
      break;
  default: /* Parrent - Generate Messages */
    while(messages[p->ID]!=NULL) {
      while(p->readed==0) {}
      while (testandset(&(p->lock))) {}
      p->text = messages[p->ID];
      p->ID++;
      p->readed = 0;
      p->lock = 0;
    }
    wait();
    printf("\n End of parent process\n");
  }
  return 0;
}

???

Аз ли греша, или това "бащата пише, детето чете" става през структурата? Ако е така, прочети отново какво се случва при fork(), а след това се заеми и с четене за shared memory (или IPC като цяло) :).

Също така, за по-добър стил, проверявай дали резултата, който върне fork() не е -1 (т.е. грешка), недей да разделяш случаите просто на 0 и не-0 :)

А защо test_and_set() винаги връща 0? Така програмата никога няма да влезе в while циклите по-долу.

А защо test_and_set() винаги връща 0? Така програмата никога няма да влезе в while циклите по-долу.

Не е това фаталното в случая, а и употребата не е за условие за влизане в цикъл, а while(test_and_set()) {} - т.е. за ключалките.

Edit: Но, да, и механизмът за заключване "куца".

      while(p->ID<20) {
        while(test_and_set()) {}
        if(p->ID!=id) {
          printf( "Message %d:\t%s\n", p->ID, p->text);
          id = p->ID;
        }
        p->readed = 1;
        p->lock = 1;
      }

Безкраен цикъл, може би p->ID++ ?
Освен това, char text[50]; strcpy(p->text, messages[0]);  ??? много тъпо, когато ползваш статични текстове, както в случая, не използвай буфери, камо ли strcpy, поне sprintf( p->text, "%.49s", message[0]); може просто
struct point {
  int ID;
  const char *text;
  int lock;
  int readed;
}*p;
 
static const char *messages[] = { ... }; p->text = message[0];

Благодаря за съветите! Просто от ужасно много време не съм ползвал C и всеки път ми е малко странно.
Коригирах си горният пост. Това с test_and_set() явно се е объркало при копирането, защото иначе си беше "правилния" вариант.
Засега програмата  пак не работи (стига си до същата точка)...

Благодаря за съветите! Просто от ужасно много време не съм ползвал C и всеки път ми е малко странно.
Коригирах си горният пост. Това с test_and_set() явно се е объркало при копирането, защото иначе си беше "правилния" вариант.
Засега програмата  пак не работи (стига си до същата точка)...

OK, ще ти го кажа направо, когато процес създаде процес-дете, адресното пространство се копира, а не се споделя (няма как да е иначе, замисли се какъв хаос би настъпил). Няма как да ти работи замисъла на програмата с този код. Прочети какво прави fork(), прочети какво е IPC и си избери някой механизъм (например shared memory).

pthread.h му е майката за това което се опитваш да направиш. Нишките за разлика от процесите поделят общо адресно пространство. Ако се каниш да си отделяш IO-то от "бизнес логиката" по-добре ползвай разните му select/poll диревати :)

Проблемът е решен. За съжеление поради ограниченото ми време използвах библиотека, предоставена ми от училище, която май не спазва много-много стандартите. Редактирал съм кода, във "работеща" версия, само дето няма да може да ви се компилира без тази библиотека. Ако някой все пак прояви някакъв интерес, може да ми пише. Но задачата наистина е тривиална, така че...