При возникновении ошибки системный вызов listen возвращает

Системный вызов listen()

Системный вызов listen() является первым из еще неизвестных нам вызовов, применяемым на TCP–сервере. В его задачу входит перевод TCP–сокета в пассивное (слушающее) состояние и создание очередей для порождаемых при установлении соединения присоединенных сокетов, находящихся в состоянии не полностью установленного соединения и полностью установленного соединения. Для этого вызов имеет два параметра: дескриптор TCP–сокета и число, определяющее глубину создаваемых очередей.

#include <sys/types.h>
#include <sys/socket.h> 
int listen(int sockd, int backlog);

Последний параметр на разных UNIX-подобных операционных системах и даже на разных версиях одной и той же системы может иметь различный смысл. Где-то это суммарная длина обеих очередей, где-то он относится к очереди не полностью установленных соединений (например, Linux до версии ядра 2.2) где-то – к очереди полностью установленных соединений (например, Linux, начиная с версии ядра 2.2), где-то – вообще игнорируется.

Системный вызов accept()

Системный вызов accept() позволяет серверу получить информацию о полностью установленных соединениях. Если очередь полностью установленных соединений не пуста, то он возвращает дескриптор для первого присоединенного сокета в этой очереди, одновременно удаляя его из очереди. Если очередь пуста, то вызов ожидает появления полностью установленного соединения. Системный вызов также позволяет серверу узнать полный адрес клиента, установившего соединение. У вызова есть три параметра: дескриптор слушающего сокета, через который ожидается установление соединения; указатель на структуру, в которую при необходимости будет занесен полный адрес сокета
клиента, установившего соединение; указатель на целую переменную, содержащую максимально допустимую длину этого адреса. Как и в случае вызова recvfrom() , последний параметр является модернизируемым, а если нас не интересует, кто с нами соединился, то вместо второго и третьего параметров можно указать значение NULL.

#include <sys/types.h>
#include <sys/socket.h> 
int accept(int sockd, 
    struct sockaddr *cliaddr, 
    int *clilen);

Пример простого TCP-сервера

Рассмотрим программу 15–16-4.c, реализующую простой TCP—сервер для сервиса echo.

/* Пример простого TCP-сервера для сервиса echo */
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdio.h>
#include <errno.h>
#include <unistd.h>
void main()
{
    int sockfd, newsockfd; /* Дескрипторы для 
слушающего и присоединенного сокетов */
    int clilen; /* Длина адреса клиента */
    int n; /* Количество принятых символов */
    char line[1000]; /* Буфер для приема информации */
    struct sockaddr_in servaddr, cliaddr; /* Структуры 
        для размещения полных адресов сервера и 
        клиента */
    /* Создаем TCP-сокет */
    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){
        perror(NULL);
        exit(1);
    }
    /* Заполняем структуру для адреса сервера: семейство
    протоколов TCP/IP, сетевой интерфейс – любой, номер 
    порта 51000. Поскольку в структуре содержится 
    дополнительное не нужное нам поле, которое должно 
    быть нулевым, побнуляем ее всю перед заполнением */
    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family= AF_INET;
    servaddr.sin_port= htons(51000);
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    /* Настраиваем адрес сокета */
    if(bind(sockfd, (struct sockaddr *) &servaddr, 
    sizeof(servaddr)) < 0){
        perror(NULL);
        close(sockfd);
        exit(1);
    }
    /* Переводим созданный сокет в пассивное (слушающее) 
    состояние. Глубину очереди для установленных 
    соединений описываем значением 5 */
    if(listen(sockfd, 5) < 0){
        perror(NULL);
        close(sockfd);
        exit(1);
    }
    /* Основной цикл сервера */
    while(1){
        /* В переменную clilen заносим максимальную
        длину ожидаемого адреса клиента */
        clilen = sizeof(cliaddr);
        /* Ожидаем полностью установленного соединения
        на слушающем сокете. При нормальном завершении 
        у нас в структуре cliaddr будет лежать полный 
        адрес клиента, установившего соединение, а в 
        переменной clilen – его фактическая длина. Вызов
        же вернет дескриптор присоединенного сокета, через
        который будет происходить общение с клиентом. 
        Заметим, что информация о клиенте у нас в
        дальнейшем никак не используется, поэтому 
        вместо второго и третьего параметров можно 
        было поставить значения NULL. */
        if((newsockfd = accept(sockfd, 
        (struct sockaddr *) &cliaddr, &clilen)) < 0){
            perror(NULL);
            close(sockfd);
            exit(1);
        }
        /* В цикле принимаем информацию от клиента до
        тех пор, пока не произойдет ошибки (вызов read()
        вернет отрицательное значение) или клиент не
        закроет соединение (вызов read() вернет 
        значение 0). Максимальную длину одной порции 
        данных от клиента ограничим 999 символами. В
        операциях чтения и записи пользуемся дескриптором
        присоединенного сокета, т. е. значением, которое
        вернул вызов accept().*/
        while((n = read(newsockfd, line, 999)) > 0){
            /* Принятые данные отправляем обратно */
            if((n = write(newsockfd, line, 
            strlen(line)+1)) < 0){
                perror(NULL);
                close(sockfd);
                close(newsockfd);
                exit(1);
            }
        }
    /* Если при чтении возникла ошибка – завершаем работу */
    if(n < 0){
            perror(NULL);
            close(sockfd);
            close(newsockfd);
            exit(1);
        }
        /* Закрываем дескриптор присоединенного сокета и
        уходим ожидать нового соединения */
        close(newsockfd);
    }
}

