Lines Matching refs:wdata
2195 struct cifs_writedata *wdata; in wdata_alloc_and_fillpages() local
2197 wdata = cifs_writedata_alloc((unsigned int)tofind, in wdata_alloc_and_fillpages()
2199 if (!wdata) in wdata_alloc_and_fillpages()
2203 PAGECACHE_TAG_DIRTY, tofind, wdata->pages); in wdata_alloc_and_fillpages()
2204 return wdata; in wdata_alloc_and_fillpages()
2208 wdata_prepare_pages(struct cifs_writedata *wdata, unsigned int found_pages, in wdata_prepare_pages() argument
2217 page = wdata->pages[i]; in wdata_prepare_pages()
2268 wdata->pages[i] = page; in wdata_prepare_pages()
2275 *index = wdata->pages[0]->index + 1; in wdata_prepare_pages()
2279 put_page(wdata->pages[i]); in wdata_prepare_pages()
2280 wdata->pages[i] = NULL; in wdata_prepare_pages()
2287 wdata_send_pages(struct cifs_writedata *wdata, unsigned int nr_pages, in wdata_send_pages() argument
2292 wdata->sync_mode = wbc->sync_mode; in wdata_send_pages()
2293 wdata->nr_pages = nr_pages; in wdata_send_pages()
2294 wdata->offset = page_offset(wdata->pages[0]); in wdata_send_pages()
2295 wdata->pagesz = PAGE_SIZE; in wdata_send_pages()
2296 wdata->tailsz = min(i_size_read(mapping->host) - in wdata_send_pages()
2297 page_offset(wdata->pages[nr_pages - 1]), in wdata_send_pages()
2299 wdata->bytes = ((nr_pages - 1) * PAGE_SIZE) + wdata->tailsz; in wdata_send_pages()
2300 wdata->pid = wdata->cfile->pid; in wdata_send_pages()
2302 rc = adjust_credits(wdata->server, &wdata->credits, wdata->bytes); in wdata_send_pages()
2306 if (wdata->cfile->invalidHandle) in wdata_send_pages()
2309 rc = wdata->server->ops->async_writev(wdata, in wdata_send_pages()
2323 struct cifs_writedata *wdata; in cifs_writepages() local
2375 wdata = wdata_alloc_and_fillpages(tofind, mapping, end, &index, in cifs_writepages()
2377 if (!wdata) { in cifs_writepages()
2385 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2390 nr_pages = wdata_prepare_pages(wdata, found_pages, mapping, wbc, in cifs_writepages()
2395 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2400 wdata->credits = credits_on_stack; in cifs_writepages()
2401 wdata->cfile = cfile; in cifs_writepages()
2402 wdata->server = server; in cifs_writepages()
2405 if (!wdata->cfile) { in cifs_writepages()
2413 rc = wdata_send_pages(wdata, nr_pages, mapping, wbc); in cifs_writepages()
2416 unlock_page(wdata->pages[i]); in cifs_writepages()
2420 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_writepages()
2424 wdata->pages[i]); in cifs_writepages()
2426 SetPageError(wdata->pages[i]); in cifs_writepages()
2427 end_page_writeback(wdata->pages[i]); in cifs_writepages()
2428 put_page(wdata->pages[i]); in cifs_writepages()
2433 kref_put(&wdata->refcount, cifs_writedata_release); in cifs_writepages()
2726 struct cifs_writedata *wdata = container_of(refcount, in cifs_uncached_writedata_release() local
2729 kref_put(&wdata->ctx->refcount, cifs_aio_ctx_release); in cifs_uncached_writedata_release()
2730 for (i = 0; i < wdata->nr_pages; i++) in cifs_uncached_writedata_release()
2731 put_page(wdata->pages[i]); in cifs_uncached_writedata_release()
2740 struct cifs_writedata *wdata = container_of(work, in cifs_uncached_writev_complete() local
2742 struct inode *inode = d_inode(wdata->cfile->dentry); in cifs_uncached_writev_complete()
2746 cifs_update_eof(cifsi, wdata->offset, wdata->bytes); in cifs_uncached_writev_complete()
2751 complete(&wdata->done); in cifs_uncached_writev_complete()
2752 collect_uncached_write_data(wdata->ctx); in cifs_uncached_writev_complete()
2754 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in cifs_uncached_writev_complete()
2758 wdata_fill_from_iovec(struct cifs_writedata *wdata, struct iov_iter *from, in wdata_fill_from_iovec() argument
2767 copied = copy_page_from_iter(wdata->pages[i], 0, bytes, from); in wdata_fill_from_iovec()
2800 cifs_resend_wdata(struct cifs_writedata *wdata, struct list_head *wdata_list, in cifs_resend_wdata() argument
2806 struct TCP_Server_Info *server = wdata->server; in cifs_resend_wdata()
2809 if (wdata->cfile->invalidHandle) { in cifs_resend_wdata()
2810 rc = cifs_reopen_file(wdata->cfile, false); in cifs_resend_wdata()
2824 rc = server->ops->wait_mtu_credits(server, wdata->bytes, in cifs_resend_wdata()
2829 if (wsize < wdata->bytes) { in cifs_resend_wdata()
2833 } while (wsize < wdata->bytes); in cifs_resend_wdata()
2834 wdata->credits = credits; in cifs_resend_wdata()
2836 rc = adjust_credits(server, &wdata->credits, wdata->bytes); in cifs_resend_wdata()
2839 if (wdata->cfile->invalidHandle) in cifs_resend_wdata()
2843 if (wdata->mr) { in cifs_resend_wdata()
2844 wdata->mr->need_invalidate = true; in cifs_resend_wdata()
2845 smbd_deregister_mr(wdata->mr); in cifs_resend_wdata()
2846 wdata->mr = NULL; in cifs_resend_wdata()
2849 rc = server->ops->async_writev(wdata, in cifs_resend_wdata()
2856 list_add_tail(&wdata->list, wdata_list); in cifs_resend_wdata()
2861 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_resend_wdata()
2865 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in cifs_resend_wdata()
2878 struct cifs_writedata *wdata; in cifs_write_from_iter() local
2937 wdata = cifs_writedata_direct_alloc(pagevec, in cifs_write_from_iter()
2939 if (!wdata) { in cifs_write_from_iter()
2946 wdata->page_offset = start; in cifs_write_from_iter()
2947 wdata->tailsz = in cifs_write_from_iter()
2954 wdata = cifs_writedata_alloc(nr_pages, in cifs_write_from_iter()
2956 if (!wdata) { in cifs_write_from_iter()
2962 rc = cifs_write_allocate_pages(wdata->pages, nr_pages); in cifs_write_from_iter()
2964 kvfree(wdata->pages); in cifs_write_from_iter()
2965 kfree(wdata); in cifs_write_from_iter()
2972 wdata, from, &cur_len, &num_pages); in cifs_write_from_iter()
2975 put_page(wdata->pages[i]); in cifs_write_from_iter()
2976 kvfree(wdata->pages); in cifs_write_from_iter()
2977 kfree(wdata); in cifs_write_from_iter()
2987 put_page(wdata->pages[nr_pages - 1]); in cifs_write_from_iter()
2989 wdata->tailsz = cur_len - ((nr_pages - 1) * PAGE_SIZE); in cifs_write_from_iter()
2992 wdata->sync_mode = WB_SYNC_ALL; in cifs_write_from_iter()
2993 wdata->nr_pages = nr_pages; in cifs_write_from_iter()
2994 wdata->offset = (__u64)offset; in cifs_write_from_iter()
2995 wdata->cfile = cifsFileInfo_get(open_file); in cifs_write_from_iter()
2996 wdata->server = server; in cifs_write_from_iter()
2997 wdata->pid = pid; in cifs_write_from_iter()
2998 wdata->bytes = cur_len; in cifs_write_from_iter()
2999 wdata->pagesz = PAGE_SIZE; in cifs_write_from_iter()
3000 wdata->credits = credits_on_stack; in cifs_write_from_iter()
3001 wdata->ctx = ctx; in cifs_write_from_iter()
3004 rc = adjust_credits(server, &wdata->credits, wdata->bytes); in cifs_write_from_iter()
3007 if (wdata->cfile->invalidHandle) in cifs_write_from_iter()
3010 rc = server->ops->async_writev(wdata, in cifs_write_from_iter()
3015 add_credits_and_wake_if(server, &wdata->credits, 0); in cifs_write_from_iter()
3016 kref_put(&wdata->refcount, in cifs_write_from_iter()
3026 list_add_tail(&wdata->list, wdata_list); in cifs_write_from_iter()
3037 struct cifs_writedata *wdata, *tmp; in collect_uncached_write_data() local
3060 list_for_each_entry_safe(wdata, tmp, &ctx->list, list) { in collect_uncached_write_data()
3062 if (!try_wait_for_completion(&wdata->done)) { in collect_uncached_write_data()
3067 if (wdata->result) in collect_uncached_write_data()
3068 rc = wdata->result; in collect_uncached_write_data()
3070 ctx->total_len += wdata->bytes; in collect_uncached_write_data()
3078 list_del_init(&wdata->list); in collect_uncached_write_data()
3082 wdata, &tmp_list, ctx); in collect_uncached_write_data()
3085 wdata->offset - ctx->pos); in collect_uncached_write_data()
3087 rc = cifs_write_from_iter(wdata->offset, in collect_uncached_write_data()
3088 wdata->bytes, &tmp_from, in collect_uncached_write_data()
3092 kref_put(&wdata->refcount, in collect_uncached_write_data()
3100 list_del_init(&wdata->list); in collect_uncached_write_data()
3101 kref_put(&wdata->refcount, cifs_uncached_writedata_release); in collect_uncached_write_data()