Каналы в Си

[Лучик искренности]

Привет всем неспящим

Пытаюсь на чистом СИ записать информацию в канал и считать оттуда в двух разных процессах. Почему-то записывает одно, а считывает совсем другое. Помогите разобраться, пожалуйста.

int main(void) {

    int     fd, result, kol = 10;
    size_t  size;
    char    name[] = "myfifo2.fifo";
    int     fileSize = 25;
    char    *string [fileSize];
    char    *res[fileSize]; 

    /* Обнуляем маску создания файлов текущего процесса для того, чтобы права доступа у создаваемого FIFO точно соответствовали параметру вызова mknod() */
    (void)umask(0); 

    //Если не можем создать FIFO
    if(mknod(name, S_IFIFO | 0666, 0) < 0) {
        printf("Can\'t create FIFO\n";);
        exit(-1); 
    }

    /* Порождаем новый процесс */ 
    if((result = fork()) < 0) {

    /* Если создать процесс не удалось, сообщаем об этом и завершаем работу */ 
        printf("Can\'t fork child\n";);
        exit(-1);
    } else if (result > 0) {

    /* Мы находимся в родительском процессе, который будет передавать информацию процессу-ребенку. В этом процессе открываем FIFO на запись.*/
	if((fd = open(name, O_WRONLY)) < 0) {
          printf("Can\'t open FIFO for writing\n";);
          exit(-1); 
    	} 

    	// Запись
    	kol = readFile(string);
    	size = write(fd, string, sizeof(string));

	int p;
	for (p = 0; p < 10; p++) { printf("%s\n", string[p]); }

    	/* Если записалось меньшее количество байт,то сообщаем об ошибке и завершаем работу */
    	if(size != sizeof(string)) {
            printf("Can\'t write all string to FIFO\n";);         
            exit(-1); 
	}
        printf("Родитель завершил работу.\n";);
        sleep(10);

        close(fd);

    } else {

        if((fd = open(name, O_RDONLY)) < 0) {
            printf("Can\'t open FIFO for reading\n";);
            exit(-1); 
        }

	// Чтение
	size = read(fd, res, sizeof(res));

	int p;
	for (p = 0; p < 10; p++) { printf("%s\n", res[p]); }

        if(size < 0) {
            printf("Can\'t read string\n";); 
            exit(-1);
        }

        close(fd);

    }
    return 0; 

}

Выводит так (сначала то, что записывается, а потом то, что считалось):

aiiu
aiiu
oiiu
aiiu
aiaiaiai
aaii
aoii
aiyy
aaii
sdad
Родитель завершил работу.

@темы: *nix

Comments

[mikluho]

Мало что знаю про Си в *nix, но вот это:

	
// Чтение

	size = read(fd, res, sizeof(res));



	int p;

	for (p = 0; p < 10; p++) { printf("%s\n", string[p]); }

вызывает подозрение в печати данных невесть откуда...

[Лучик искренности]

mikluho, ой, да, там я ошиблась - теперь исправила, но оно после чтения теперь вообще ничего не выводит =/

[Ri]

Не хватает реализации readFile и инклюдов. Выложите программу целиком.

[Лучик искренности]

Ri, так я же наоборот убрала лишнее, чтобы не загружать тут никого лишним кодом и алгоритмами. да и readFile не существенно вообще, там все нормально.
фишка в том, что в вот таком варианте, когда тоже самое с fifo, но поток один, все отлично работает, а когда разделяю на два - что-то не то уже(

int main(void) {
    int     fd, kol;
    size_t  size;
    char    name[] = "myfifo.fifo";
    int     fileSize = 25;
    char    *string [fileSize];
    char    *res[fileSize]; 
    
    /* Обнуляем маску создания файлов текущего процесса для того, чтобы права доступа у создаваемого FIFO точно соответствовали параметру вызова mknod() */
    (void)umask(0); 

    //Если не можем создать FIFO
    if(mknod(name, S_IFIFO | 0666, 0) < 0){
        printf("Can\'t create FIFO\n");
        exit(-1); 
    }

    /*В этом процессе открываем FIFO на запись.*/
    if((fd = open(name, O_RDWR)) < 0){
        printf("Can\'t open FIFO for writing\n");
        exit(-1); 
    } 

    // Запись
    kol = readFile(string);
    size = write(fd, string, sizeof(string));
    /* Если записалось меньшее количество байт,то сообщаем об ошибке и завершаем работу */
    if(size != sizeof(string)){
        printf("Can\'t write all string to FIFO\n");         
        exit(-1); 
    } 

    // Чтение из FIFO
    read(fd, res, sizeof(res));

    printWords(res, kol);

    //Закрываем входной поток
    close(fd);

    return 0; 
}

Мне сказали, что проблема может быть вот в чем: "Дело в том, что вы пересылаете не сами строки, а лишь указатели на них. У дочернего процесса по этим адресам нужных строк нет."
Но я не знаю, как ее решить =/

//Внезапно, как-то я пропустил этот пост

Лучик искренности,
1.
char *string [fileSize];
char *res[fileSize];
это массивы указателей. В нём можно "поуказывать" на fileSize (который в данном случае = 25) строк, но физически эти строки в этом массиве располагаться не будут, только их адреса в памяти. Если непонятно - то прошу сюда.
Соответственно, размер записываемого (и считываемого) это уже никак не 25 строчек, а просто размер буфера - т.е filesize*sizeof(char*). В пределах одного процесса это будет работать, поскольку по считанным адресам будут строки. А вот у другого процесса - другое адресное пространство, и обращение по "чужому" указателю в лучшем случае даст просто мусор. Потому нужно записывать каждую строчку отдельно, циклом проходясь по всему массиву строк. Печать же того, что было "записано" как-то же догадались сделать правильно, вот с вызовом write нужно сделать примерно то же самое.

Читать - уже немножко сложнее, тут есть проблема в размере поступающих данных, которого вам (если делать все "па чэснаму") никто не скажет. Устанавливаем размер блока для чтения (любое симпатичное тебе число на таких маленьких объёмах данных), выделяешь пару блоков на буфер, читаешь в буфер поблочно. В случае, если данных больше, чем у нас выделено памяти - реаллоцируем (realloc) буфер на ещё пару блоков сверху. В результате - получится один большой буфер, содержащий все строки. Просто так вывести его не получится - он повсеместно содержит 0-байтыю Но можно его "подробить" в массив, используя в качестве разделителя эти самые 0-байты.
//подробно расписывать не буду - получится простыня подлиннее кода, это дело реализующего. Но идею уловить можно, как мне кажется.

2. Читать (read()) нужно в цикле пока он не вернёт <=0. 0 - в случае успешного завершения, -1 - ошибка.