Наберите и откомпилируйте программу. Запустите ее на выполнение. Модифицируйте текст программы TCP-клиента (программа 15–16-3.c ), заменив номер порта с 7 на 51000. Запустите клиента с другого виртуального терминала или с другого компьютера и убедитесь, что клиент и сервер взаимодействуют корректно.

Перевод сокета в пассивное состояние. Создание очереди соединений

listenQ

accept().

write()

close()

connect()

Окончание
соединения

Рис.
14-15.7.
Схема
взаимодействия клиента и сервера для
протокола TCP

Установление
логического соединения. Системный вызов
connectQ

Среди
системных вызовов со стороны клиента
появляется только один новый — connect
().
Системный вызов connect
()
при работе с ТСР-сокетами служит для
установления логического соединения
со стороны клиента. Вызов connect
()
скрывает внутри себя настройку сокета
на выбранный системой порт и произвольный
сетевой интерфейс (по сути дела, вызов
bind()
с нулевым номером порта и IP-адресом
INADDR_ANY).
Вызов
блокируется до тех пор, пока не будет
установлено логическое соединение, или
пока не пройдет определенный промежуток
времени, который может регулироваться
системным администратором.

Для
установления соединения необходимо
задать три параметра: дескриптор
активного сокета, через который будет
устанавливаться соединение, полный
адрес сокета сервера и его длину.

Системный
вызов connect()

Прототип
системного вызова

Mnclude
<sys/types.h> Mnclude <sys/socket.h>

int
connect(int sockd, struct sockaddr *servaddr, int addrlen);

Описание
системного вызова

Системный
вызов connect
служит
для организации связи клиента с сервером.
Чаще всего он используется для установления
логического соединения, хотя может быть
применен и при связи с помощью датаграмм
(connectionless).
Данное описание не является полным
описанием системного вызова, а
предназначено только для использования
в нашем курсе. Полную информацию можно
найти в UNIX
Manual.

Параметр
sockd
является
дескриптором созданного ранее
коммуникационного узла, т. е. значением,
которое вернул системный вызов socket
().

Параметр
servaddr
представляет
собой адрес структуры, содержащей
информацию о полном адресе сокета
сервера. Он имеет тип указателя на
структуру-шаблон struct
sockaddr,
которая
должна быть конкретизирована в зависимости
от используемого семейства протоколов
и заполнена перед вызовом.

Параметр
addrlen
должен
содержать фактическую длину структуры,
адрес которой передается в качестве
второго параметра. Эта длина меняется
в зависмости от семейства протоколов
и различается даже в пределах одного
семейства протоколов (например, для
UNIX
Domain).

При
установлении виртуального соединения
системный вызов не возвращается до его
установления или до истечения
установленного в системе времени —
timeout.
При использовании его в connectionless
связи вызов возвращается немедленно.

Возвращаемое
значение

Системный
вызов возвращает значение 0
при
нормальном завершении и отрицательное
значение, если в процессе его выполнения
возникла ошибка.

Пример
программы TCP-клиента

Рассмотрим
пример — программу 14—15-З.с. Это простой
ТСР-кли-ент, обращающийся к стандартному
системному сервису echo.
Стандартный
сервис принимает от клиента текстовую
датаграмму и, не изменяя ее, отправляет
обратно. За сервисом зарезервирован
номер порта 7. Заметим, что это порт 7 TCP
— не путать с портом 7 UDP
из примера в разделе «Пример программы
UDP-клиента»!
Для правильного запуска программы
необходимо указать символьный IP-адрес
сетевого интерфейса компьютера, к
сервису которого требуется обратиться,
в качестве аргумента командной строки,
например:

a.out
192.168.253.12

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

/*
Простой пример TCP-клиента
для сервиса echo
*/

#include
<sys/types.h>

#include
<sys/socket.h>

#include
<netinet/in.h>

#include
<arpa/inet.h>

#include
<string.h>

#include
<stdio.h>

#include
<errno.h>

#include
<unistd.h>

void
main(int argc, char **argv)

