Lines Matching refs:wdata
2119 struct cifs_writedata *wdata; in wdata_alloc_and_fillpages() local
2121 wdata = cifs_writedata_alloc((unsigned int)tofind, in wdata_alloc_and_fillpages()
2123 if (!wdata) in wdata_alloc_and_fillpages()
2127 PAGECACHE_TAG_DIRTY, tofind, wdata->pages); in wdata_alloc_and_fillpages()
2128 return wdata; in wdata_alloc_and_fillpages()
2132 wdata_prepare_pages(struct cifs_writedata *wdata, unsigned int found_pages, in wdata_prepare_pages() argument
2141 page = wdata->pages[i]; in wdata_prepare_pages()
2192 wdata->pages[i] = page; in wdata_prepare_pages()
2199 *index = wdata->pages[0]->index + 1; in wdata_prepare_pages()
2203 put_page(wdata->pages[i]); in wdata_prepare_pages()
2204 wdata->pages[i] = NULL; in wdata_prepare_pages()
2211 wdata_send_pages(struct cifs_writedata *wdata, unsigned int nr_pages, in wdata_send_pages() argument
2216 tlink_tcon(wdata->cfile->tlink)->ses->server; in wdata_send_pages()
2218 wdata->sync_mode = wbc->sync_mode; in wdata_send_pages()
2219 wdata->nr_pages = nr_pages; in wdata_send_pages()
2220 wdata->offset = page_offset(wdata->pages[0]); in wdata_send_pages()
2221 wdata->pagesz = PAGE_SIZE; in wdata_send_pages()
2222 wdata->tailsz = min(i_size_read(mapping->host) - in wdata_send_pages()
2223 page_offset(wdata->pages[nr_pages - 1]), in wdata_send_pages()
2225 wdata->bytes = ((nr_pages - 1) * PAGE_SIZE) + wdata->tailsz; in wdata_send_pages()
2226 wdata->pid = wdata->cfile->pid; in wdata_send_pages()
2228 rc = adjust_credits(server, &wdata->credits, wdata->bytes); in wdata_send_pages()
2232 if (wdata->cfile->invalidHandle) in wdata_send_pages()
2235 rc = server->ops->async_writev(wdata, cifs_writedata_release); in wdata_send_pages()
2248 struct cifs_writedata *wdata; in cifs_writepages() local
2299 wdata = wdata_alloc_and_fillpages(tofind, mapping, end, &index, in cifs_writepages()
2301 if (!wdata) { in cifs_writepages()
2309 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2314 nr_pages = wdata_prepare_pages(wdata, found_pages, mapping, wbc, in cifs_writepages()
2319 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2324 wdata->credits = credits_on_stack; in cifs_writepages()
2325 wdata->cfile = cfile; in cifs_writepages()
2328 if (!wdata->cfile) { in cifs_writepages()
2336 rc = wdata_send_pages(wdata, nr_pages, mapping, wbc); in cifs_writepages()
2339 unlock_page(wdata->pages[i]); in cifs_writepages()
2343 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_writepages()
2347 wdata->pages[i]); in cifs_writepages()
2349 SetPageError(wdata->pages[i]); in cifs_writepages()
2350 end_page_writeback(wdata->pages[i]); in cifs_writepages()
2351 put_page(wdata->pages[i]); in cifs_writepages()
2356 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2644 struct cifs_writedata *wdata = container_of(refcount, in cifs_uncached_writedata_release() local
2647 kref_put(&wdata->ctx->refcount, cifs_aio_ctx_release); in cifs_uncached_writedata_release()
2648 for (i = 0; i < wdata->nr_pages; i++) in cifs_uncached_writedata_release()
2649 put_page(wdata->pages[i]); in cifs_uncached_writedata_release()
2658 struct cifs_writedata *wdata = container_of(work, in cifs_uncached_writev_complete() local
2660 struct inode *inode = d_inode(wdata->cfile->dentry); in cifs_uncached_writev_complete()
2664 cifs_update_eof(cifsi, wdata->offset, wdata->bytes); in cifs_uncached_writev_complete()
2669 complete(&wdata->done); in cifs_uncached_writev_complete()
2670 collect_uncached_write_data(wdata->ctx); in cifs_uncached_writev_complete()
2672 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in cifs_uncached_writev_complete()
2676 wdata_fill_from_iovec(struct cifs_writedata *wdata, struct iov_iter *from, in wdata_fill_from_iovec() argument
2685 copied = copy_page_from_iter(wdata->pages[i], 0, bytes, from); in wdata_fill_from_iovec()
2718 cifs_resend_wdata(struct cifs_writedata *wdata, struct list_head *wdata_list, in cifs_resend_wdata() argument
2725 tlink_tcon(wdata->cfile->tlink)->ses->server; in cifs_resend_wdata()
2728 if (wdata->cfile->invalidHandle) { in cifs_resend_wdata()
2729 rc = cifs_reopen_file(wdata->cfile, false); in cifs_resend_wdata()
2743 rc = server->ops->wait_mtu_credits(server, wdata->bytes, in cifs_resend_wdata()
2748 if (wsize < wdata->bytes) { in cifs_resend_wdata()
2752 } while (wsize < wdata->bytes); in cifs_resend_wdata()
2753 wdata->credits = credits; in cifs_resend_wdata()
2755 rc = adjust_credits(server, &wdata->credits, wdata->bytes); in cifs_resend_wdata()
2758 if (wdata->cfile->invalidHandle) in cifs_resend_wdata()
2761 rc = server->ops->async_writev(wdata, in cifs_resend_wdata()
2767 list_add_tail(&wdata->list, wdata_list); in cifs_resend_wdata()
2772 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_resend_wdata()
2776 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in cifs_resend_wdata()
2789 struct cifs_writedata *wdata; in cifs_write_from_iter() local
2850 wdata = cifs_writedata_direct_alloc(pagevec, in cifs_write_from_iter()
2852 if (!wdata) { in cifs_write_from_iter()
2859 wdata->page_offset = start; in cifs_write_from_iter()
2860 wdata->tailsz = in cifs_write_from_iter()
2867 wdata = cifs_writedata_alloc(nr_pages, in cifs_write_from_iter()
2869 if (!wdata) { in cifs_write_from_iter()
2875 rc = cifs_write_allocate_pages(wdata->pages, nr_pages); in cifs_write_from_iter()
2877 kvfree(wdata->pages); in cifs_write_from_iter()
2878 kfree(wdata); in cifs_write_from_iter()
2885 wdata, from, &cur_len, &num_pages); in cifs_write_from_iter()
2888 put_page(wdata->pages[i]); in cifs_write_from_iter()
2889 kvfree(wdata->pages); in cifs_write_from_iter()
2890 kfree(wdata); in cifs_write_from_iter()
2900 put_page(wdata->pages[nr_pages - 1]); in cifs_write_from_iter()
2902 wdata->tailsz = cur_len - ((nr_pages - 1) * PAGE_SIZE); in cifs_write_from_iter()
2905 wdata->sync_mode = WB_SYNC_ALL; in cifs_write_from_iter()
2906 wdata->nr_pages = nr_pages; in cifs_write_from_iter()
2907 wdata->offset = (__u64)offset; in cifs_write_from_iter()
2908 wdata->cfile = cifsFileInfo_get(open_file); in cifs_write_from_iter()
2909 wdata->pid = pid; in cifs_write_from_iter()
2910 wdata->bytes = cur_len; in cifs_write_from_iter()
2911 wdata->pagesz = PAGE_SIZE; in cifs_write_from_iter()
2912 wdata->credits = credits_on_stack; in cifs_write_from_iter()
2913 wdata->ctx = ctx; in cifs_write_from_iter()
2916 rc = adjust_credits(server, &wdata->credits, wdata->bytes); in cifs_write_from_iter()
2919 if (wdata->cfile->invalidHandle) in cifs_write_from_iter()
2922 rc = server->ops->async_writev(wdata, in cifs_write_from_iter()
2927 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_write_from_iter()
2928 kref_put(&wdata->refcount, in cifs_write_from_iter()
2938 list_add_tail(&wdata->list, wdata_list); in cifs_write_from_iter()
2949 struct cifs_writedata *wdata, *tmp; in collect_uncached_write_data() local
2972 list_for_each_entry_safe(wdata, tmp, &ctx->list, list) { in collect_uncached_write_data()
2974 if (!try_wait_for_completion(&wdata->done)) { in collect_uncached_write_data()
2979 if (wdata->result) in collect_uncached_write_data()
2980 rc = wdata->result; in collect_uncached_write_data()
2982 ctx->total_len += wdata->bytes; in collect_uncached_write_data()
2990 list_del_init(&wdata->list); in collect_uncached_write_data()
2994 wdata, &tmp_list, ctx); in collect_uncached_write_data()
2997 wdata->offset - ctx->pos); in collect_uncached_write_data()
2999 rc = cifs_write_from_iter(wdata->offset, in collect_uncached_write_data()
3000 wdata->bytes, &tmp_from, in collect_uncached_write_data()
3004 kref_put(&wdata->refcount, in collect_uncached_write_data()
3012 list_del_init(&wdata->list); in collect_uncached_write_data()
3013 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in collect_uncached_write_data()