aboutsummaryrefslogtreecommitdiffstats
path: root/net/sunrpc/xdr.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/sunrpc/xdr.c')
-rw-r--r--net/sunrpc/xdr.c22
1 files changed, 14 insertions, 8 deletions
diff --git a/net/sunrpc/xdr.c b/net/sunrpc/xdr.c
index 65b268d39782..b3ac3f72bf9c 100644
--- a/net/sunrpc/xdr.c
+++ b/net/sunrpc/xdr.c
@@ -176,21 +176,23 @@ xdr_inline_pages(struct xdr_buf *xdr, unsigned int offset,
176 xdr->buflen += len; 176 xdr->buflen += len;
177} 177}
178 178
179int 179ssize_t
180xdr_partial_copy_from_skb(struct xdr_buf *xdr, unsigned int base, 180xdr_partial_copy_from_skb(struct xdr_buf *xdr, unsigned int base,
181 skb_reader_t *desc, 181 skb_reader_t *desc,
182 skb_read_actor_t copy_actor) 182 skb_read_actor_t copy_actor)
183{ 183{
184 struct page **ppage = xdr->pages; 184 struct page **ppage = xdr->pages;
185 unsigned int len, pglen = xdr->page_len; 185 unsigned int len, pglen = xdr->page_len;
186 ssize_t copied = 0;
186 int ret; 187 int ret;
187 188
188 len = xdr->head[0].iov_len; 189 len = xdr->head[0].iov_len;
189 if (base < len) { 190 if (base < len) {
190 len -= base; 191 len -= base;
191 ret = copy_actor(desc, (char *)xdr->head[0].iov_base + base, len); 192 ret = copy_actor(desc, (char *)xdr->head[0].iov_base + base, len);
193 copied += ret;
192 if (ret != len || !desc->count) 194 if (ret != len || !desc->count)
193 return 0; 195 goto out;
194 base = 0; 196 base = 0;
195 } else 197 } else
196 base -= len; 198 base -= len;
@@ -214,8 +216,11 @@ xdr_partial_copy_from_skb(struct xdr_buf *xdr, unsigned int base,
214 * are small by default but can get huge. */ 216 * are small by default but can get huge. */
215 if (unlikely(*ppage == NULL)) { 217 if (unlikely(*ppage == NULL)) {
216 *ppage = alloc_page(GFP_ATOMIC); 218 *ppage = alloc_page(GFP_ATOMIC);
217 if (unlikely(*ppage == NULL)) 219 if (unlikely(*ppage == NULL)) {
218 return -ENOMEM; 220 if (copied == 0)
221 copied = -ENOMEM;
222 goto out;
223 }
219 } 224 }
220 225
221 len = PAGE_CACHE_SIZE; 226 len = PAGE_CACHE_SIZE;
@@ -233,16 +238,17 @@ xdr_partial_copy_from_skb(struct xdr_buf *xdr, unsigned int base,
233 } 238 }
234 flush_dcache_page(*ppage); 239 flush_dcache_page(*ppage);
235 kunmap_atomic(kaddr, KM_SKB_SUNRPC_DATA); 240 kunmap_atomic(kaddr, KM_SKB_SUNRPC_DATA);
241 copied += ret;
236 if (ret != len || !desc->count) 242 if (ret != len || !desc->count)
237 return 0; 243 goto out;
238 ppage++; 244 ppage++;
239 } while ((pglen -= len) != 0); 245 } while ((pglen -= len) != 0);
240copy_tail: 246copy_tail:
241 len = xdr->tail[0].iov_len; 247 len = xdr->tail[0].iov_len;
242 if (base < len) 248 if (base < len)
243 copy_actor(desc, (char *)xdr->tail[0].iov_base + base, len - base); 249 copied += copy_actor(desc, (char *)xdr->tail[0].iov_base + base, len - base);
244 250out:
245 return 0; 251 return copied;
246} 252}
247 253
248 254