примеры работы с пайпами на делфи

[supernewbie]

если у кого есть примеры работы с пайпами на делфи, киньте их сюды

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

[destructor]

http://www.google.ru/search?client=o...hannel=suggest

третья или четвертая ссыль, помоему оно

[Morfik]

забил я на эту штуку - там рабочий пример передачи трафика из клинта ло2 в экзешник пайпами )

[supernewbie]

Сообщение от Morfik

забил я на эту штуку - там рабочий пример передачи трафика из клинта ло2 в экзешник пайпами )

блин, там дллка не принимает данные вроде да, ну щас попробую также как в сервере, в цикле реад делать

[supernewbie]

пля, посмотрите хуле он виснет когда Send у клиента вызываю

добавлено через хз скока там чего

да что за гавно!(

[supernewbie]

работает тока асинхронка, ему ваще пох, флудит сендами на бедный сервак! че сделать чтобы эта шняга суспендилась пока серв не обработает)

Добавлено через 5 часов 45 минут
пля, обнаружил ещё какую-то загадучную хрень, главный поток не резумится если засуспендить его

[Morfik]

Сообщение от supernewbie

работает тока асинхронка, ему ваще пох, флудит сендами на бедный сервак! че сделать чтобы эта шняга суспендилась пока серв не обработает)

Добавлено через 5 часов 45 минут
пля, обнаружил ещё какую-то загадучную хрень, главный поток не резумится если засуспендить его

используй че нить для синхронизации, тот же мютекс или симофор

[supernewbie]

я ваще так подумал, проще будет при отправке суспендить поток, а резумить тока по ответу от сервера, но блин, поток не резумится, крт. секции не робят, мутекс не робит, ваще хрень какая-то)

procedure TPipeClient.Answer;
begin
ReleaseMutex(hMutex);
end;

procedure TPipeClient.Send(buf:string);
var
  rc:boolean;
begin
//if not FConnected then exit;
rc:=WriteFile (hPipe, pointer(buf)^, Length(buf), bytesWritten, @OverLapWrt);
if not rc then
if GetLastError = ERROR_IO_PENDING then
          WaitForSingleObject (hEventWrt, INFINITE)
          else FConnected:=false;
hMutex:=CreateMutex(nil, true, 'SendMutex');
if GetLastError = ERROR_ALREADY_EXISTS then
WaitForSingleObject (hMutex, INFINITE);
end;

это это не робит, ему пох! он нече не ждет никакие мюьтексы!

Добавлено через 1 час 12 минут
пасаны, че я не так делаю)

Добавлено через 12 минут
ыы, семафор робит))

[xkor]

Оффтоп

Сообщение от supernewbie

пасаны, че я не так делаю)

живёшь)

[supernewbie]

Оффтоп

о_о
как жезка

Добавлено через 39 минут
пля короче это какой-то херовый способ синхрона, если клиент и сервер одновременно пошлют мессаджи друг другу то оба будут ждать друг от друга ответов, и вот я хз..

Добавлено через 6 минут
короче хз, при быстром обмене месаджами происходит висяк(