FIFO Pipelining Server только получает определенную сумму
Поэтому я пытаюсь реализовать базовый конвейер FIFO в C, используя mkfifo(). Вот мои классы кода:
main.c:
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);
}
client.c:
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;
}
server.c:
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
Сервер должен получить сообщение целиком, но это не так. Что я делаю неправильно? Спасибо за любую помощь!
1 ответ
Я заметил, что вы сократили обычно существенную проверку возвращаемых значений из open
а также read
а также write
, Если бы вы имели, вы могли заметить ошибку в этой строке
write(fd, string, sizeof(string));
Так как string
указатель, вы отправляете 8 байт (размер указателя). Вы должны использовать strlen(string)
или это +1
в зависимости от того, нужно ли отправлять терминатор.
write(fd, string, strlen(string));
Вы повторяете ошибку в своем недавнем неразумном редактировании:
read(fd, input, sizeof(input));
Вы бы лучше придерживаться оригинала #define
и используя это как для выделения буфера, так и для размера запроса на чтение.