Lines Matching full:cb

58 	struct nvmf_tcp_command_buffer *cb;
99 	struct nvmf_tcp_command_buffer *cb;
101 	cb = malloc(sizeof(*cb));
102 	cb->qp = qp;
103 	cb->data = data;
104 	cb->data_offset = data_offset;
105 	cb->data_len = data_len;
106 	cb->data_xfered = 0;
107 	cb->cid = cid;
108 	cb->ttag = ttag;
111 		LIST_INSERT_HEAD(&qp->rx_buffers, cb, link);
113 		LIST_INSERT_HEAD(&qp->tx_buffers, cb, link);
114 	return (cb);
122 	struct nvmf_tcp_command_buffer *cb;
125 	LIST_FOREACH(cb, list, link) {
126 		if (cb->cid == cid && cb->ttag == ttag)
127 			return (cb);
136 	struct nvmf_tcp_command_buffer *cb;
138 	cb = tcp_find_command_buffer(qp, cid, ttag, receive);
139 	if (cb != NULL)
140 		LIST_REMOVE(cb, link);
144 tcp_free_command_buffer(struct nvmf_tcp_command_buffer *cb)
146 	LIST_REMOVE(cb, link);
147 	free(cb);
499 	struct nvmf_tcp_command_buffer *cb;
512 	cb = tcp_find_command_buffer(qp, h2c->cccid, h2c->ttag, true);
513 	if (cb == NULL) {
533 	if (data_offset < cb->data_offset ||
534 	    data_offset + data_len > cb->data_offset + cb->data_len) {
542 	if (data_offset != cb->data_offset + cb->data_xfered) {
550 	if ((cb->data_xfered + data_len == cb->data_len) !=
559 	cb->data_xfered += data_len;
560 	data_offset -= cb->data_offset;
562 	memcpy((char *)cb->data + data_offset, icd, data_len);
572 	struct nvmf_tcp_command_buffer *cb;
578 	cb = tcp_find_command_buffer(qp, c2h->cccid, 0, true);
579 	if (cb == NULL) {
603 	if (data_offset < cb->data_offset ||
604 	    data_offset + data_len > cb->data_offset + cb->data_len) {
612 	if (data_offset != cb->data_offset + cb->data_xfered) {
620 	if ((cb->data_xfered + data_len == cb->data_len) !=
629 	cb->data_xfered += data_len;
630 	data_offset -= cb->data_offset;
632 	memcpy((char *)cb->data + data_offset, icd, data_len);
640 		cqe.cid = cb->cid;
704 	struct nvmf_tcp_command_buffer *cb;
711 	cb = tcp_find_command_buffer(qp, r2t->cccid, 0, false);
712 	if (cb == NULL) {
722 	if (data_offset != cb->data_xfered) {
735 	if (data_offset + data_len > cb->data_len) {
743 	cb->data_xfered += data_len;
750 	    data_offset, (char *)cb->data + data_offset, data_len, true);
1119 	struct nvmf_tcp_command_buffer *ncb, *cb;
1125 	LIST_FOREACH_SAFE(cb, &qp->rx_buffers, link, ncb) {
1126 		tcp_free_command_buffer(cb);
1128 	LIST_FOREACH_SAFE(cb, &qp->tx_buffers, link, ncb) {
1129 		tcp_free_command_buffer(cb);
1183 	if (tc->cb != NULL)
1184 		tcp_free_command_buffer(tc->cb);
1231 		tc->cb = tcp_alloc_command_buffer(qp, nc->nc_data, 0,
1341 	struct nvmf_tcp_command_buffer *cb;
1355 	cb = tcp_alloc_command_buffer(qp, buf, data_offset, len,
1359 	while (cb->data_xfered < cb->data_len) {
1364 	tcp_free_command_buffer(cb);