Lines Matching refs:wdata
2199 struct cifs_writedata *wdata; in wdata_alloc_and_fillpages() local
2201 wdata = cifs_writedata_alloc((unsigned int)tofind, in wdata_alloc_and_fillpages()
2203 if (!wdata) in wdata_alloc_and_fillpages()
2207 PAGECACHE_TAG_DIRTY, tofind, wdata->pages); in wdata_alloc_and_fillpages()
2208 return wdata; in wdata_alloc_and_fillpages()
2212 wdata_prepare_pages(struct cifs_writedata *wdata, unsigned int found_pages, in wdata_prepare_pages() argument
2221 page = wdata->pages[i]; in wdata_prepare_pages()
2272 wdata->pages[i] = page; in wdata_prepare_pages()
2279 *index = wdata->pages[0]->index + 1; in wdata_prepare_pages()
2283 put_page(wdata->pages[i]); in wdata_prepare_pages()
2284 wdata->pages[i] = NULL; in wdata_prepare_pages()
2291 wdata_send_pages(struct cifs_writedata *wdata, unsigned int nr_pages, in wdata_send_pages() argument
2296 wdata->sync_mode = wbc->sync_mode; in wdata_send_pages()
2297 wdata->nr_pages = nr_pages; in wdata_send_pages()
2298 wdata->offset = page_offset(wdata->pages[0]); in wdata_send_pages()
2299 wdata->pagesz = PAGE_SIZE; in wdata_send_pages()
2300 wdata->tailsz = min(i_size_read(mapping->host) - in wdata_send_pages()
2301 page_offset(wdata->pages[nr_pages - 1]), in wdata_send_pages()
2303 wdata->bytes = ((nr_pages - 1) * PAGE_SIZE) + wdata->tailsz; in wdata_send_pages()
2304 wdata->pid = wdata->cfile->pid; in wdata_send_pages()
2306 rc = adjust_credits(wdata->server, &wdata->credits, wdata->bytes); in wdata_send_pages()
2310 if (wdata->cfile->invalidHandle) in wdata_send_pages()
2313 rc = wdata->server->ops->async_writev(wdata, in wdata_send_pages()
2327 struct cifs_writedata *wdata; in cifs_writepages() local
2379 wdata = wdata_alloc_and_fillpages(tofind, mapping, end, &index, in cifs_writepages()
2381 if (!wdata) { in cifs_writepages()
2389 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2394 nr_pages = wdata_prepare_pages(wdata, found_pages, mapping, wbc, in cifs_writepages()
2399 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2404 wdata->credits = credits_on_stack; in cifs_writepages()
2405 wdata->cfile = cfile; in cifs_writepages()
2406 wdata->server = server; in cifs_writepages()
2409 if (!wdata->cfile) { in cifs_writepages()
2417 rc = wdata_send_pages(wdata, nr_pages, mapping, wbc); in cifs_writepages()
2420 unlock_page(wdata->pages[i]); in cifs_writepages()
2424 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_writepages()
2428 wdata->pages[i]); in cifs_writepages()
2430 SetPageError(wdata->pages[i]); in cifs_writepages()
2431 end_page_writeback(wdata->pages[i]); in cifs_writepages()
2432 put_page(wdata->pages[i]); in cifs_writepages()
2437 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2753 struct cifs_writedata *wdata = container_of(refcount, in cifs_uncached_writedata_release() local
2756 kref_put(&wdata->ctx->refcount, cifs_aio_ctx_release); in cifs_uncached_writedata_release()
2757 for (i = 0; i < wdata->nr_pages; i++) in cifs_uncached_writedata_release()
2758 put_page(wdata->pages[i]); in cifs_uncached_writedata_release()
2767 struct cifs_writedata *wdata = container_of(work, in cifs_uncached_writev_complete() local
2769 struct inode *inode = d_inode(wdata->cfile->dentry); in cifs_uncached_writev_complete()
2773 cifs_update_eof(cifsi, wdata->offset, wdata->bytes); in cifs_uncached_writev_complete()
2778 complete(&wdata->done); in cifs_uncached_writev_complete()
2779 collect_uncached_write_data(wdata->ctx); in cifs_uncached_writev_complete()
2781 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in cifs_uncached_writev_complete()
2785 wdata_fill_from_iovec(struct cifs_writedata *wdata, struct iov_iter *from, in wdata_fill_from_iovec() argument
2794 copied = copy_page_from_iter(wdata->pages[i], 0, bytes, from); in wdata_fill_from_iovec()
2827 cifs_resend_wdata(struct cifs_writedata *wdata, struct list_head *wdata_list, in cifs_resend_wdata() argument
2833 struct TCP_Server_Info *server = wdata->server; in cifs_resend_wdata()
2836 if (wdata->cfile->invalidHandle) { in cifs_resend_wdata()
2837 rc = cifs_reopen_file(wdata->cfile, false); in cifs_resend_wdata()
2851 rc = server->ops->wait_mtu_credits(server, wdata->bytes, in cifs_resend_wdata()
2856 if (wsize < wdata->bytes) { in cifs_resend_wdata()
2860 } while (wsize < wdata->bytes); in cifs_resend_wdata()
2861 wdata->credits = credits; in cifs_resend_wdata()
2863 rc = adjust_credits(server, &wdata->credits, wdata->bytes); in cifs_resend_wdata()
2866 if (wdata->cfile->invalidHandle) in cifs_resend_wdata()
2870 if (wdata->mr) { in cifs_resend_wdata()
2871 wdata->mr->need_invalidate = true; in cifs_resend_wdata()
2872 smbd_deregister_mr(wdata->mr); in cifs_resend_wdata()
2873 wdata->mr = NULL; in cifs_resend_wdata()
2876 rc = server->ops->async_writev(wdata, in cifs_resend_wdata()
2883 list_add_tail(&wdata->list, wdata_list); in cifs_resend_wdata()
2888 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_resend_wdata()
2892 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in cifs_resend_wdata()
2905 struct cifs_writedata *wdata; in cifs_write_from_iter() local
2964 wdata = cifs_writedata_direct_alloc(pagevec, in cifs_write_from_iter()
2966 if (!wdata) { in cifs_write_from_iter()
2973 wdata->page_offset = start; in cifs_write_from_iter()
2974 wdata->tailsz = in cifs_write_from_iter()
2981 wdata = cifs_writedata_alloc(nr_pages, in cifs_write_from_iter()
2983 if (!wdata) { in cifs_write_from_iter()
2989 rc = cifs_write_allocate_pages(wdata->pages, nr_pages); in cifs_write_from_iter()
2991 kvfree(wdata->pages); in cifs_write_from_iter()
2992 kfree(wdata); in cifs_write_from_iter()
2999 wdata, from, &cur_len, &num_pages); in cifs_write_from_iter()
3002 put_page(wdata->pages[i]); in cifs_write_from_iter()
3003 kvfree(wdata->pages); in cifs_write_from_iter()
3004 kfree(wdata); in cifs_write_from_iter()
3014 put_page(wdata->pages[nr_pages - 1]); in cifs_write_from_iter()
3016 wdata->tailsz = cur_len - ((nr_pages - 1) * PAGE_SIZE); in cifs_write_from_iter()
3019 wdata->sync_mode = WB_SYNC_ALL; in cifs_write_from_iter()
3020 wdata->nr_pages = nr_pages; in cifs_write_from_iter()
3021 wdata->offset = (__u64)offset; in cifs_write_from_iter()
3022 wdata->cfile = cifsFileInfo_get(open_file); in cifs_write_from_iter()
3023 wdata->server = server; in cifs_write_from_iter()
3024 wdata->pid = pid; in cifs_write_from_iter()
3025 wdata->bytes = cur_len; in cifs_write_from_iter()
3026 wdata->pagesz = PAGE_SIZE; in cifs_write_from_iter()
3027 wdata->credits = credits_on_stack; in cifs_write_from_iter()
3028 wdata->ctx = ctx; in cifs_write_from_iter()
3031 rc = adjust_credits(server, &wdata->credits, wdata->bytes); in cifs_write_from_iter()
3034 if (wdata->cfile->invalidHandle) in cifs_write_from_iter()
3037 rc = server->ops->async_writev(wdata, in cifs_write_from_iter()
3042 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_write_from_iter()
3043 kref_put(&wdata->refcount, in cifs_write_from_iter()
3053 list_add_tail(&wdata->list, wdata_list); in cifs_write_from_iter()
3064 struct cifs_writedata *wdata, *tmp; in collect_uncached_write_data() local
3087 list_for_each_entry_safe(wdata, tmp, &ctx->list, list) { in collect_uncached_write_data()
3089 if (!try_wait_for_completion(&wdata->done)) { in collect_uncached_write_data()
3094 if (wdata->result) in collect_uncached_write_data()
3095 rc = wdata->result; in collect_uncached_write_data()
3097 ctx->total_len += wdata->bytes; in collect_uncached_write_data()
3105 list_del_init(&wdata->list); in collect_uncached_write_data()
3109 wdata, &tmp_list, ctx); in collect_uncached_write_data()
3112 wdata->offset - ctx->pos); in collect_uncached_write_data()
3114 rc = cifs_write_from_iter(wdata->offset, in collect_uncached_write_data()
3115 wdata->bytes, &tmp_from, in collect_uncached_write_data()
3119 kref_put(&wdata->refcount, in collect_uncached_write_data()
3127 list_del_init(&wdata->list); in collect_uncached_write_data()
3128 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in collect_uncached_write_data()