cxgbe/tom/t4_ddp.c

170 	long copied;
173 	 * If this job had copied data out of the socket buffer before
177 	copied = job->aio_received;
178 	if (copied != 0 || error == 0)
179 		aio_complete(job, copied, 0);
301 	long copied;
321 		copied = job->aio_received;
323 		if (placed > job->uaiocb.aio_nbytes - copied)
324 			placed = job->uaiocb.aio_nbytes - copied;
329 			 * Update the copied length for when
334 		} else if (copied + placed != 0) {
336 			    "%s: completing %p (copied %ld, placed %lu)",
337 			    __func__, job, copied, placed);
339 			aio_complete(job, copied + placed, 0);
490 	long copied;
574 		 * Update the copied length for when
579 		copied = job->aio_received;
581 		CTR4(KTR_CXGBE, "%s: completing %p (copied %ld, placed %d)",
582 		    __func__, job, copied, len);
584 		aio_complete(job, copied + len, 0);
638 	long copied;
676 		copied = job->aio_received;
677 		if (copied == 0) {
681 			CTR3(KTR_CXGBE, "%s: completing %p (copied %ld)",
682 			    __func__, job, copied);
683 			aio_complete(job, copied, 0);
706 	long copied;
723 		copied = job->aio_received;
725 		if (placed > job->uaiocb.aio_nbytes - copied)
726 			placed = job->uaiocb.aio_nbytes - copied;
731 			 * Update the copied length for when
739 			aio_complete(job, copied + placed, 0);
1407 	long copied;
1410 	 * If this job had copied data out of the socket buffer before
1414 	copied = job->aio_received;
1415 	if (copied != 0)
1416 		aio_complete(job, copied, 0);
1448 	size_t copied, offset, resid;
1495 		 * If this job has previously copied some data, report
1499 		copied = job->aio_received;
1500 		if (copied != 0) {
1502 			aio_complete(job, copied, 0);
1573 		copied = job->aio_received;
1574 		if (copied != 0) {
1577 			aio_complete(job, copied, 0);
1622 	copied = 0;
1644 		error = uiomove_fromphys(ps->pages, offset + copied,
1647 		copied += uio.uio_offset;
1651 	if (copied != 0) {
1652 		sbdrop_locked(sb, copied);
1653 		job->aio_received += copied;
1655 		copied = job->aio_received;
1687 			aio_complete(job, copied, 0);