Взаимодействие процессов в UNIX

Сентябрь 7, 2022

Главная
Алгебра
Взаимодействие процессов в UNIX

Содержание

2. IPC PIPE Канал – однонаправленная передача данных между двумя процессами. Low level Piping int pipe(int fd[2]);
3. Low-level piping stdin = 0 stdout = 1 stderr = 2 1. pipe(fd) 2. fork() 3.
4. FIFO int mknod(char *pathname, int mode, int dev); pathname – имя FIFO mode – флаг S_IFIFO,
5. При чтении меньшего числа байт, чем есть в канале, остаток сохраняется При чтении большего числа байт,
6. IPC FIFO mknod(“myfifo”, S_IFIFO | 0666, 0); open(“myfifo”, O_RDONLY); open(“myfifo”, O_WRONLY); read(handle, buff, MAXBUFF); write(handle, “Hello,
7. Взаимодействие потоков в Win32
8. Unnamed pipes Неименованные каналы Однонаправленный локальный механизм взаимодействия BOOL CreatePipe( PHANDLE phRead, PHANDLE phWrite, LPSECURITY_ATTRIBUTES lpsa,
9. Named pipes Именованные каналы Двунаправленный механизм взаимодействия, может использоваться локально и удаленно HANDLE CreateNamedPipe( LPCTSTR lpszPipeName,
10. Named pipes Именованные каналы m_hPipe = ::CreateNamedPipe ( "\\\\.\\pipe\\ipcdemo", // Имя канала PIPE_ACCESS_OUTBOUND, // Доступ только
12. Скачать презентацию

Слайд 2

IPC PIPE
Канал – однонаправленная передача данных между двумя процессами.
Low level

Piping
int pipe(int fd[2]);
int filedes[2]={outdes,indes};
Formatted Piping
FILE *popen(char *command, char *type);
pclose(FILE *stream);

Слайд 3

Low-level piping
stdin = 0
stdout = 1
stderr = 2
1. pipe(fd)
2. fork()
3. close(0)
4.

dup2(fd[0],0)
5. close(fd[0])
6. close(fd[1])
7. exec*(“more”)

1. close(1)
2. dup2(fd[1],1)
3. close(fd[0])
4. close(fd[1])
5. exec*(“ls -la”)

>>PIPE>>

fd[0] = 4

fd[1] = 6

0 = stdin

1 = stdout

2 = stderr

4 = fd[0]

6 = fd[1]

Слайд 4

FIFO
int mknod(char *pathname, int mode, int dev);
pathname – имя FIFO
mode –

флаг S_IFIFO, а также флаги владения, прав доступа и т.д.
dev – игнорируется

Слайд 5

При чтении меньшего числа байт, чем есть в канале, остаток сохраняется
При

чтении большего числа байт, чем есть в канале, возвращается доступное число байт
Если канал пуст и ни один процесс не открыл его на запись, будет возвращено 0 байт. Если какой-либо процесс открыл канал на запись, то read будет переведен в состояние ожидания (если канал не работает в режиме NO_DELAY).
Запись числа байт, меньше емкости канала гарантировано атомарно.
При записи числа байт, больше емкости канала, write блокируется, атомарность не гарантируется

Каналы

Слайд 6

IPC FIFO
mknod(“myfifo”, S_IFIFO | 0666, 0);
open(“myfifo”, O_RDONLY);
open(“myfifo”, O_WRONLY);
read(handle, buff, MAXBUFF);
write(handle, “Hello,

world!”);
close(handle);
unlink(“myfifo”);

Слайд 7

Взаимодействие потоков в Win32

Слайд 8

Unnamed pipes Неименованные каналы
Однонаправленный локальный механизм взаимодействия
BOOL CreatePipe(
PHANDLE phRead,
PHANDLE phWrite,

LPSECURITY_ATTRIBUTES lpsa,
DWORD cbPipe );

Слайд 9

Named pipes Именованные каналы
Двунаправленный механизм взаимодействия, может использоваться локально и удаленно
HANDLE CreateNamedPipe(

LPCTSTR lpszPipeName,
DWORD fdwOpenMode,
DWORD fdwPipMode,
DWORD nMaxInstances,
DWORD cbOutBuf,
DWORD cbInBuf,
DWORD dwTimeOut,
LPSECURITY_ATTRIBUTES lpsa );

Слайд 10

$Named pipes Именованные каналы m_hPipe = ::CreateNamedPipe ( "\\\\.\\pipe\\ipcdemo", // Имя$

Named pipes Именованные каналы
m_hPipe = ::CreateNamedPipe (
"\\\\.\\pipe\\ipcdemo", // Имя канала
PIPE_ACCESS_OUTBOUND,

// Доступ только для записи
PIPE_TYPE_BYTE | PIPE_NOWAIT, // Запись байтов, без ожидания
1, // По одному экземпляру за один раз
0, // Размер выходного буфера (байт)
0, // Размер входного буфера (байт)
0, // Время ожидания (мс)
NULL // Использовать дескриптор безопасности
// по умолчанию
);

Взаимодействие процессов в UNIX

Содержание

IPC PIPEКанал – однонаправленная передача данных между двумя процессами. Low level

Low-level pipingstdin = 0stdout = 1stderr = 21. pipe(fd)2. fork()3. close(0)4.

FIFOint mknod(char *pathname, int mode, int dev);pathname – имя FIFOmode –

При чтении меньшего числа байт, чем есть в канале, остаток сохраняетсяПри

IPC FIFOmknod(“myfifo”, S_IFIFO | 0666, 0);open(“myfifo”, O_RDONLY);open(“myfifo”, O_WRONLY);read(handle, buff, MAXBUFF);write(handle, “Hello,

Взаимодействие потоков в Win32

Unnamed pipes Неименованные каналыОднонаправленный локальный механизм взаимодействияBOOL CreatePipe( PHANDLE phRead, PHANDLE phWrite,

Named pipes Именованные каналыДвунаправленный механизм взаимодействия, может использоваться локально и удаленноHANDLE CreateNamedPipe(

Named pipes Именованные каналыm_hPipe = ::CreateNamedPipe ( "\\\\.\\pipe\\ipcdemo", // Имя канала PIPE_ACCESS_OUTBOUND,

Похожие презентации