Итак, я пытаюсь реализовать базовый конвейер FIFO на C, используя mkfifo(). Вот мои классы кода:
основной.с:
int main(int argc, char *argv[]) {
char *path = "/tmp/fifo";
pid_t pid;
setlinebuf(stdout);
unlink(path);
mkfifo(path, 0600);
pid = fork();
if (pid == 0) {
client(path);
} else {
server(path);
}
return(0);
}
клиент.с:
void client(char *path) {
char *input;
input = (char *)malloc(200 * sizeof(char));
read(STDIN_FILENO, input, 200);
struct Message message;
message = protocol(input); //protocol simply takes an input string and formats it
char number = message.server;
char* string;
string = message.string;
int fd;
fd = open(path, O_WRONLY);
write(fd, string, sizeof(string));
printf("Client send: %s\n", string);
close(fd);
return;
}
сервер.с:
void server(char *path) {
int fd;
char *input;
input = (char *)malloc(200 * sizeof(char));
fd = open(path, O_RDONLY);
read(fd, input, sizeof(input));
printf("Server receive: %s\n", input);
close(fd);
return;
}
Теперь конвейер работает, но сервер почему-то получает только часть сообщения. Например, если мы получим следующую строку из протокола: «HELLO WORLD», мы получим следующий вывод:
Server receive: HELLO WO
Client send: HELLO WORLD
Сервер должен получить все сообщение, но это не так. Что я делаю неправильно? Спасибо за любую помощь!
input = (char *)malloc(200 * sizeof(char));
, а затемread(fd, input, MAX_BUF);
, когдаMAX_BUF
равно 1024? - person Weather Vane   schedule 02.06.2016