Lines Matching full:copied
166 long copied;
169 * If this job had copied data out of the socket buffer before
173 copied = job->aio_received;
174 if (copied != 0 || error == 0)
175 aio_complete(job, copied, 0);
469 long copied;
506 copied = job->aio_received;
508 if (placed > job->uaiocb.aio_nbytes - copied)
509 placed = job->uaiocb.aio_nbytes - copied;
517 * Update the copied length for when
522 } else if (copied + placed != 0) {
524 "%s: completing %p (copied %ld, placed %lu)",
525 __func__, job, copied, placed);
527 aio_complete(job, copied + placed, 0);
649 long copied;
736 * Update the copied length for when
741 copied = job->aio_received;
744 "%s: tid %u, completing %p (copied %ld, placed %d)",
745 __func__, toep->tid, job, copied, len);
747 aio_complete(job, copied + len, 0);
1024 long copied;
1064 copied = job->aio_received;
1065 if (copied == 0) {
1069 CTR3(KTR_CXGBE, "%s: completing %p (copied %ld)",
1070 __func__, job, copied);
1071 aio_complete(job, copied, 0);
1096 long copied;
1138 copied = job->aio_received;
1140 if (placed > job->uaiocb.aio_nbytes - copied)
1141 placed = job->uaiocb.aio_nbytes - copied;
1149 * Update the copied length for when
1157 aio_complete(job, copied + placed, 0);
2286 long copied;
2289 * If this job had copied data out of the socket buffer before
2293 copied = job->aio_received;
2294 if (copied != 0)
2295 aio_complete(job, copied, 0);
2327 size_t copied, offset, resid;
2374 * If this job has previously copied some data, report
2378 copied = job->aio_received;
2379 if (copied != 0) {
2381 aio_complete(job, copied, 0);
2452 copied = job->aio_received;
2453 if (copied != 0) {
2456 aio_complete(job, copied, 0);
2501 copied = 0;
2526 error = uiomove_fromphys(ps->pages, offset + copied,
2529 uiomove_fromphys(ps->pages, offset + copied, uio.uio_resid, &uio);
2532 copied += uio.uio_offset;
2536 if (copied != 0) {
2537 sbdrop_locked(sb, copied);
2538 job->aio_received += copied;
2540 copied = job->aio_received;
2572 aio_complete(job, copied, 0);