Lines Matching defs: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);
2298 long copied;
2301 * If this job had copied data out of the socket buffer before
2305 copied = job->aio_received;
2306 if (copied != 0)
2307 aio_complete(job, copied, 0);
2339 size_t copied, offset, resid;
2386 * If this job has previously copied some data, report
2390 copied = job->aio_received;
2391 if (copied != 0) {
2393 aio_complete(job, copied, 0);
2464 copied = job->aio_received;
2465 if (copied != 0) {
2468 aio_complete(job, copied, 0);
2513 copied = 0;
2538 error = uiomove_fromphys(ps->pages, offset + copied,
2541 uiomove_fromphys(ps->pages, offset + copied, uio.uio_resid, &uio);
2544 copied += uio.uio_offset;
2548 if (copied != 0) {
2549 sbdrop_locked(sb, copied);
2550 job->aio_received += copied;
2552 copied = job->aio_received;
2584 aio_complete(job, copied, 0);