{

int
sockfd;
/* Дескриптор сокета */

int
n;
/* Количество переданных или прочитанных

символов
*/ int
i;
/* Счетчик цикла */

char
sendline[1000],recvline[1000]
; /* Массивы для отсылаемой и принятой
строки */ struct
sockaddr_in
servaddr;
/* Структура для

адреса
сервера */ /* Сначала проверяем наличие
второго аргумента в командной строке.
При его отсутствии прекращаем работу
*/ if(argc
!= 2){

printf(«Usage:
a.out
<IP
address>n»);

exit(l);

}

/*
Обнуляем символьные массивы */
bzero(sendline,1000);
bzero(recvline,1000);
/* Создаем ТСР-сокет */

if((sockfd
= socket(PF_INET, SOCK_STREAM, 0)) < 0){ perror(NULL); /* Печатаем
сообщение
об
ошибке
*/

exit
(1) ;

}

/*
Заполняем структуру для адреса сервера:
семейство протоколов TCP/IP, сетевой
интерфейс — из аргумента командной
строки, номер порта 7.
Поскольку в структуре содержится
дополнительное не нужное нам поле,
хоторое должно быть нулевым, перед
заполнением обнуляем ее всю */
bzero(&servaddr,
sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_port =
htons(51000);

іf(inet_aton(argv[1],
kservaddr.sin_addr) == 0){ printf(«Invalid IP addressn»);
close(sockfd); exit(1);

}

/*
Устанавливаем логическое соединение
через созданный сокет с сокетом сервера,
адрес которого мы занесли в структуру
*/

if
(connect(sockfd, (struct sockaddr *) &servaddr, sizeof(servaddr))
< 0){

perror(NULL);

close(sockfd);

exit(1);

}

/*
Три раза в цикле вводим строку с
клавиатуры, отправляем ее серверу и
читаем полученный ответ */ for(i=0;
i<3;
i++){

printf(«String
=> «); fflush(stdin);

fgets(sendline,
1000, stdin)• if( (n = write(sockfd, sendline, strlen(sendline)+1))
< 0){

perror(«Can’t
writen»);

close(sockfd);

exit(1)
;

}

if
( (n = read(sockfd,recvline, 999)) < 0){ perror(«Can¹t
readn»); close(sockfd); exit(1) ;

)

printf(«%s»,
recvline);

}

/*
Завершаем
соединение
*/ close(sockfd);

}

Наберите
и откомпилируйте программу. Перед
запуском узнайте
у своего системного администратора,
запущен
ли в системе стандартный TCP-сервис
echo
и,
если нет, попросите это сделать. Запустите
программу с запросом к сервису своего
компьютера, к сервисам других компьютеров.
Если в качестве IP-адреса
указать несуществующий адрес или адрес
выключенной машины, то программа сообщит
об ошибке при работе вызова connect
()
(правда, возможно, придется подождать
окончания time-out’a).
При задании адреса компьютера, на котором
не работает сервис echo,
об
ошибке станет известно сразу же. Протокол
TCP
является надежным протоколом. Если
логическое соединение установить не
удалось, то отправитель будет знать об
этом.

Как
происходит установление виртуального
соединения

Протокол
TCP
является надежным дуплексным протоколом.
С точки зрения пользователя работа
через протокол TCP
выглядит как обмен информацией через
поток данных. Внутри сетевых частей
операционных систем поток данных
отправителя нарезается на пакеты данных,
которые, собственно, путешествуют по
сети и на машине-получателе вновь
собираются в выходной поток данных. В
лекции 4
речь
шла о том, каким образом может обеспечиваться
надежность передачи информации в
средствах связи, использующих в своей
основе передачу пакетов данных. В
протоколе TCP
используются приемы нумерации передаваемых
пакетов и контроля порядка их получения,
подтверждения о приеме пакета со стороны
получателя и насчет контрольных сумм
по передаваемой информации. Для
правильного порядка получения пакетов
получатель должен знать начальный номер
первого пакета отправителя. Поскольку
связь является дуплексной, и в роли
отправителя пакетов данных могут
выступать обе взаимодействующие стороны,
они до передачи пакетов данных должны
обменяться, по крайней мере, информацией
об их начальных номерах. Согласование
начальных номеров происходит по
инициативе клиента при выполнении
системного вызова connect
().

Для
такого согласования клиент посылает
серверу специальный пакет информации,
который принято называть SYN
(от слова synchronize
— синхронизировать). Он содержит, как
минимум, начальный номер для пакетов
данных, который будет использовать
клиент. Сервер должен подтвердить
получение пакета SYN
от клиента и отправить ему свой пакет
SYN
с начальным номером для пакетов данных,
в виде единого пакета с сегментами SYN
и АСК (от слова acknowledgement
— подтверждение). В ответ клиент пакетом
данных АСК должен подтвердить прием
пакета данных от сервера.

Описанная
выше процедура, получившая название
трехэтапного
рукопожатия (three—way
handshake),
схематично
изображена на рисунке 14-15.8. При приеме
на машине-сервере пакета SYN,
направленного на пассивный (слушающий)
сокет, сетевая часть создает операционной
системе копию этого сокета — присоединенный
сокет — для последующего общения,
отмечая его как сокет сне полностью
установленным соединением. После приема
от клиента пакета АСК этот сокет
переводится в состояние полностью
установленного соединения, и тогда он
готов к дальнейшей работе с использованием
вызовов read
()
и write
().

Системный
вызов listen()

Системный
вызов listen
()
является первым из еще неизвестных нам
вызовов, применяемым на TCP-сервере.
В его задачу входит перевод ТСР-сокета
в пассивное (слушающее) состояние и
создание очередей для порождаемых при
установлении соединения присоединенных
сокетов, находящихся в состоянии не
полностью установленного соединения
и полностью установленного соединения.
Для этого вызов имеет два параметра:
дескриптор ТСР-сокета и число, определяющее
глубину создаваемых очередей.

Клиент

Сервер

Начало
вызова connectQ

Создание
присоединенного сокета в очереди не
полностью установленных соединений

Перевод
присоединенного сокета в очередь
полностью установленных соединений

Рис.
14-15.8. Схема установления ТСР-соединения

Системный
вызов listen()

Прототип
системного вызова

#include
<sys/types.h>

#include
<sys/socket.h>

int
listen{int
sockd,
int
backlog);

Описание
системного вызова

Системный
вызов listen
используется
сервером, ориентированным на установление
связи путем виртуального соединения,
для перевода сокета в пассивный режим
и установления глубины очереди для
соединений.

Параметр
sockd
является
дескриптором созданного ранее сокета,
который должен быть переведен в пассивный
режим, т. е. значением, которое вернул
системный вызов socket
().
Системный
вызов 1
i
st
en
требует
предварительной настройки адреса сокета
с помощью системного вызова bind
().

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

Возвращаемое
значение

Системный
вызов возвращает значение 0
при
нормальном завершении и значение -1
при
возникновении ошибки.

Последний
параметр на разных UNIX-подобных
операционных системах и даже на разных
версиях одной и той же системы может
иметь различный смысл. Где-то это
суммарная длина обеих очередей, где-то
он относится к очереди не полностью
установленных соединений (например,
Linux
до версии ядра 2.2) где-то — к очереди
полностью установленных соединений
(например, Linux,
начиная с версии ядра 2.2), где-то — вообще
игнорируется.

Системный
вызов accept()

Системный
вызов accept
()
позволяет серверу получить информацию
о полностью установленных соединениях.
Если очередь полностью установленных
соединений не пуста, то он возвращает
дескриптор для первого присоединенного
сокета в этой очереди, одновременно
удаляя его из очереди. Если очередь
пуста, то вызов ожидает появления
полностью установленного соединения.
Системный вызов также позволяет серверу
узнать полный адрес клиента, установившего
соединение. У вызова есть три параметра:
дескриптор слушающего сокета, через
который ожидается установление
соединения; указатель на структуру, в
которую при необходимости будет занесен
полный адрес сокета клиента, установившего
соединение; указатель на целую переменную,
содержащую максимально допустимую
длину этого адреса. Как и в случае вызова
recvfromO,
последний
параметр является модернизируемым, а
если нас не интересует, кто с нами
соединился, то вместо второго и третьего
параметров можно указать значение NULL.

Системный
вызов accept()

Прототип
системного вызова

#include
<sys/types.h> #include <sys/socket.h>

int
accept(int sockd, struct sockaddr *cliaddr, int *clilen);

Описание
системного вызова

Системный
вызов accept
используется
сервером, ориентированным на установление
связи путем виртуального соединения,
для приема полностью установленного
соединения.

Параметр
sockd
является
дескриптором созданного и настроенного
сокета, предварительного переведенного
в пассивный (слушающий) режим с помощью
системного вызова listen
().

Системный
вызов accept
требует
предварительной настройки адреса сокета
с помощью системного вызова bind().

Параметр
cliaddr
служит
для получения адреса клиента, установившего
логическое соединение, и должен содержать
указатель на структуру, в которую будет
занесен этот адрес.

Параметр
с
1
i
1
en
содержит
указатель на целую переменную, которая
после возвращения из вызова будет
содержать фактическую длину адреса
клиента. Заметим,
что перед вызовом эта переменная должна
содержать максимально
допустимое значение такой длины. Если
параметр cliaddr
имеет
значение NULL,
то
и параметр clilen
может
иметь значение NULL.

Возвращаемое
значение

Системный
вызов возвращает при нормальном
завершении дескриптор присоединенного
сокега, созданного при установлении
соединения для последующего общения
клиента и сервера, и значение -1
при
возникновении ошибки.

Пример
простого ТСР-сервера

Рассмотрим
программу 14—15-4.С,
реализующую
простой ТСР-сер-вер для сервиса echo:

/*
Пример простого TCP-сервера
для сервиса echo
*/

#include
<sys/types.h>

#include
<sys/socket.h>

#include
<netinet/in.h>

#include
<arpa/inet.h>

#include
<string.h>

#include
<stdio.h>

#include
<errno.h>

#include
<unistd.h>

void
main()

{

int
sockfd, newsockfd; /* Дескрипторы
для

слушающего
и присоединенного сокетов */

int
clilen;
/* Длина адреса клиента */

int
п; /* Количество принятых символов */

char
line[1000];
/* Буфер для приема информации */

struct
sockaddr_in servaddr, cliaddr; /* Структуры

для
размещения полных адресов сервера и

клиента
*/ /* Создаем
ТСР-сокет
*/

if((sockfd
= socket(AF_INET, SOCK_STREAM, 0)) < 0){ perror(NULL); exit(1);

/*
Заполняем структуру для адреса сервера:
семейство протоколов TCP/IP, сетевой
интерфейс — любой, номер порта 51000.
Поскольку
в структуре содержится дополнительное
не нужное нам поле, которое должно быть
нулевым, обнуляем ее всю перед заполнением
*/ bzero(&servaddr,
sizeof(servaddr));
servaddr.sin_family=
AF_INET;
servaddr.sin_port=
htons(51000);
servaddr.sin_addr.s_addr
= htonl(INADDR_ANY);
/* Настраиваем адрес сокета */

іf(bind(sockfd,
(struct sockaddr *) &servaddr, sizeof(servaddr)) < 0){

perror(NULL);

close(sockfd);

exit
(1) ;

}

/*
Переводим
созданный
сокет в пассивное (слушающее) состояние.
Глубину очереди для установленных
соединений описываем значением 5 */ if
(listenfsockfd,
5) < 0){

perror(NULL);

close(sockfd);

exit
(1) ;

}

/*
Основной цикл сервера */ while(l){

/*
В переменную clilen
заносим максимальную длину ожидаемого
адреса клиента */ clilen
= sizeof(cliaddr);

/*
Ожидаем полностью установленного
соединения на слушающем сокете. При
нормальном завершении у нас в структуре
cliaddr
будет лежать полный адрес клиента,
установившего соединение, а в переменной
clilen
— его фактическая длина. Вызов же вернет
дескриптор присоединенного сокета,
через который будет происходить общение
с клиентом. Заметим, что информация о
клиенте у нас в дальнейшем никак не
используется, поэтому вместо второго
и третьего параметров можно было
поставить значения NULL.
*/
if((newsockfd = accept(sockfd,

(struct
sockaddr *) &cliaddr, &clilen)) < 0){

perror(NULL);
close(sockfd); exit(1);

}

/*
В цикле принимаем информацию от клиента
до тех пор, пока не произойдет ошибки
(вызов read()
вернет отрицательное значение) или
клиент не закроет соединение (вызов
read()
вернет значение 0). Максимальную длину
одной порции данных от клиента ограничим
999 символами. В
операциях чтения и записи пользуемся
дескриптором присоединенного сокета,
т. е. значением, которое вернул вызов
accept().*/

while((n
= read(newsockfd,
line,
999)) > 0){ /* Принятые данные отправляем
обратно */ if((n
= write(newsockfd,
line,
strlen(line)+1))
< 0){

perror(NULL);

closet
sockfd) ;

close(newsockfd);

exit(1)
;

}

}

/*
Если при чтении возникла ошибка —
завершаем работу */ if(п
< 0){

perror(NULL);

close(sockfd);

close(newsockfd);

exit(1);

}

/*
Закрываем дескриптор присоединенного
сокета и уходим ожидать нового соединения
*/ close(newsockfd);

}

}

