Шрифт:
28 ctlbuf.len = 0;
29 ctlbuf.buf = (char*)&rcvbuf;
30 flags = RS_HIPRI;
31 Getmsg(fd, &ctlbuf, NULL, &flags);
32 if (ctlbuf.len < (int)sizeof(long))
33 err_quit("tpi_connect: bad length from getmsg");
34 switch (rcvbuf.type) {
35 case T_OK_ACK:
36 break;
37 case T_ERROR_ACK:
38 if (ctlbuf.len < (int)sizeof(struct T_error_ack))
39 err_quit("tpi_connect: bad length for T_ERROR_ACK");
40 error_ack = (struct T_error_ack*)&rcvbuf;
41 err_quit("tpi_connect: T_ERROR_ACK from conn %d, %d)",
42 error_ack->TLI_error, error_ack->UNIX_error);
43 default:
44 err_quit("tpi connect, unexpected message type: &d", rcvbuf.type);
45 }
46 ctlbuf.maxlen = sizeof(conn_con);
47 ctlbuf.len = 0;
48 ctlbuf.buf = (char*)&conn_con;
49 flags = 0;
50 Getmsg(fd, &ctlbuf, NULL, &flags);
51 if (ctlbuf.len < (int)sizeof(long))
52 err_quit("tpi_connect2: bad length from getmsg");
53 switch (conn_con.msg_hdr.PRIM_type) {
54 case T_CONN_CON:
55 break;
56 case T_DISCON_IND:
57 if (ctlbuf.len < (int)sizeof(struct T_discon_ind))
58 err_quit("tpi_connect2: bad length for T_DISCON_IND");
59 discon_ind = (struct T_discon_ind*)&conn_con.msg_hdr;
60 err_quit("tpi_connect2: T_DISCON_IND from conn (%d)",
61 discon_ind->DISCON_reason);
62 default:
63 err_quit("tpi_connect2: unexpected message type. %d",
64 conn_con.msg_hdr PRIM_type);
65 }
66 }
Заполнение структуры запроса и отправка поставщику
18-26
В TPI определена структура T_conn_req
, содержащая адрес протокола и параметры для соединения:
struct T_conn_req {
long PRIM_type; /* T_CONN_REQ */
long DEST_length; /* длина адреса получателя */
long DEST_offset; /* смещение адреса получателя */
long OPT_length; /* длина параметров */
long OPT_offset; /* смещение параметров */
/* затем следуют адреса протокола и параметры соединения */
};
Как и в случае функции
tpi_bind
, мы определяем свою собственную структуру с именем conn_req
, которая включает в себя структуру T_conn_req
, а также содержит место для адреса протокола. Мы заполняем структуру conn_req
, обнуляя поля OPT_length
и OPT_offset
. Мы вызываем функцию putmsg
только с управляющей информацией и флагом 0 для отправки сообщения типа M_PROTO
вниз по потоку. Чтение ответа
27-45
Мы вызываем функцию getmsg
, ожидая получить в ответ либо сообщение T_OK_ACK
, если было начато установление соединения, либо сообщение T_ERROR_ACK
(которые мы уже показывали выше). В случае ошибки мы завершаем выполнение программы. Поскольку мы не знаем, сообщение какого типа мы получим, то определяем объединение с именем T_primitives
для приема всех возможных запросов и ответов и размещаем это объединение в памяти как входной буфер для управляющей информации при вызове функции getmsg
.