_pipe
Создает канал для чтения и записи.
.gif "Важное примечание") Важно |
|---|
Этот API нельзя использовать в приложениях, выполняемых в Среда выполнения Windows.Дополнительные сведения см. в разделе Функции CRT не поддерживаются при /ZW. |
int _pipe( int *pfds, unsigned int psize, int textmode );
Параметры
pfds[2]
Массив, который должна содержать прочитал идентификаторы и записи файла.psize
Объем памяти для резервирования.textmode
Файловый режим.
Возвращаемое значение
Возвращает 0 в случае успешного выполнения).Возвращает – 1 для указания ошибки.При возникновении ошибки errno имеет одно из следующих значений:
значение EMFILE, указывающее, что не осталось идентификатора файла недоступно.
ENFILE, который указывает на переполнение система-файл- таблицы.
значение EINVAL, указывающее, что pfds или массив нулевого указателя или что недопустимое значение для textmode был передан в.
Дополнительные сведения об этих и других кодах возврата см. в разделе errno, _doserrno, _sys_errlist и _sys_nerr.
Заметки
Функция _pipe создает канал, искусственный канал ВВОДА-ВЫВОДА, программа использует для передачи сведениями для других программ.Канал напоминает файл, поскольку он содержит указатель файла, идентификатор файла, или оба, и его можно чтения или записи путем использования стандартных функций для ввода и вывода библиотеки.Однако канал не представляет конкретный файл или устройство.Вместо этого он представляет временное хранилище в памяти, не зависит от собственной памяти программы и полностью контролируется операционной системой.
_pipe похож на _open, но будет открыт канал для чтения и записи и возвращает 2 идентификатора файла вместо одного.Программа может использовать обе стороны канала или закрыть одну, для этого не требуется.Например, процессор команды в Windows создает канал во время выполнения, например PROGRAM1 | PROGRAM2.
Дескриптор стандартного вывода каналу PROGRAM1 вложен в записи дескриптора.Стандартный дескриптор ввода PROGRAM2 вложен дескриптора канала прочитанному.Это исключает необходимость создания временных файлов для передачи информации для других программ.
Функция _pipe возвращает 2 идентификатора файла к каналу в аргументе pfds.Элемент pfds[0] содержит дескриптор чтение, а элемент pfds[1] содержит дескриптор записи.Используются идентификаторы файла канала точно так же, как и другие идентификаторы файла.(Низкоуровневые функции входных и выходных данных _read и _write могут считывать и записывать в каналу). Чтобы определить условия элемент - канала, проверка запроса _read, который возвращает 0 как число байтов для чтения.
Аргумент psize определяет объем памяти в байтах, чтобы зарезервировать для канала.Аргумент textmode определяет режим перевода для канала.Очевидным константы _O_TEXT определяет преобразование текста и константы _O_BINARY определяет бинарный перевода.(См. fopen, _wfopen для описания режимов текста и бинарный). Если аргумент textmode 0, _pipe использует режим преобразования по умолчанию, определенный переменной _fmode умолчание- режима.
В многопоточных программах, нельзя блокировать не выполняется.Идентификаторы файлов, возвращаются вновь открыт и не должны быть доступны любым потоком до тех пор, пока _pipe после вызова не завершится.
Использовать функцию _pipe для взаимодействия между процессами и дочерним процессом, каждый процесс должен иметь только один открытый дескриптор в канале.Дескрипторы должны быть противоположностями: если родительский имеет доступ на чтение открытый дескриптор, то дочерний элемент должен иметь открытый дескриптор записи.Простейший способ сделать это значение OR (|флажок _O_NOINHERIT ) с textmode.Затем с помощью свойства _dup или _dup2 создать наследуемый копию дескриптора канала, следует передать дочернему элементу.Закройте исходного дескриптора, а затем порождайте дочерний процесс.О получении из вызова инициализировать, закрыть дескриптор дважды в процессе.Дополнительные сведения см. в примере 2 ниже в данном разделе.
В операционной системе Windows, канал при уничтожении все его дескрипторов были закрыты.(Если все дескрипторы, считываемых в канале были закрыты, то запись в каналу вызывает ошибку). Все операции чтения и записи в ожидании канала до тех пор, пока недостаточно данных или достаточного пространства буфера, чтобы выполнить запрос ВВОДА-ВЫВОДА.
Требования
Функция |
Требуемый заголовок |
Необязательный заголовок |
|---|---|---|
_pipe |
<io.h> |
<fcntl.h><errno.h>2, 1 |
1 Для _O_BINARY и определения _O_TEXT.
2 определения errno.
Дополнительные сведения о совместимости см. в разделе Совместимость.
Библиотеки
Все версии Библиотек времени выполнения C.
Пример 1
// crt_pipe.c
/* This program uses the _pipe function to pass streams of
* text to spawned processes.
*/
#include <stdlib.h>
#include <stdio.h>
#include <io.h>
#include <fcntl.h>
#include <process.h>
#include <math.h>
enum PIPES { READ, WRITE }; /* Constants 0 and 1 for READ and WRITE */
#define NUMPROBLEM 8
int main( int argc, char *argv[] )
{
int fdpipe[2];
char hstr[20];
int pid, problem, c;
int termstat;
/* If no arguments, this is the spawning process */
if( argc == 1 )
{
setvbuf( stdout, NULL, _IONBF, 0 );
/* Open a set of pipes */
if( _pipe( fdpipe, 256, O_BINARY ) == -1 )
exit( 1 );
/* Convert pipe read descriptor to string and pass as argument
* to spawned program. Program spawns itself (argv[0]).
*/
_itoa_s( fdpipe[READ], hstr, sizeof(hstr), 10 );
if( ( pid = _spawnl( P_NOWAIT, argv[0], argv[0],
hstr, NULL ) ) == -1 )
printf( "Spawn failed" );
/* Put problem in write pipe. Since spawned program is
* running simultaneously, first solutions may be done
* before last problem is given.
*/
for( problem = 1000; problem <= NUMPROBLEM * 1000; problem += 1000)
{
printf( "Son, what is the square root of %d?\n", problem );
_write( fdpipe[WRITE], (char *)&problem, sizeof( int ) );
}
/* Wait until spawned program is done processing. */
_cwait( &termstat, pid, WAIT_CHILD );
if( termstat & 0x0 )
printf( "Child failed\n" );
_close( fdpipe[READ] );
_close( fdpipe[WRITE] );
}
/* If there is an argument, this must be the spawned process. */
else
{
/* Convert passed string descriptor to integer descriptor. */
fdpipe[READ] = atoi( argv[1] );
/* Read problem from pipe and calculate solution. */
for( c = 0; c < NUMPROBLEM; c++ )
{
_read( fdpipe[READ], (char *)&problem, sizeof( int ) );
printf( "Dad, the square root of %d is %3.2f.\n",
problem, sqrt( ( double )problem ) );
}
}
}
Пример результатов выполнения
Son, what is the square root of 1000?
Son, what is the square root of 2000?
Son, what iDad, the square root of 1000 is 31.62.
Dad, the square root of 2000 is 44.72.
s the square root of 3000?
Dad, the square root of 3000 is 54.77.
Son, what is the square root of 4000?
Dad, the square root of 4000 is 63.25.
Son, what is the square root of 5000?
Dad, the square root of 5000 is 70.71.
Son, what is the square root of 6000?
SonDad, the square root of 6000 is 77.46.
, what is the square root of 7000?
Dad, the square root of 7000 is 83.67.
Son, what is the square root of 8000?
Dad, the square root of 8000 is 89.44.
Пример 2
Это простое приложение фильтра.Это порождает crt_pipe_beeper приложения после его создает канал направляющий stdout порожданного приложения в фильтр.Удаляет фильтр ASCII 7 символов (звукового сигнала).
// crt_pipe_beeper.c
#include <stdio.h>
#include <string.h>
int main()
{
int i;
for(i=0;i<10;++i)
{
printf("This is speaker beep number %d...\n\7", i+1);
}
return 0;
}
Само приложение фильтра:
// crt_pipe_BeepFilter.C
// arguments: crt_pipe_beeper.exe
#include <windows.h>
#include <process.h>
#include <memory.h>
#include <string.h>
#include <stdio.h>
#include <fcntl.h>
#include <io.h>
#define OUT_BUFF_SIZE 512
#define READ_FD 0
#define WRITE_FD 1
#define BEEP_CHAR 7
char szBuffer[OUT_BUFF_SIZE];
int Filter(char* szBuff, ULONG nSize, int nChar)
{
char* szPos = szBuff + nSize -1;
char* szEnd = szPos;
int nRet = nSize;
while (szPos > szBuff)
{
if (*szPos == nChar)
{
memmove(szPos, szPos+1, szEnd - szPos);
--nRet;
}
--szPos;
}
return nRet;
}
int main(int argc, char** argv)
{
int nExitCode = STILL_ACTIVE;
if (argc >= 2)
{
HANDLE hProcess;
int fdStdOut;
int fdStdOutPipe[2];
// Create the pipe
if(_pipe(fdStdOutPipe, 512, O_NOINHERIT) == -1)
return 1;
// Duplicate stdout file descriptor (next line will close original)
fdStdOut = _dup(_fileno(stdout));
// Duplicate write end of pipe to stdout file descriptor
if(_dup2(fdStdOutPipe[WRITE_FD], _fileno(stdout)) != 0)
return 2;
// Close original write end of pipe
_close(fdStdOutPipe[WRITE_FD]);
// Spawn process
hProcess = (HANDLE)_spawnvp(P_NOWAIT, argv[1],
(const char* const*)&argv[1]);
// Duplicate copy of original stdout back into stdout
if(_dup2(fdStdOut, _fileno(stdout)) != 0)
return 3;
// Close duplicate copy of original stdout
_close(fdStdOut);
if(hProcess)
{
int nOutRead;
while (nExitCode == STILL_ACTIVE)
{
nOutRead = _read(fdStdOutPipe[READ_FD],
szBuffer, OUT_BUFF_SIZE);
if(nOutRead)
{
nOutRead = Filter(szBuffer, nOutRead, BEEP_CHAR);
fwrite(szBuffer, 1, nOutRead, stdout);
}
if(!GetExitCodeProcess(hProcess,(unsigned long*)&nExitCode))
return 4;
}
}
}
return nExitCode;
}
Output
This is speaker beep number 1...
This is speaker beep number 2...
This is speaker beep number 3...
This is speaker beep number 4...
This is speaker beep number 5...
This is speaker beep number 6...
This is speaker beep number 7...
This is speaker beep number 8...
This is speaker beep number 9...
This is speaker beep number 10...
Эквивалент в .NET Framework
Неприменимо. Для вызова стандартной функции C используйте PInvoke. Для получения дополнительной информации см. Примеры вызовов неуправляемого кода.