Наберите
и откомпилируйте программу. Запустите
ее на выполнение. Модифицируйте текст
программы ТСР-клиента (программа 14—
15-З.с), заменив номер порта с 7 на 51000.
Запустите клиента с другого виртуального
терминала или с другого компьютера и
убедитесь, что клиент и сервер
взаимодействуют корректно.

Создание
программы с параллельной обработкой
запросов клиентов

В
приведенном выше примере сервер
осуществлял последовательную обработку
запросов от разных клиентов. При таком
подходе клиенты могут подолгу простаивать
после установления соединения, ожидая
обслуживания. Поэтому обычно применяется
схема псевдопараллельной обработки
запросов. После приема установленного
соединения сервер порождает процесс-ребенок,
которому и поручает дальнейшую работу
с клиентом. Процесс-родитель закрывает
присоединенный сокет и уходит на ожидание
нового соединения. Схематично организация
такого сервера изображена на рис.
14-15.9.

Напишите,
откомпилируйте и запустите такой
параллельный сервер. Убедитесь в его
работоспособности. Не забудьте о
необходимости удаления зомби-процессов.

Применение
интерфейса сетевых вызовов для других
семейств протоколов. UNIX
Domain
протоколы. Файлы типа «сокет»

Рассмотренный
нами интерфейс умеет работать не только
со стеком протоколов TCP/IP, но и с другими
семействами протоколов. При этом
требуется лишь незначительное изменение
написанных с его помощью программ.
Рассмотрим действия, которые необходимо
выполнить для модернизации написанных
для TCP/IP программ под другое семейство
протоколов:

