usr.sbin/ctld/pdu.c

48 pdu_ahs_length(const struct pdu *pdu)
51 	return (pdu->pdu_bhs->bhs_total_ahs_len * 4);
55 pdu_data_segment_length(const struct pdu *pdu)
59 	len += pdu->pdu_bhs->bhs_data_segment_len[0];
61 	len += pdu->pdu_bhs->bhs_data_segment_len[1];
63 	len += pdu->pdu_bhs->bhs_data_segment_len[2];
69 pdu_set_data_segment_length(struct pdu *pdu, uint32_t len)
72 	pdu->pdu_bhs->bhs_data_segment_len[2] = len;
73 	pdu->pdu_bhs->bhs_data_segment_len[1] = len >> 8;
74 	pdu->pdu_bhs->bhs_data_segment_len[0] = len >> 16;
77 struct pdu *
80 	struct pdu *pdu;
82 	pdu = calloc(sizeof(*pdu), 1);
83 	if (pdu == NULL)
86 	pdu->pdu_bhs = calloc(sizeof(*pdu->pdu_bhs), 1);
87 	if (pdu->pdu_bhs == NULL)
90 	pdu->pdu_connection = conn;
92 	return (pdu);
95 struct pdu *
96 pdu_new_response(struct pdu *request)
105 pdu_receive(struct pdu *pdu)
109 	kernel_receive(pdu);
111 	len = pdu_ahs_length(pdu);
115 	len = pdu_data_segment_length(pdu);
117 	pdu->pdu_data_len = len;
121 pdu_send(struct pdu *pdu)
124 	pdu_set_data_segment_length(pdu, pdu->pdu_data_len);
125 	kernel_send(pdu);
131 pdu_padding(const struct pdu *pdu)
134 	if ((pdu->pdu_data_len % 4) != 0)
135 		return (4 - (pdu->pdu_data_len % 4));
159 pdu_receive(struct pdu *pdu)
164 	pdu_read(pdu->pdu_connection->conn_socket,
165 	    (char *)pdu->pdu_bhs, sizeof(*pdu->pdu_bhs));
167 	len = pdu_ahs_length(pdu);
171 	len = pdu_data_segment_length(pdu);
179 		pdu->pdu_data_len = len;
180 		pdu->pdu_data = malloc(len);
181 		if (pdu->pdu_data == NULL)
184 		pdu_read(pdu->pdu_connection->conn_socket,
185 		    (char *)pdu->pdu_data, pdu->pdu_data_len);
187 		padding = pdu_padding(pdu);
190 			pdu_read(pdu->pdu_connection->conn_socket,
197 pdu_send(struct pdu *pdu)
205 	pdu_set_data_segment_length(pdu, pdu->pdu_data_len);
206 	iov[0].iov_base = pdu->pdu_bhs;
207 	iov[0].iov_len = sizeof(*pdu->pdu_bhs);
211 	if (pdu->pdu_data_len > 0) {
212 		iov[1].iov_base = pdu->pdu_data;
213 		iov[1].iov_len = pdu->pdu_data_len;
217 		padding = pdu_padding(pdu);
227 	ret = writev(pdu->pdu_connection->conn_socket, iov, iovcnt);
240 pdu_delete(struct pdu *pdu)
243 	free(pdu->pdu_data);
244 	free(pdu->pdu_bhs);
245 	free(pdu);