Операционная система UNIX - Робачевский Андрей Михайлович
Шрифт:
Интервал:
Закладка:
req.addr.maxlen = sizeof(serv_addr);
req.addr.len = sizeof(serv_addr);
req.addr.buf = (char*)&serv_addr;
/* Максимальное число запросов, ожидающих обработки,
установим равным 5 */
req.qlen = 5;
/* Свяжем узел с запросом */
if (t_bind(tn, &req, (struct t_bind*)0) < 0) {
t_error("Ошибка вызова t_bind();
exit(1);
}
fprintf(stderr, "Адрес сервера: %sn",
inet_ntoa(serv_addr.sin_addr));
/* Поскольку в структуре t_call нам понадобится только буфер
для хранения адреса клиента, разместим ее динамически */
if ((call =
(struct t_call*)t_alloc(tn, T_CALL, T_ADDR)) == NULL) {
t_error("Ошибка вызова t_alloc()");
exit(2);
}
call->addr.maxlen = sizeof(serv_addr);
call->addr.len = sizeof(srv_addr);
call->opt.len = 0;
call->update.len = 0;
/* Бесконечный цикл получения и обработки запросов */
while (1) {
/* Ждем поступления запроса на установление соединения */
if (t_listen(s, call) < 0) {
t_error("Ошибка вызова t_listen()");
exit(1);
}
/* Выведем информацию о клиенте, сделавшем запрос */
clnt_addr = (struct sockaddr_in*)call->addr.buf;
printf("Клиент: %sn", inet_ntoa(clnt_addr->sin_addr));
/* Создадим транспортный узел для обслуживания запроса */
if (ntn = t_open("/dev/tcp", O_RDWR, (struct t_info*)0)) < 0) {
t_error("Ошибка вызова t_open()");
exit(1);
}
/* Пусть система сама свяжет его с подходящим адресом */
if (t_bind(ntn, (struct t_bind*)0), (struct t_bind*)0) < 0) {
t_error("Ошибка вызова t_accept()");
exit(1);
}
/* Примем запрос и переведем его обслуживание на новый
транспортный узел */
if (t_accept(tn, ntn, call) < 0) {
t_error("Ошибка вызова t_accept()");
exit(1);
}
/* Создадим новый процесс для обслуживания запроса.
При этом родительский процесс продолжает принимать
запросы от клиентов */
if ((pid = fork()) == -1) {
t_error("Ошибка вызова fork()");
exit(1);
}
if (pid == 0) {
int nbytes;
/* Дочерний процесс: этот транспортный узел уже не нужен,
он используется родителем */
close(tn);
while ((nbytes = t_rcv(ntn, buf,
sizeof(buf), &flags)) != 0) {
t_snd(ntn, buf, sizeof(buf), 0);
}
t_close(ntn);
exit(0);
}
/* Родительский процесс: этот транспортный узел не нужен,
он используется дочерним процессом для обмена данными
с клиентом */
t_close(ntn);
}
t_close(ntn);
}
Клиент#include <sys/types.h>
#include <sys/socket.h>
#include <tiuser.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <fcntl.h>
#include <netdb.h>
#define PORTNUM 1500
main(argc, argv)
char *argv[];
int argc;
{
int tn;
int flags;
struct sockaddr_in serv_addr;
struct hostent *hp;
char buf[80]="Здравствуй, мир!";
struct t_call* call;
/* В качестве аргумента клиенту передается доменное имя хоста,
на котором запущен сервер. Произведем трансляцию доменного
имени в адрес */
if ((hp = gethostbyname(argv[1])) == 0) {