1. Изменяется
   тип сокета, поэтому для его точной
   спецификации нужно задавать другие
   параметры в системном вызове socket
   ().

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

3. Описание
   типов данных и предопределенных констант
   будет находиться в других include-файлах,
   поэтому потребуется заменить include-файлы
   <netinet/in.h>
   и
   <агра/inet.h>
   на
   файлы, относящиеся к выбранному семейству
   протоколов.

4. Может
   измениться способ вычисления фактической
   длины полного адреса сокета и указания
   его максимального размера.

И
все!!!

Давайте
подробнее рассмотрим эти изменения на
примере семейства UNIX
Domain
протоколов. Семейство UNIX
Domain
протоколов предназначено для общения
локальных процессов с использованием
интер фейса системных вызовов. Оно
содержит один потоковый и один
дата-граммный протокол. Никакой сетевой
интерфейс при этом не используется, а
вся передача информации реально
происходит через адресное пространство
ядра операционной системы. Многие
программы, взаимодействующие и с
локальными, и с удаленными процессами
(например, Х-ЭДпс!оу8),
для
локального общения используют этот
стек протоколов.

Процесс-ребенок

Закрытие
пассивного сокета

Ожидание
получения информации. Чтение информации

Обработка
информации

Отправление
ответа

Завершение
соединения. Закрытие присоединенного
сокета

closeQ

read
()

writeQ

cIose()

Закрытие
присоединенного сокета

closeQ

Окончание
работы

exit()

Рис.
14-15.9. Схема работы ТСР-сервера с
параллельной обработкой запросов

Поскольку
общение происходит в рамках одной
вычислительной системы, в полном адресе
сокета его удаленная часть отсутствует.
В качестве адресного пространства
портов — локальной части адреса —
выбрано адресное пространство, совпадающее
с множеством всех допустимых имен файлов
в файловой системе.

При
этом в качестве имени сокета требуется
задавать имя несуществующего еще файла
в директории, к которой у вас есть права
доступа как на запись, так и на чтение.
При настройке адреса (системный вызов
bind())
под этим именем будет создан файл типа
«сокет» — последний еще неизвестный
нам тип файла. Этот файл для сокетов
играет роль файла-метки типа FIFO
для именованных pip’oe.
Если на вашей машине функционируют
Х-Windows,
то вы сможете обнаружить такой файл в
директории с именем /стр/
. Xll-unix
—
это файл типа «сокет», служащий для
взаимодействия локальных процессов с
оконным сервером.

