Как сделать синхронную запись в пайп?

Question

[Павел Каптур]

Всем привет, делаю двусторонний канал из двух пайпов и при тестировании заметил, что записывая данные с одной стороны получаю разбивку сообщения при приеме. например

f
OnRead2 f
ffffff
OnRead2 f
OnRead2 ffff
OnRead2 f

т.е. напечатанное превратилось в три строки.
Попробовал установить флаг O_SYNC, но ситуация не изменилась.
FIFO открывается и создается так

if(mkfifo(pipeForWriting, S_IFIFO|S_IRWXU|S_IRWXG|S_IRWXO) != 0)
    {
		if(errno==EEXIST)
			return 0;
		printf("create named pipe error = %d\n", errno); /* произошла ошибка */
	    return errno;
    }

pipeForWritingDescriptor = open(pipeForWriting, O_SYNC|O_WRONLY);

Как сделать так, что бы считывалось все сообщение целиком?

Comments

[Алексей Черемисин]

А как пишем и читаем то?

[Павел Каптур]

Алексей Черемисин: с помощью стандартных вызовов read и write и так как они не содержат параметров ввода, я не стал их приводить

[Алексей Черемисин]

Тоесть по одному байту?!

[Павел Каптур]

Алексей Черемисин: почему по одному? весь буфер сразу

[Алексей Черемисин]

Павел Каптур: так я и спрашиваю как вы определяете количество! Код приведите. Скорее всего у вас не все помещается в буфер пайпа, ну и стандартно по возврату каретки буфер флашится.

[Axian Ltd.]

Имхо пайп и не гарантирует "сообщения", он поток. Про сообщений это другая опера.

[Павел Каптур]

Алексей Черемисин:

int NamedPipeClass::Write(unsigned char * buffer, unsigned int bufferLen)
{
	return write(pipeForWritingDescriptor, buffer, bufferLen);
}

int NamedPipeClass::ReadingThread()
{
	unsigned char buf[MAX_BUF];
	ssize_t bytesReaded = 0;
	while(!bExit)
	{
		memset(buf,0,MAX_BUF);
		bytesReaded = read(pipeForReadingDescriptor, buf, MAX_BUF);
		if(bytesReaded>0)
		{
			if(onRead!=NULL)
				onRead(buf, bytesReaded, this);
		}
	}
	return 0;
}

[Павел Каптур]

Алексей Черемисин: для формирования сообщения используется просто ввод с клавиатуры через cin

Answer 1

[Алексей Черемисин]

Так понятно. Вам лучше всего перейти на "сообщения" со свое структурой.
В заголовке сообщения просто ставите его длину, а уже в цикле считываете само тело до достижения длины. Таким образом вы не будете зависеть от буферов и прочей асинхронности записи.
Собственно с сокетами такая же история, да и с остальными потоками.

Comments

[Павел Каптур]

я о чем то подобном предполагал, просто надеялся что есь способ сделать полное чтение.

[Алексей Черемисин]

Павел Каптур: ну, если сообщения одинаковой длины, то просто читаем до ее достижения. Ну или пайпы вам не совсем подходят, или взять библиотеку типа zeromq и забить на пайпы. Они не для этого. Вообще-то в ipc есть еще shared memory и queue. Не то чтобы с ними удобнее, они есть как минимум. С ними проблема с переинициализацией. Ну или опять же zeromq и товарищи...

[Алексей Черемисин]

Павел Каптур: ах, ну да. Если строки заканчиваются возвратом каретки, то пользуйте printf и scanf, как это не пародоксально.

[Алексей Черемисин]

Ну или fputs/fgets

[Павел Каптур]

Алексей Черемисин: большое спасибо, а можно еще один вопрос, мне просто интересно услышать мнение. Вопрос связан с архитектурой, вот я пишу клиента, т.е. он по сути создает экземпляр класса pipe и ожидает через пайп, когда придет команда умереть, сам экземпляр pipe при инициализации создает поток слушатель, к которому повешен callback. Ну и типа от далее приходят данные, попадают в callback и должна произойти сборка какая то. Появилась мысль написать класс, который будет буферизировать в себя данные и по запросу отдавать полученные команды. Так вот, обработка команд должен вестись в одном потоке, а прием данных через callback. Таким образом, получается, что без глобального экземпляра класса не обойтись? вот как правильнее сделать подобную работу с буферизацией?

[Алексей Черемисин]

Павел Каптур: Ну, "глобальный класс" здесь совсем не нужен. А буферизицию лучше сделать через очередь сообщений. И эту ссылку на эту очередь передавать и в callback и в обработчик команд. В принципе это традиционная модель - consumer-producer. Если пишете на C++ с использование какого-то фреймворка, то наверняка уже есть готовые классы.
И "глобальный класс" обычно называется singleton. Но чтобы не делать именно один класс, обычно создают объект типа Context, и его передают во все нужные сущности. Единственное, позаботьтесь о синхронизации доступа через блокировки.

[Алексей Черемисин]

Да, ссылку на очередь (queue) как раз и можно положить в ваш объект context.