dev/iscsi/icl_soft.c

145 icl_conn_receive(struct icl_conn *ic, size_t len)
155 	uio.uio_resid = len;
253 	uint32_t len = 0;
255 	len += request->ip_bhs->bhs_data_segment_len[0];
256 	len <<= 8;
257 	len += request->ip_bhs->bhs_data_segment_len[1];
258 	len <<= 8;
259 	len += request->ip_bhs->bhs_data_segment_len[2];
261 	return (len);
273 icl_pdu_set_data_segment_length(struct icl_pdu *response, uint32_t len)
276 	response->ip_bhs->bhs_data_segment_len[2] = len;
277 	response->ip_bhs->bhs_data_segment_len[1] = len >> 8;
278 	response->ip_bhs->bhs_data_segment_len[0] = len >> 16;
294 	size_t len;
298 	len = sizeof(struct iscsi_bhs) + response->ip_data_len +
301 		len += ISCSI_HEADER_DIGEST_SIZE;
303 		len += ISCSI_DATA_DIGEST_SIZE;
305 	return (len);
412 	size_t len;
414 	len = icl_pdu_data_segment_length(request);
415 	if (len == 0)
422 	KASSERT(len > request->ip_data_len, ("len <= request->ip_data_len"));
423 	len -= request->ip_data_len;
430 	if (len > partial_receive_len) {
433 		    len, partial_receive_len));
435 		len = partial_receive_len;
437 		return (len);
447 	if ((len % 4) != 0)
448 		len += 4 - (len % 4);
451 	ICL_DEBUG("need %zd bytes of data", len));
454 	return (len);
462 	size_t len, padding = 0;
470 	len = icl_pdu_data_segment_length(request);
471 	if (len == 0)
474 	if ((len % 4) != 0)
475 		padding = 4 - (len % 4);
480 	KASSERT(len > request->ip_data_len, ("len <= request->ip_data_len"));
481 	len -= request->ip_data_len;
483 	if (len + padding > *availablep) {
491 		    len + padding, *availablep - padding));
493 		len = *availablep - padding;
502 	if (len > 0) {
503 		m = icl_conn_receive(request->ip_conn, len + padding);
514 		request->ip_data_len += len;
515 		*availablep -= len + padding;
517 		ICL_DEBUG("len 0");
574 	size_t len;
620 		len = icl_pdu_data_segment_length(request);
621 		if (len > ic->ic_max_data_segment_length) {
626 			    len, ic->ic_max_data_segment_length);
876 	request->ip_bhs_mbuf->m_pkthdr.len = pdu_len;
964 				request->ip_bhs_mbuf->m_pkthdr.len += size2;
1082 icl_pdu_append_data(struct icl_pdu *request, const void *addr, size_t len,
1088 	KASSERT(len > 0, ("len == 0"));
1090 	newmb = m_getm2(NULL, len, flags, MT_DATA, M_PKTHDR);
1092 		ICL_WARN("failed to allocate mbuf for %zd bytes", len);
1097 		copylen = min(M_TRAILINGSPACE(mb), len - off);
1102 	KASSERT(off == len, ("%s: off != len", __func__));
1106 		request->ip_data_len = len;
1109 		request->ip_data_len += len;
1117     const void *addr, size_t len, int flags)
1120 	return (icl_pdu_append_data(request, addr, len, flags));
1124 icl_pdu_get_data(struct icl_pdu *ip, size_t off, void *addr, size_t len)
1127 	m_copydata(ip->ip_data_mbuf, off, len, addr);
1132     size_t off, void *addr, size_t len)
1135 	return (icl_pdu_get_data(ip, off, addr, len));