Для
хранения полного адреса сокета
используется структура следующего
вида, описанного в файле <sys/un.
h>:

struct
sockaddr __un{

short
sun_family; /* Избранное
семейство

протоколов
— всегда AF_UNIX
*/ char
sun_path[108];
/* Имя файла типа «сокет» */

};

Выбранное
имя файла мы будем копировать внутрь
структуры, используя функциюstrcpy().

Фактическая
длина полного адреса сокета, хранящегося
в структуре с именем my_addr,
может
быть вычислена следующим образом:
sizeof(short)+strlen(my_addr.sun_path).
В Linux
для этих целей можно использовать
специальный макрос языка С:

SUN_LEN(struct
sokaddr_un*)

Ниже
приведены тексты переписанных подсемейство
UNIX
Domain
протоколов клиента и сервера для сервиса
echo
(программы
14— 15-5.c
и
14—15-6.с), общающиеся через датаграммы.
Клиент использует сокет с именем АААА
в
текущей директории, а сервер — сокет с
именем ВВВВ.
Как
следует из описания типа данных, эти
имена (полные или относительные) не
должны по длине превышать 107 символов.
Комментарии даны лишь для изменений по
сравнению с программами 14—15—l.c
и 14— 15-2.c.

/*
A simple echo UNIX Domain datagrairan server */ #include
<sys/types.h> #include <sys/socket.h>

#include
<sys/un.h> /* Новый
include-файл
вместо

netinet/in.h
и
arpa/inet.h */ #include <string.h> #include <stdio.h>
#include <errno.h> #include <unistd.h> int main() {

int
sockfd; int clilen, n; char line[1000];

struct
sockaddr_un servaddr, cliaddr; /* новый

тип
данных под адреса сокетов */ if((sockfd
= socket(AF_UNIX,
SOCK_DGRAM,
0)) < 0) /* Изменен тип семейства протоколов
*/

{

perror(NULL);
exit (1) ;

}

bzero(&servaddr,
sizeof(servaddr));

servaddr.sun_family
= AF_UNIX; /* Изменен
тип

семейства
протоколов и имя поля в структуре */
strcpy(servaddr.sun_path,»ВВВВ»);
/* Локальный

адрес
сокета сервера — ВВВВ
— в текущей
директории */ if(bind(sockfd,
(struct
sockaddr
*) &servaddr,
SUN_LEN(&servaddr))
< 0) /* Изменено вычисление

фактической
длины адреса */

{

perror(NULL);
close(sockfd);
exit(1);

}

while(l)
{

clilen
= sizeof(struct sockaddr_un); /* Изменено

вычисление
максимальной
длины
для
адреса
клиента
*/ if((n = recvfrom(sockfd, line, 999, 0, (struct sockaddr *)
&cliaddr, &clilen)) < 0){

perror(NULL);

close(sockfd)
;

exit(1);

}

if(sendto(sockfd,
line, strlen(line), 0, (struct sockaddr *) &cliaddr, clilen) <
0){

perror(NULL);
close(sockfd); exit(1);

}

}

return
0;

}

/*
A simple echo UNIX Domain datagram client */ #include <sys/types.h>
#include <sys/socket.h>

#include
<sys/un.h> /* Новый
include-файл
вместо

netinet/in.h
и
arpa/inet.h */ #include <string.h> #include <stdio.h>
#include <errno.h> #include <unistd.h>

int
main()
/* Аргументы командной строки не нужны,
так как сервис является локальным, и не
нужно

указывать,
к какой машине мы обращаемся с запросом
*/

{

int
sockfd; int n, len;

char
sendline[1000], recvline[1000];

struct
sockaddr_un servaddr, cliaddr; /* новый

тип
данных под адреса сокетов */

if((sockfd
= socket(AF_UNIX, SOCK_DGRAM, 0)) < 0)

/*
Изменен тип семейства протоколов */

{

perror(NULL);
exit(1);

}

bzero(kcliaddr,
sizeof(cliaddr));

cliaddr.sun_family=
AF_UNIX;
/* Изменен тип

семейства
протоколов и имя поля в структуре */
strcpy(cliaddr.sun_path,»АААА»);/*
Локальный адрес

сокета
клиента — АААА — в текущей директории */
if(bind(sockfd,
(struct
sockaddr
*) kcliaddr,
SUN_LEN(kcliaddr))
< 0) /* Изменено вычисление

фактической
длины адреса */

{

perror(NULL);

close(sockfd);
exit(1)
;

}

bzero(&servaddr,
si zeof(servaddr));

servaddr.sun_family
= AF_UNIX; /* Изменен
тип

семейства
протоколов и имя поля в структуре */
strcpy(servaddr.sun_path,»ВВВВ»);
/* Локальный адрес

сокета
сервера — ВВВВ — в текущей директории */
printf(«String
=> «); fgets(sendline,
1000,
stdin);

if(sendto(sockfd,
sendline,
strlen(sendline)+1,
0,
(struct
sockaddr
*) &servaddr,
SUN_LEN(&servaddr))
< 0)
/*
Изменено вычисление фактической длины
адреса */

{

perror(NULL);
close(sockfd); exit (1) ;

}

if((n
= recvfrom(sockfd, recvline, 1000,
0,
(struct
sockaddr *) NULL, NULL)) < 0){

perror(NULL);

close(sockfd);

exit(1)
;

}

recvline[n]
= 0
;
printf(«%s»,
recvline); close(sockfd); return 0;

}

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

