Lines Matching refs:acb

95     CURLAIOCB *acb[CURL_NUM_ACB];  member
274 CURLAIOCB *acb) in curl_find_buf() argument
299 qemu_iovec_from_buf(acb->qiov, 0, buf, clamped_len); in curl_find_buf()
301 qemu_iovec_memset(acb->qiov, clamped_len, 0, len - clamped_len); in curl_find_buf()
303 acb->ret = 0; in curl_find_buf()
316 acb->start = start - state->buf_start; in curl_find_buf()
317 acb->end = acb->start + clamped_len; in curl_find_buf()
320 if (!state->acb[j]) { in curl_find_buf()
321 state->acb[j] = acb; in curl_find_buf()
369 CURLAIOCB *acb = state->acb[i]; in curl_multi_check_completion() local
371 if (acb == NULL) { in curl_multi_check_completion()
377 assert(state->buf_off >= acb->end); in curl_multi_check_completion()
379 qemu_iovec_from_buf(acb->qiov, 0, in curl_multi_check_completion()
380 state->orig_buf + acb->start, in curl_multi_check_completion()
381 acb->end - acb->start); in curl_multi_check_completion()
383 if (acb->end - acb->start < acb->bytes) { in curl_multi_check_completion()
384 size_t offset = acb->end - acb->start; in curl_multi_check_completion()
385 qemu_iovec_memset(acb->qiov, offset, 0, in curl_multi_check_completion()
386 acb->bytes - offset); in curl_multi_check_completion()
390 acb->ret = error ? -EIO : 0; in curl_multi_check_completion()
391 state->acb[i] = NULL; in curl_multi_check_completion()
393 aio_co_wake(acb->co); in curl_multi_check_completion()
560 assert(!s->acb[j]); in curl_clean_state()
893 static void coroutine_fn curl_setup_preadv(BlockDriverState *bs, CURLAIOCB *acb) in curl_setup_preadv() argument
900 uint64_t start = acb->offset; in curl_setup_preadv()
907 if (curl_find_buf(s, start, acb->bytes, acb)) { in curl_setup_preadv()
922 acb->ret = -EIO; in curl_setup_preadv()
926 acb->start = 0; in curl_setup_preadv()
927 acb->end = MIN(acb->bytes, s->len - start); in curl_setup_preadv()
932 state->buf_len = MIN(acb->end + s->readahead_size, s->len - start); in curl_setup_preadv()
937 acb->ret = -ENOMEM; in curl_setup_preadv()
940 state->acb[0] = acb; in curl_setup_preadv()
943 trace_curl_setup_preadv(acb->bytes, start, state->range); in curl_setup_preadv()
946 state->acb[0] = NULL; in curl_setup_preadv()
947 acb->ret = -EIO; in curl_setup_preadv()
964 CURLAIOCB acb = { in curl_co_preadv() local
972 curl_setup_preadv(bs, &acb); in curl_co_preadv()
973 while (acb.ret == -EINPROGRESS) { in curl_co_preadv()
976 return acb.ret; in curl_co_preadv()