Создание
потоковых клиента и сервера для стека
UNIX
Domain
протоколов

По
аналогии с программами в предыдущем
примере модифицируйте тексты программ
TCP
клиента и сервера для сервиса echo
(программы
14—15-3.с и 14— 15-4.с) для потокового общения
в семействе UNIX
Domain
протоколов. Откомпилируйте их и убедитесь
в их правильном функционировании.

Литература

[Bach,
1986] [СС1ТТ, 1991]

[Denning,
1996] [DoD, 1993] [DTI, 1991]

[Intel,
1989] [Linnaes,1789]

[Ritchie,1984]

[Silberschatz,
2002]

[Stevens,
1990]

[Axo,
2001]

[Баурн,1986]
[Беляков,
1991]

[Блэк,
2001] [Брамм, 1990] [Вахалия, 2003] [Дейтел, 1987]
[Дунаев, 1996]

Bach
M.J. The design of the UNIX Operating System.— Prentice-Hall, 1986.

Security
Architecture for Open Systems Interconnection for CCITT Applications.
Recommendations X.800. CCITT. -Geneva. 1991.

Peter
J. Denning. Before memory was virtual, Draft, June 6th 1996, at
http://cne.gmu.edu/pjd/PUBS/bvm.pdf.
Department of Defense. Trusted Computer System Evaluation Criteria. —
DoD 5200.28, STD. 1993. Department of Trade and Industry. Information
Technology Security Evaluation Criteria (ITSEC). Harmonized Criteria
of France — Germany — the Netherlands — the United Kingdom. —
London. 1991. i486™ Microprocessor, Intel Corporation, 1989.
Linnaeus. Karl, Systema naturae, 13^lh
ed., t. 1-3 — Lugduni, 1789-96

Ritchie
D.M., The Evolution of the Unix Time-sharing System. // AT&T Bell
Laboratories Technical Journal 63

No.
6, Part 2, October 1984 — pp. 1577-93. Silberschatz A., P.B.Galvin,
Operating System Concepts, 6th edition. — John Willey & Sons,
2002.

Stevens
R. W,
Unix Network Programming — Prentice Hall, Inc., 1990, First
edition.

Axo
В., Хопкрофт Д., Ульман Д. Структуры данных
и алгоритмы. — М.: Вильяме, 2001. Баурн С.
Операционная система UNIX.
— М.: Мир. 1986. Беляков М.И., Рабовер Ю.И.,
Фридман А.Л. Мобильная операционная
система. — М.:, Радио и связь, 1991.

Блэк
У.
Интернет: протоколы безопасности.
Учебный курс. — Спб.: Издательский дом
Питер, 2001. Брамм П., Брамм Д. Микропроцессор
80386 и его применение. — М., Мир, 1990.

Вахалия
Ю. UNIX
изнутри. — Спб.: Издательский дом Питер,
2003.

Дейтел
Г.
Введение в операционные системы. — М.:
Мир, 1987.

Дунаев
С.
Unix. System V.
Release 4.2. — М.:
Диалог
МИФИ,
1996.

[Казаринов,
1990] Казаринов Ю.М., Номоконов В.М.,
Подклетнов Г.С., Филиппов Ф.М.
Микропроцессорный комплекс К1810. — М.:
Высшая школа, 1990.[Кастер, 1996] Кастер
Хелен. Основы Windows
NT
и NTFS.
— М.:

Русская
редакция.1996. [Керниган, 1992] Керниган Б.
В., Пайк P.
UNIX
— универсальная среда программирования.
— М.: Финансы и статистика. 1992. [Коффрон,
1983] Коффрон Дж. Технические средства
микропроцессорных систем. — М.: Мир,
1983.[Кузнецов] Кузнецов С.Д. Операционная
система UNIX.
— http://www.citforum.rU/operating_systems/unix/contents.s
html.

[Олифер,
2000] Олифер В.Г., Олифер Н.А. Новые технологии
и оборудование IP-сетей.
— Спб.: BHV,
2000. [Олифер, 2001] Олифер В.Г., Олифер Н.А.
Сетевые операционные системы. — Спб.:
Издательский дом Питер, 2001. [Олифер,
2002] Олифер В.Г., Олифер Н.А. Компьютерные
сети. Принципы, технологии, протоколы.
— Спб.: Издательский дом Питер, 2002.
[Снейдер, 2001] Снейдер Й. Эффективное
программирование TCP/IP. — Издательский
дом Питер, 2001. [Соломон, 2001] Соломон Д.,
Руссинович М. Внутреннее устройство
Microsoft
Windows
2000. — СПб: Издательский дом Питер,
М.: Русская редакция, 2001. [Стивене, 2002]
Стивене У.
UNIX:
Взаимодействие процессов. —

СПб:
Издательский дом Питер, 2002. [Стивене,
2003] Стивене У.
UNIX:
разработка сетевых приложений. —

СПб:
Издательский дом Питер, 2003. [Столлингс,
2001] Столлингс В., Операционные системы.
— М.:

Вильяме,
2001.

[Таненбаум,
2002] Таненбаум Э. Современные операционные

системы.
— СПб.: Издательский дом Питер, 2002.
[Таненбаум, 2003] Таненбаум Э. Компьютерные
сети. — СПб.:

Издательский
дом Питер, 2003. [Таненбаум II, 2003] Таненбаум
Э., Ван Стеен М. Распределенные системы.
Принципы и парадигмы. — СПб.:

Издательский
дом Питер, 2003. [Робачевский, 1999] Робачевский
А. Операционная система UNIX.
— Спб.: BHV,
1999.

[Цикритис,
1977] Цикритис Д., Бернстайн Ф. Операционные
системы. — М.: Мир. 1977.

Серия
«Основы информационных технологий»

Серия
учебных пособий «Основы информационных
технологий» открыта в издательстве
Интернет-Университета Информационных
Технологий в 2003 году и предполагает
издание более 100 книг. В настоящее время
в ее рамках вышли более 30
учебных пособий по самым разным
направлениям информационных и
коммуникационных технологий. Авторами
этой серии являются известные профессора
и преподаватели ведущих российских
вузов, а также представители компьютерного
бизнеса и академической среды. Ряд
учебных курсов создаются при активном
участии и поддержке ведущих отечественных
и иностранных компаний, а также
общественных организаций и коммерческих
ассоциаций в области информационных
технологий.

Книги
серии

1. Основы
Web-технологий,

П.Б.
Храмцови др., 2003, 512 с, ISBN
5-9556-0001-9.

2. Основы
сетей передачи данных,

В.Г.
Олифер, Н.А. Олифер, 2005, 176 с, ISBN
5-9556-0035-3.

Читать новости Linux в Telegram ✆

listen() — Unix, Linux System Call

Web This Site   Unix for Beginners   Unix Shell Programming   Advanced Unix   Unix Useful References   Unix Useful Resources   Selected Reading Copyright © 2014 by tutorialspoint

Home     References     Discussion Forums     About TP   Advertisements NAME listen — listen for connections on a socket SYNOPSIS #include <sys/socket.h> int listen(int sockfd, int backlog); DESCRIPTION To accept connections, a socket is first created with socket(2), a willingness to accept incoming connections and a queue limit for incoming connections are specified with listen(), and then the connections are accepted with accept(2). The listen() call applies only to sockets of type SOCK_STREAM or SOCK_SEQPACKET. The backlog parameter defines the maximum length the queue of pending connections may grow to. If a connection request arrives with the queue full the client may receive an error with an indication of ECONNREFUSED or, if the underlying protocol supports retransmission, the request may be ignored so that retries succeed. NOTES The behaviour of the backlog parameter on TCP sockets changed with Linux 2.2. Now it specifies the queue length for completely established sockets waiting to be accepted, instead of the number of incomplete connection requests. The maximum length of the queue for incomplete sockets can be set using the tcp_max_syn_backlog sysctl. When syncookies are enabled there is no logical maximum length and this sysctl setting is ignored. See tcp(7) for more information. RETURN VALUE On success, zero is returned. On error, -1 is returned, and errno is set appropriately. ERRORS Tag Description EADDRINUSE   Another socket is already listening on the same port. EBADF The argument sockfd is not a valid descriptor. ENOTSOCK   The argument sockfd is not a socket. EOPNOTSUPP   The socket is not of a type that supports the listen() operation. CONFORMING TO 4.4BSD, POSIX.1-2001. The listen() function call first appeared in 4.2BSD. BUGS If the socket is of type AF_INET, and the backlog argument is greater than the constant SOMAXCONN (128 in Linux 2.0 & 2.2), it is silently truncated to SOMAXCONN. SEE ALSO accept (2) bind (2) connect (2) socket (2) Advertisements

Advertisements

listen() — Unix, Linux System Call

Web This Site   Unix for Beginners   Unix Shell Programming   Advanced Unix   Unix Useful References   Unix Useful Resources   Selected Reading Copyright © 2014 by tutorialspoint

Home     References     Discussion Forums     About TP   Advertisements NAME listen — listen for connections on a socket SYNOPSIS #include <sys/socket.h> int listen(int sockfd, int backlog); DESCRIPTION To accept connections, a socket is first created with socket(2), a willingness to accept incoming connections and a queue limit for incoming connections are specified with listen(), and then the connections are accepted with accept(2). The listen() call applies only to sockets of type SOCK_STREAM or SOCK_SEQPACKET. The backlog parameter defines the maximum length the queue of pending connections may grow to. If a connection request arrives with the queue full the client may receive an error with an indication of ECONNREFUSED or, if the underlying protocol supports retransmission, the request may be ignored so that retries succeed. NOTES The behaviour of the backlog parameter on TCP sockets changed with Linux 2.2. Now it specifies the queue length for completely established sockets waiting to be accepted, instead of the number of incomplete connection requests. The maximum length of the queue for incomplete sockets can be set using the tcp_max_syn_backlog sysctl. When syncookies are enabled there is no logical maximum length and this sysctl setting is ignored. See tcp(7) for more information. RETURN VALUE On success, zero is returned. On error, -1 is returned, and errno is set appropriately. ERRORS Tag Description EADDRINUSE   Another socket is already listening on the same port. EBADF The argument sockfd is not a valid descriptor. ENOTSOCK   The argument sockfd is not a socket. EOPNOTSUPP   The socket is not of a type that supports the listen() operation. CONFORMING TO 4.4BSD, POSIX.1-2001. The listen() function call first appeared in 4.2BSD. BUGS If the socket is of type AF_INET, and the backlog argument is greater than the constant SOMAXCONN (128 in Linux 2.0 & 2.2), it is silently truncated to SOMAXCONN. SEE ALSO accept (2) bind (2) connect (2) socket (2) Advertisements

Advertisements