uvm_bio.c revision 1.70 1 1.70 rmind /* $NetBSD: uvm_bio.c,v 1.70 2010/06/22 18:34:50 rmind Exp $ */
2 1.2 chs
3 1.13 chs /*
4 1.2 chs * Copyright (c) 1998 Chuck Silvers.
5 1.2 chs * All rights reserved.
6 1.2 chs *
7 1.2 chs * Redistribution and use in source and binary forms, with or without
8 1.2 chs * modification, are permitted provided that the following conditions
9 1.2 chs * are met:
10 1.2 chs * 1. Redistributions of source code must retain the above copyright
11 1.2 chs * notice, this list of conditions and the following disclaimer.
12 1.2 chs * 2. Redistributions in binary form must reproduce the above copyright
13 1.2 chs * notice, this list of conditions and the following disclaimer in the
14 1.2 chs * documentation and/or other materials provided with the distribution.
15 1.2 chs * 3. The name of the author may not be used to endorse or promote products
16 1.2 chs * derived from this software without specific prior written permission.
17 1.2 chs *
18 1.2 chs * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19 1.2 chs * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20 1.2 chs * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21 1.2 chs * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22 1.2 chs * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
23 1.2 chs * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
24 1.2 chs * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
25 1.2 chs * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
26 1.2 chs * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27 1.2 chs * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28 1.2 chs * SUCH DAMAGE.
29 1.2 chs *
30 1.2 chs */
31 1.2 chs
32 1.2 chs /*
33 1.33 chs * uvm_bio.c: buffered i/o object mapping cache
34 1.2 chs */
35 1.2 chs
36 1.21 lukem #include <sys/cdefs.h>
37 1.70 rmind __KERNEL_RCSID(0, "$NetBSD: uvm_bio.c,v 1.70 2010/06/22 18:34:50 rmind Exp $");
38 1.21 lukem
39 1.21 lukem #include "opt_uvmhist.h"
40 1.50 yamt #include "opt_ubc.h"
41 1.2 chs
42 1.2 chs #include <sys/param.h>
43 1.2 chs #include <sys/systm.h>
44 1.65 ad #include <sys/kmem.h>
45 1.2 chs #include <sys/kernel.h>
46 1.60 ad #include <sys/proc.h>
47 1.67 pooka #include <sys/vnode.h>
48 1.2 chs
49 1.2 chs #include <uvm/uvm.h>
50 1.2 chs
51 1.2 chs /*
52 1.2 chs * global data structures
53 1.2 chs */
54 1.2 chs
55 1.2 chs /*
56 1.2 chs * local functions
57 1.2 chs */
58 1.2 chs
59 1.39 thorpej static int ubc_fault(struct uvm_faultinfo *, vaddr_t, struct vm_page **,
60 1.44 drochner int, int, vm_prot_t, int);
61 1.39 thorpej static struct ubc_map *ubc_find_mapping(struct uvm_object *, voff_t);
62 1.2 chs
63 1.2 chs /*
64 1.2 chs * local data structues
65 1.2 chs */
66 1.2 chs
67 1.18 chs #define UBC_HASH(uobj, offset) \
68 1.18 chs (((((u_long)(uobj)) >> 8) + (((u_long)(offset)) >> PAGE_SHIFT)) & \
69 1.2 chs ubc_object.hashmask)
70 1.2 chs
71 1.18 chs #define UBC_QUEUE(offset) \
72 1.18 chs (&ubc_object.inactive[(((u_long)(offset)) >> ubc_winshift) & \
73 1.18 chs (UBC_NQUEUES - 1)])
74 1.18 chs
75 1.18 chs #define UBC_UMAP_ADDR(u) \
76 1.18 chs (vaddr_t)(ubc_object.kva + (((u) - ubc_object.umap) << ubc_winshift))
77 1.18 chs
78 1.18 chs
79 1.18 chs #define UMAP_PAGES_LOCKED 0x0001
80 1.18 chs #define UMAP_MAPPING_CACHED 0x0002
81 1.2 chs
82 1.2 chs struct ubc_map
83 1.2 chs {
84 1.2 chs struct uvm_object * uobj; /* mapped object */
85 1.2 chs voff_t offset; /* offset into uobj */
86 1.33 chs voff_t writeoff; /* write offset */
87 1.33 chs vsize_t writelen; /* write len */
88 1.18 chs int refcount; /* refcount on mapping */
89 1.18 chs int flags; /* extra state */
90 1.42 yamt int advice;
91 1.2 chs
92 1.2 chs LIST_ENTRY(ubc_map) hash; /* hash table */
93 1.2 chs TAILQ_ENTRY(ubc_map) inactive; /* inactive queue */
94 1.2 chs };
95 1.2 chs
96 1.2 chs static struct ubc_object
97 1.2 chs {
98 1.2 chs struct uvm_object uobj; /* glue for uvm_map() */
99 1.2 chs char *kva; /* where ubc_object is mapped */
100 1.2 chs struct ubc_map *umap; /* array of ubc_map's */
101 1.2 chs
102 1.2 chs LIST_HEAD(, ubc_map) *hash; /* hashtable for cached ubc_map's */
103 1.2 chs u_long hashmask; /* mask for hashtable */
104 1.2 chs
105 1.2 chs TAILQ_HEAD(ubc_inactive_head, ubc_map) *inactive;
106 1.2 chs /* inactive queues for ubc_map's */
107 1.2 chs
108 1.2 chs } ubc_object;
109 1.2 chs
110 1.63 yamt const struct uvm_pagerops ubc_pager = {
111 1.48 christos .pgo_fault = ubc_fault,
112 1.2 chs /* ... rest are NULL */
113 1.2 chs };
114 1.2 chs
115 1.2 chs int ubc_nwins = UBC_NWINS;
116 1.11 chs int ubc_winshift = UBC_WINSHIFT;
117 1.11 chs int ubc_winsize;
118 1.27 thorpej #if defined(PMAP_PREFER)
119 1.2 chs int ubc_nqueues;
120 1.2 chs #define UBC_NQUEUES ubc_nqueues
121 1.2 chs #else
122 1.2 chs #define UBC_NQUEUES 1
123 1.2 chs #endif
124 1.2 chs
125 1.50 yamt #if defined(UBC_STATS)
126 1.50 yamt
127 1.50 yamt #define UBC_EVCNT_DEFINE(name) \
128 1.50 yamt struct evcnt ubc_evcnt_##name = \
129 1.50 yamt EVCNT_INITIALIZER(EVCNT_TYPE_MISC, NULL, "ubc", #name); \
130 1.50 yamt EVCNT_ATTACH_STATIC(ubc_evcnt_##name);
131 1.50 yamt #define UBC_EVCNT_INCR(name) ubc_evcnt_##name.ev_count++
132 1.50 yamt
133 1.50 yamt #else /* defined(UBC_STATS) */
134 1.50 yamt
135 1.50 yamt #define UBC_EVCNT_DEFINE(name) /* nothing */
136 1.50 yamt #define UBC_EVCNT_INCR(name) /* nothing */
137 1.50 yamt
138 1.50 yamt #endif /* defined(UBC_STATS) */
139 1.50 yamt
140 1.50 yamt UBC_EVCNT_DEFINE(wincachehit)
141 1.50 yamt UBC_EVCNT_DEFINE(wincachemiss)
142 1.57 yamt UBC_EVCNT_DEFINE(faultbusy)
143 1.50 yamt
144 1.2 chs /*
145 1.2 chs * ubc_init
146 1.2 chs *
147 1.2 chs * init pager private data structures.
148 1.2 chs */
149 1.2 chs
150 1.2 chs void
151 1.2 chs ubc_init(void)
152 1.2 chs {
153 1.2 chs struct ubc_map *umap;
154 1.2 chs vaddr_t va;
155 1.2 chs int i;
156 1.15 simonb
157 1.15 simonb /*
158 1.15 simonb * Make sure ubc_winshift is sane.
159 1.15 simonb */
160 1.15 simonb if (ubc_winshift < PAGE_SHIFT)
161 1.15 simonb ubc_winshift = PAGE_SHIFT;
162 1.2 chs
163 1.2 chs /*
164 1.2 chs * init ubc_object.
165 1.2 chs * alloc and init ubc_map's.
166 1.2 chs * init inactive queues.
167 1.2 chs * alloc and init hashtable.
168 1.2 chs * map in ubc_object.
169 1.2 chs */
170 1.2 chs
171 1.38 yamt UVM_OBJ_INIT(&ubc_object.uobj, &ubc_pager, UVM_OBJ_KERN);
172 1.2 chs
173 1.65 ad ubc_object.umap = kmem_zalloc(ubc_nwins * sizeof(struct ubc_map),
174 1.65 ad KM_SLEEP);
175 1.7 enami if (ubc_object.umap == NULL)
176 1.7 enami panic("ubc_init: failed to allocate ubc_map");
177 1.2 chs
178 1.18 chs if (ubc_winshift < PAGE_SHIFT) {
179 1.18 chs ubc_winshift = PAGE_SHIFT;
180 1.18 chs }
181 1.2 chs va = (vaddr_t)1L;
182 1.2 chs #ifdef PMAP_PREFER
183 1.36 atatat PMAP_PREFER(0, &va, 0, 0); /* kernel is never topdown */
184 1.11 chs ubc_nqueues = va >> ubc_winshift;
185 1.11 chs if (ubc_nqueues == 0) {
186 1.11 chs ubc_nqueues = 1;
187 1.2 chs }
188 1.2 chs #endif
189 1.11 chs ubc_winsize = 1 << ubc_winshift;
190 1.65 ad ubc_object.inactive = kmem_alloc(UBC_NQUEUES *
191 1.65 ad sizeof(struct ubc_inactive_head), KM_SLEEP);
192 1.7 enami if (ubc_object.inactive == NULL)
193 1.7 enami panic("ubc_init: failed to allocate inactive queue heads");
194 1.2 chs for (i = 0; i < UBC_NQUEUES; i++) {
195 1.2 chs TAILQ_INIT(&ubc_object.inactive[i]);
196 1.2 chs }
197 1.2 chs for (i = 0; i < ubc_nwins; i++) {
198 1.2 chs umap = &ubc_object.umap[i];
199 1.2 chs TAILQ_INSERT_TAIL(&ubc_object.inactive[i & (UBC_NQUEUES - 1)],
200 1.2 chs umap, inactive);
201 1.2 chs }
202 1.2 chs
203 1.65 ad ubc_object.hash = hashinit(ubc_nwins, HASH_LIST, true,
204 1.65 ad &ubc_object.hashmask);
205 1.2 chs for (i = 0; i <= ubc_object.hashmask; i++) {
206 1.2 chs LIST_INIT(&ubc_object.hash[i]);
207 1.2 chs }
208 1.2 chs
209 1.2 chs if (uvm_map(kernel_map, (vaddr_t *)&ubc_object.kva,
210 1.11 chs ubc_nwins << ubc_winshift, &ubc_object.uobj, 0, (vsize_t)va,
211 1.2 chs UVM_MAPFLAG(UVM_PROT_ALL, UVM_PROT_ALL, UVM_INH_NONE,
212 1.9 chs UVM_ADV_RANDOM, UVM_FLAG_NOMERGE)) != 0) {
213 1.26 provos panic("ubc_init: failed to map ubc_object");
214 1.2 chs }
215 1.2 chs UVMHIST_INIT(ubchist, 300);
216 1.2 chs }
217 1.2 chs
218 1.2 chs /*
219 1.69 rmind * ubc_fault_page: helper of ubc_fault to handle a single page.
220 1.70 rmind *
221 1.70 rmind * => Caller has UVM object locked.
222 1.69 rmind */
223 1.69 rmind
224 1.70 rmind static inline int
225 1.69 rmind ubc_fault_page(const struct uvm_faultinfo *ufi, const struct ubc_map *umap,
226 1.69 rmind struct vm_page *pg, vm_prot_t prot, vm_prot_t access_type, vaddr_t va)
227 1.69 rmind {
228 1.69 rmind struct uvm_object *uobj;
229 1.69 rmind vm_prot_t mask;
230 1.69 rmind int error;
231 1.69 rmind bool rdonly;
232 1.69 rmind
233 1.69 rmind uobj = pg->uobject;
234 1.70 rmind KASSERT(mutex_owned(&uobj->vmobjlock));
235 1.70 rmind
236 1.69 rmind if (pg->flags & PG_WANTED) {
237 1.69 rmind wakeup(pg);
238 1.69 rmind }
239 1.69 rmind KASSERT((pg->flags & PG_FAKE) == 0);
240 1.69 rmind if (pg->flags & PG_RELEASED) {
241 1.69 rmind mutex_enter(&uvm_pageqlock);
242 1.69 rmind uvm_pagefree(pg);
243 1.69 rmind mutex_exit(&uvm_pageqlock);
244 1.70 rmind return 0;
245 1.69 rmind }
246 1.69 rmind if (pg->loan_count != 0) {
247 1.69 rmind
248 1.69 rmind /*
249 1.69 rmind * Avoid unneeded loan break, if possible.
250 1.69 rmind */
251 1.69 rmind
252 1.69 rmind if ((access_type & VM_PROT_WRITE) == 0) {
253 1.69 rmind prot &= ~VM_PROT_WRITE;
254 1.69 rmind }
255 1.69 rmind if (prot & VM_PROT_WRITE) {
256 1.69 rmind struct vm_page *newpg;
257 1.69 rmind
258 1.69 rmind newpg = uvm_loanbreak(pg);
259 1.69 rmind if (newpg == NULL) {
260 1.69 rmind uvm_page_unbusy(&pg, 1);
261 1.70 rmind return ENOMEM;
262 1.69 rmind }
263 1.69 rmind pg = newpg;
264 1.69 rmind }
265 1.69 rmind }
266 1.69 rmind
267 1.69 rmind /*
268 1.69 rmind * Note that a page whose backing store is partially allocated
269 1.69 rmind * is marked as PG_RDONLY.
270 1.69 rmind */
271 1.69 rmind
272 1.69 rmind KASSERT((pg->flags & PG_RDONLY) == 0 ||
273 1.69 rmind (access_type & VM_PROT_WRITE) == 0 ||
274 1.69 rmind pg->offset < umap->writeoff ||
275 1.69 rmind pg->offset + PAGE_SIZE > umap->writeoff + umap->writelen);
276 1.69 rmind
277 1.69 rmind rdonly = ((access_type & VM_PROT_WRITE) == 0 &&
278 1.69 rmind (pg->flags & PG_RDONLY) != 0) ||
279 1.69 rmind UVM_OBJ_NEEDS_WRITEFAULT(uobj);
280 1.69 rmind mask = rdonly ? ~VM_PROT_WRITE : VM_PROT_ALL;
281 1.69 rmind
282 1.69 rmind error = pmap_enter(ufi->orig_map->pmap, va, VM_PAGE_TO_PHYS(pg),
283 1.69 rmind prot & mask, PMAP_CANFAIL | (access_type & mask));
284 1.69 rmind
285 1.69 rmind mutex_enter(&uvm_pageqlock);
286 1.69 rmind uvm_pageactivate(pg);
287 1.69 rmind mutex_exit(&uvm_pageqlock);
288 1.69 rmind pg->flags &= ~(PG_BUSY|PG_WANTED);
289 1.69 rmind UVM_PAGE_OWN(pg, NULL);
290 1.69 rmind
291 1.70 rmind return error;
292 1.69 rmind }
293 1.69 rmind
294 1.69 rmind /*
295 1.2 chs * ubc_fault: fault routine for ubc mapping
296 1.2 chs */
297 1.18 chs
298 1.39 thorpej static int
299 1.54 yamt ubc_fault(struct uvm_faultinfo *ufi, vaddr_t ign1, struct vm_page **ign2,
300 1.54 yamt int ign3, int ign4, vm_prot_t access_type, int flags)
301 1.2 chs {
302 1.2 chs struct uvm_object *uobj;
303 1.2 chs struct ubc_map *umap;
304 1.2 chs vaddr_t va, eva, ubc_offset, slot_offset;
305 1.69 rmind struct vm_page *pgs[ubc_winsize >> PAGE_SHIFT];
306 1.18 chs int i, error, npages;
307 1.23 chs vm_prot_t prot;
308 1.69 rmind
309 1.69 rmind UVMHIST_FUNC("ubc_fault"); UVMHIST_CALLED(ubchist);
310 1.2 chs
311 1.2 chs /*
312 1.2 chs * no need to try with PGO_LOCKED...
313 1.2 chs * we don't need to have the map locked since we know that
314 1.2 chs * no one will mess with it until our reference is released.
315 1.2 chs */
316 1.18 chs
317 1.2 chs if (flags & PGO_LOCKED) {
318 1.2 chs uvmfault_unlockall(ufi, NULL, &ubc_object.uobj, NULL);
319 1.2 chs flags &= ~PGO_LOCKED;
320 1.2 chs }
321 1.2 chs
322 1.2 chs va = ufi->orig_rvaddr;
323 1.2 chs ubc_offset = va - (vaddr_t)ubc_object.kva;
324 1.11 chs umap = &ubc_object.umap[ubc_offset >> ubc_winshift];
325 1.2 chs KASSERT(umap->refcount != 0);
326 1.53 yamt KASSERT((umap->flags & UMAP_PAGES_LOCKED) == 0);
327 1.18 chs slot_offset = ubc_offset & (ubc_winsize - 1);
328 1.2 chs
329 1.34 chs /*
330 1.34 chs * some platforms cannot write to individual bytes atomically, so
331 1.34 chs * software has to do read/modify/write of larger quantities instead.
332 1.34 chs * this means that the access_type for "write" operations
333 1.34 chs * can be VM_PROT_READ, which confuses us mightily.
334 1.37 perry *
335 1.34 chs * deal with this by resetting access_type based on the info
336 1.34 chs * that ubc_alloc() stores for us.
337 1.34 chs */
338 1.34 chs
339 1.34 chs access_type = umap->writelen ? VM_PROT_WRITE : VM_PROT_READ;
340 1.34 chs UVMHIST_LOG(ubchist, "va 0x%lx ubc_offset 0x%lx access_type %d",
341 1.34 chs va, ubc_offset, access_type, 0);
342 1.34 chs
343 1.33 chs #ifdef DIAGNOSTIC
344 1.33 chs if ((access_type & VM_PROT_WRITE) != 0) {
345 1.33 chs if (slot_offset < trunc_page(umap->writeoff) ||
346 1.33 chs umap->writeoff + umap->writelen <= slot_offset) {
347 1.33 chs panic("ubc_fault: out of range write");
348 1.33 chs }
349 1.33 chs }
350 1.33 chs #endif
351 1.33 chs
352 1.2 chs /* no umap locking needed since we have a ref on the umap */
353 1.2 chs uobj = umap->uobj;
354 1.2 chs
355 1.33 chs if ((access_type & VM_PROT_WRITE) == 0) {
356 1.33 chs npages = (ubc_winsize - slot_offset) >> PAGE_SHIFT;
357 1.33 chs } else {
358 1.33 chs npages = (round_page(umap->offset + umap->writeoff +
359 1.33 chs umap->writelen) - (umap->offset + slot_offset))
360 1.33 chs >> PAGE_SHIFT;
361 1.33 chs flags |= PGO_PASTEOF;
362 1.33 chs }
363 1.2 chs
364 1.2 chs again:
365 1.2 chs memset(pgs, 0, sizeof (pgs));
366 1.64 ad mutex_enter(&uobj->vmobjlock);
367 1.2 chs
368 1.33 chs UVMHIST_LOG(ubchist, "slot_offset 0x%x writeoff 0x%x writelen 0x%x ",
369 1.33 chs slot_offset, umap->writeoff, umap->writelen, 0);
370 1.33 chs UVMHIST_LOG(ubchist, "getpages uobj %p offset 0x%x npages %d",
371 1.18 chs uobj, umap->offset + slot_offset, npages, 0);
372 1.2 chs
373 1.33 chs error = (*uobj->pgops->pgo_get)(uobj, umap->offset + slot_offset, pgs,
374 1.42 yamt &npages, 0, access_type, umap->advice, flags | PGO_NOBLOCKALLOC |
375 1.41 yamt PGO_NOTIMESTAMP);
376 1.24 simonb UVMHIST_LOG(ubchist, "getpages error %d npages %d", error, npages, 0,
377 1.24 simonb 0);
378 1.2 chs
379 1.5 chs if (error == EAGAIN) {
380 1.70 rmind kpause("ubc_fault", false, hz >> 2, NULL);
381 1.2 chs goto again;
382 1.2 chs }
383 1.5 chs if (error) {
384 1.10 chs return error;
385 1.5 chs }
386 1.2 chs
387 1.69 rmind /*
388 1.69 rmind * For virtually-indexed, virtually-tagged caches we should avoid
389 1.69 rmind * creating writable mappings when we do not absolutely need them,
390 1.69 rmind * since the "compatible alias" trick does not work on such caches.
391 1.69 rmind * Otherwise, we can always map the pages writable.
392 1.69 rmind */
393 1.69 rmind
394 1.69 rmind #ifdef PMAP_CACHE_VIVT
395 1.69 rmind prot = VM_PROT_READ | access_type;
396 1.69 rmind #else
397 1.69 rmind prot = VM_PROT_READ | VM_PROT_WRITE;
398 1.69 rmind #endif
399 1.70 rmind
400 1.70 rmind /*
401 1.70 rmind * Note: in the common case, all returned pages would have the same
402 1.70 rmind * UVM object. However, due to layered file-systems and e.g. tmpfs,
403 1.70 rmind * returned pages may have different objects. We "remember" the
404 1.70 rmind * last object in the loop to reduce locking overhead and to perform
405 1.70 rmind * pmap_update() before object unlock.
406 1.70 rmind */
407 1.70 rmind uobj = NULL;
408 1.70 rmind
409 1.2 chs va = ufi->orig_rvaddr;
410 1.2 chs eva = ufi->orig_rvaddr + (npages << PAGE_SHIFT);
411 1.2 chs
412 1.28 yamt UVMHIST_LOG(ubchist, "va 0x%lx eva 0x%lx", va, eva, 0, 0);
413 1.28 yamt for (i = 0; va < eva; i++, va += PAGE_SIZE) {
414 1.69 rmind struct vm_page *pg;
415 1.34 chs
416 1.24 simonb UVMHIST_LOG(ubchist, "pgs[%d] = %p", i, pgs[i], 0, 0);
417 1.2 chs pg = pgs[i];
418 1.2 chs
419 1.2 chs if (pg == NULL || pg == PGO_DONTCARE) {
420 1.2 chs continue;
421 1.2 chs }
422 1.70 rmind if (__predict_false(pg->uobject != uobj)) {
423 1.70 rmind /* Check for the first iteration and error cases. */
424 1.70 rmind if (uobj != NULL) {
425 1.70 rmind /* Must make VA visible before the unlock. */
426 1.70 rmind pmap_update(ufi->orig_map->pmap);
427 1.70 rmind mutex_exit(&uobj->vmobjlock);
428 1.70 rmind }
429 1.70 rmind uobj = pg->uobject;
430 1.70 rmind mutex_enter(&uobj->vmobjlock);
431 1.70 rmind }
432 1.70 rmind error = ubc_fault_page(ufi, umap, pg, prot, access_type, va);
433 1.70 rmind if (error) {
434 1.70 rmind /*
435 1.70 rmind * Flush (there might be pages entered), drop the lock,
436 1.70 rmind * "forget" the object and perform uvm_wait().
437 1.70 rmind * Note: page will re-fault.
438 1.70 rmind */
439 1.70 rmind pmap_update(ufi->orig_map->pmap);
440 1.70 rmind mutex_exit(&uobj->vmobjlock);
441 1.70 rmind uobj = NULL;
442 1.70 rmind uvm_wait("ubc_fault");
443 1.70 rmind }
444 1.70 rmind }
445 1.70 rmind if (__predict_true(uobj != NULL)) {
446 1.70 rmind pmap_update(ufi->orig_map->pmap);
447 1.70 rmind mutex_exit(&uobj->vmobjlock);
448 1.2 chs }
449 1.8 chs return 0;
450 1.2 chs }
451 1.2 chs
452 1.2 chs /*
453 1.2 chs * local functions
454 1.2 chs */
455 1.2 chs
456 1.39 thorpej static struct ubc_map *
457 1.39 thorpej ubc_find_mapping(struct uvm_object *uobj, voff_t offset)
458 1.2 chs {
459 1.2 chs struct ubc_map *umap;
460 1.2 chs
461 1.2 chs LIST_FOREACH(umap, &ubc_object.hash[UBC_HASH(uobj, offset)], hash) {
462 1.2 chs if (umap->uobj == uobj && umap->offset == offset) {
463 1.2 chs return umap;
464 1.2 chs }
465 1.2 chs }
466 1.2 chs return NULL;
467 1.2 chs }
468 1.2 chs
469 1.2 chs
470 1.2 chs /*
471 1.2 chs * ubc interface functions
472 1.2 chs */
473 1.2 chs
474 1.2 chs /*
475 1.18 chs * ubc_alloc: allocate a file mapping window
476 1.2 chs */
477 1.18 chs
478 1.2 chs void *
479 1.42 yamt ubc_alloc(struct uvm_object *uobj, voff_t offset, vsize_t *lenp, int advice,
480 1.42 yamt int flags)
481 1.2 chs {
482 1.6 chs vaddr_t slot_offset, va;
483 1.2 chs struct ubc_map *umap;
484 1.6 chs voff_t umap_offset;
485 1.18 chs int error;
486 1.2 chs UVMHIST_FUNC("ubc_alloc"); UVMHIST_CALLED(ubchist);
487 1.2 chs
488 1.33 chs UVMHIST_LOG(ubchist, "uobj %p offset 0x%lx len 0x%lx",
489 1.33 chs uobj, offset, *lenp, 0);
490 1.2 chs
491 1.34 chs KASSERT(*lenp > 0);
492 1.6 chs umap_offset = (offset & ~((voff_t)ubc_winsize - 1));
493 1.4 enami slot_offset = (vaddr_t)(offset & ((voff_t)ubc_winsize - 1));
494 1.18 chs *lenp = MIN(*lenp, ubc_winsize - slot_offset);
495 1.2 chs
496 1.2 chs /*
497 1.33 chs * the object is always locked here, so we don't need to add a ref.
498 1.2 chs */
499 1.2 chs
500 1.2 chs again:
501 1.64 ad mutex_enter(&ubc_object.uobj.vmobjlock);
502 1.2 chs umap = ubc_find_mapping(uobj, umap_offset);
503 1.2 chs if (umap == NULL) {
504 1.50 yamt UBC_EVCNT_INCR(wincachemiss);
505 1.2 chs umap = TAILQ_FIRST(UBC_QUEUE(offset));
506 1.2 chs if (umap == NULL) {
507 1.64 ad mutex_exit(&ubc_object.uobj.vmobjlock);
508 1.60 ad kpause("ubc_alloc", false, hz, NULL);
509 1.2 chs goto again;
510 1.2 chs }
511 1.2 chs
512 1.2 chs /*
513 1.18 chs * remove from old hash (if any), add to new hash.
514 1.2 chs */
515 1.2 chs
516 1.2 chs if (umap->uobj != NULL) {
517 1.2 chs LIST_REMOVE(umap, hash);
518 1.2 chs }
519 1.2 chs umap->uobj = uobj;
520 1.2 chs umap->offset = umap_offset;
521 1.2 chs LIST_INSERT_HEAD(&ubc_object.hash[UBC_HASH(uobj, umap_offset)],
522 1.18 chs umap, hash);
523 1.18 chs va = UBC_UMAP_ADDR(umap);
524 1.18 chs if (umap->flags & UMAP_MAPPING_CACHED) {
525 1.18 chs umap->flags &= ~UMAP_MAPPING_CACHED;
526 1.18 chs pmap_remove(pmap_kernel(), va, va + ubc_winsize);
527 1.18 chs pmap_update(pmap_kernel());
528 1.18 chs }
529 1.18 chs } else {
530 1.50 yamt UBC_EVCNT_INCR(wincachehit);
531 1.18 chs va = UBC_UMAP_ADDR(umap);
532 1.2 chs }
533 1.2 chs
534 1.2 chs if (umap->refcount == 0) {
535 1.2 chs TAILQ_REMOVE(UBC_QUEUE(offset), umap, inactive);
536 1.2 chs }
537 1.2 chs
538 1.2 chs #ifdef DIAGNOSTIC
539 1.18 chs if ((flags & UBC_WRITE) && (umap->writeoff || umap->writelen)) {
540 1.33 chs panic("ubc_alloc: concurrent writes uobj %p", uobj);
541 1.2 chs }
542 1.2 chs #endif
543 1.2 chs if (flags & UBC_WRITE) {
544 1.2 chs umap->writeoff = slot_offset;
545 1.2 chs umap->writelen = *lenp;
546 1.2 chs }
547 1.2 chs
548 1.2 chs umap->refcount++;
549 1.42 yamt umap->advice = advice;
550 1.64 ad mutex_exit(&ubc_object.uobj.vmobjlock);
551 1.18 chs UVMHIST_LOG(ubchist, "umap %p refs %d va %p flags 0x%x",
552 1.18 chs umap, umap->refcount, va, flags);
553 1.18 chs
554 1.18 chs if (flags & UBC_FAULTBUSY) {
555 1.18 chs int npages = (*lenp + PAGE_SIZE - 1) >> PAGE_SHIFT;
556 1.18 chs struct vm_page *pgs[npages];
557 1.40 yamt int gpflags =
558 1.41 yamt PGO_SYNCIO|PGO_OVERWRITE|PGO_PASTEOF|PGO_NOBLOCKALLOC|
559 1.41 yamt PGO_NOTIMESTAMP;
560 1.18 chs int i;
561 1.30 dbj KDASSERT(flags & UBC_WRITE);
562 1.57 yamt KASSERT(umap->refcount == 1);
563 1.2 chs
564 1.57 yamt UBC_EVCNT_INCR(faultbusy);
565 1.18 chs if (umap->flags & UMAP_MAPPING_CACHED) {
566 1.18 chs umap->flags &= ~UMAP_MAPPING_CACHED;
567 1.18 chs pmap_remove(pmap_kernel(), va, va + ubc_winsize);
568 1.18 chs }
569 1.59 yamt again_faultbusy:
570 1.22 enami memset(pgs, 0, sizeof(pgs));
571 1.64 ad mutex_enter(&uobj->vmobjlock);
572 1.33 chs error = (*uobj->pgops->pgo_get)(uobj, trunc_page(offset), pgs,
573 1.42 yamt &npages, 0, VM_PROT_READ | VM_PROT_WRITE, advice, gpflags);
574 1.24 simonb UVMHIST_LOG(ubchist, "faultbusy getpages %d", error, 0, 0, 0);
575 1.18 chs if (error) {
576 1.18 chs goto out;
577 1.18 chs }
578 1.18 chs for (i = 0; i < npages; i++) {
579 1.59 yamt struct vm_page *pg = pgs[i];
580 1.59 yamt
581 1.59 yamt KASSERT(pg->uobject == uobj);
582 1.59 yamt if (pg->loan_count != 0) {
583 1.64 ad mutex_enter(&uobj->vmobjlock);
584 1.59 yamt if (pg->loan_count != 0) {
585 1.59 yamt pg = uvm_loanbreak(pg);
586 1.59 yamt }
587 1.64 ad mutex_exit(&uobj->vmobjlock);
588 1.59 yamt if (pg == NULL) {
589 1.59 yamt pmap_kremove(va, ubc_winsize);
590 1.59 yamt pmap_update(pmap_kernel());
591 1.64 ad mutex_enter(&uobj->vmobjlock);
592 1.59 yamt uvm_page_unbusy(pgs, npages);
593 1.64 ad mutex_exit(&uobj->vmobjlock);
594 1.59 yamt uvm_wait("ubc_alloc");
595 1.59 yamt goto again_faultbusy;
596 1.59 yamt }
597 1.59 yamt pgs[i] = pg;
598 1.59 yamt }
599 1.18 chs pmap_kenter_pa(va + slot_offset + (i << PAGE_SHIFT),
600 1.68 cegger VM_PAGE_TO_PHYS(pg),
601 1.68 cegger VM_PROT_READ | VM_PROT_WRITE, 0);
602 1.18 chs }
603 1.18 chs pmap_update(pmap_kernel());
604 1.18 chs umap->flags |= UMAP_PAGES_LOCKED;
605 1.57 yamt } else {
606 1.57 yamt KASSERT((umap->flags & UMAP_PAGES_LOCKED) == 0);
607 1.18 chs }
608 1.18 chs
609 1.18 chs out:
610 1.18 chs return (void *)(va + slot_offset);
611 1.2 chs }
612 1.2 chs
613 1.18 chs /*
614 1.18 chs * ubc_release: free a file mapping window.
615 1.18 chs */
616 1.2 chs
617 1.2 chs void
618 1.39 thorpej ubc_release(void *va, int flags)
619 1.2 chs {
620 1.2 chs struct ubc_map *umap;
621 1.2 chs struct uvm_object *uobj;
622 1.18 chs vaddr_t umapva;
623 1.55 thorpej bool unmapped;
624 1.2 chs UVMHIST_FUNC("ubc_release"); UVMHIST_CALLED(ubchist);
625 1.2 chs
626 1.24 simonb UVMHIST_LOG(ubchist, "va %p", va, 0, 0, 0);
627 1.11 chs umap = &ubc_object.umap[((char *)va - ubc_object.kva) >> ubc_winshift];
628 1.18 chs umapva = UBC_UMAP_ADDR(umap);
629 1.2 chs uobj = umap->uobj;
630 1.2 chs KASSERT(uobj != NULL);
631 1.2 chs
632 1.18 chs if (umap->flags & UMAP_PAGES_LOCKED) {
633 1.18 chs int slot_offset = umap->writeoff;
634 1.18 chs int endoff = umap->writeoff + umap->writelen;
635 1.18 chs int zerolen = round_page(endoff) - endoff;
636 1.18 chs int npages = (int)(round_page(umap->writeoff + umap->writelen)
637 1.18 chs - trunc_page(umap->writeoff)) >> PAGE_SHIFT;
638 1.18 chs struct vm_page *pgs[npages];
639 1.18 chs paddr_t pa;
640 1.18 chs int i;
641 1.55 thorpej bool rv;
642 1.18 chs
643 1.57 yamt KASSERT((umap->flags & UMAP_MAPPING_CACHED) == 0);
644 1.18 chs if (zerolen) {
645 1.18 chs memset((char *)umapva + endoff, 0, zerolen);
646 1.18 chs }
647 1.18 chs umap->flags &= ~UMAP_PAGES_LOCKED;
648 1.64 ad mutex_enter(&uvm_pageqlock);
649 1.18 chs for (i = 0; i < npages; i++) {
650 1.18 chs rv = pmap_extract(pmap_kernel(),
651 1.18 chs umapva + slot_offset + (i << PAGE_SHIFT), &pa);
652 1.18 chs KASSERT(rv);
653 1.18 chs pgs[i] = PHYS_TO_VM_PAGE(pa);
654 1.18 chs pgs[i]->flags &= ~(PG_FAKE|PG_CLEAN);
655 1.28 yamt KASSERT(pgs[i]->loan_count == 0);
656 1.18 chs uvm_pageactivate(pgs[i]);
657 1.18 chs }
658 1.64 ad mutex_exit(&uvm_pageqlock);
659 1.18 chs pmap_kremove(umapva, ubc_winsize);
660 1.18 chs pmap_update(pmap_kernel());
661 1.64 ad mutex_enter(&uobj->vmobjlock);
662 1.18 chs uvm_page_unbusy(pgs, npages);
663 1.64 ad mutex_exit(&uobj->vmobjlock);
664 1.56 thorpej unmapped = true;
665 1.18 chs } else {
666 1.56 thorpej unmapped = false;
667 1.18 chs }
668 1.18 chs
669 1.64 ad mutex_enter(&ubc_object.uobj.vmobjlock);
670 1.2 chs umap->writeoff = 0;
671 1.2 chs umap->writelen = 0;
672 1.2 chs umap->refcount--;
673 1.2 chs if (umap->refcount == 0) {
674 1.33 chs if (flags & UBC_UNMAP) {
675 1.2 chs
676 1.2 chs /*
677 1.33 chs * Invalidate any cached mappings if requested.
678 1.33 chs * This is typically used to avoid leaving
679 1.33 chs * incompatible cache aliases around indefinitely.
680 1.2 chs */
681 1.2 chs
682 1.18 chs pmap_remove(pmap_kernel(), umapva,
683 1.18 chs umapva + ubc_winsize);
684 1.18 chs umap->flags &= ~UMAP_MAPPING_CACHED;
685 1.17 chris pmap_update(pmap_kernel());
686 1.2 chs LIST_REMOVE(umap, hash);
687 1.2 chs umap->uobj = NULL;
688 1.2 chs TAILQ_INSERT_HEAD(UBC_QUEUE(umap->offset), umap,
689 1.2 chs inactive);
690 1.2 chs } else {
691 1.18 chs if (!unmapped) {
692 1.18 chs umap->flags |= UMAP_MAPPING_CACHED;
693 1.18 chs }
694 1.2 chs TAILQ_INSERT_TAIL(UBC_QUEUE(umap->offset), umap,
695 1.2 chs inactive);
696 1.2 chs }
697 1.2 chs }
698 1.24 simonb UVMHIST_LOG(ubchist, "umap %p refs %d", umap, umap->refcount, 0, 0);
699 1.64 ad mutex_exit(&ubc_object.uobj.vmobjlock);
700 1.2 chs }
701 1.2 chs
702 1.58 yamt /*
703 1.58 yamt * ubc_uiomove: move data to/from an object.
704 1.58 yamt */
705 1.58 yamt
706 1.58 yamt int
707 1.62 yamt ubc_uiomove(struct uvm_object *uobj, struct uio *uio, vsize_t todo, int advice,
708 1.62 yamt int flags)
709 1.58 yamt {
710 1.58 yamt voff_t off;
711 1.58 yamt const bool overwrite = (flags & UBC_FAULTBUSY) != 0;
712 1.58 yamt int error;
713 1.58 yamt
714 1.58 yamt KASSERT(todo <= uio->uio_resid);
715 1.58 yamt KASSERT(((flags & UBC_WRITE) != 0 && uio->uio_rw == UIO_WRITE) ||
716 1.58 yamt ((flags & UBC_READ) != 0 && uio->uio_rw == UIO_READ));
717 1.58 yamt
718 1.58 yamt off = uio->uio_offset;
719 1.58 yamt error = 0;
720 1.58 yamt while (todo > 0) {
721 1.58 yamt vsize_t bytelen = todo;
722 1.58 yamt void *win;
723 1.58 yamt
724 1.62 yamt win = ubc_alloc(uobj, off, &bytelen, advice, flags);
725 1.58 yamt if (error == 0) {
726 1.58 yamt error = uiomove(win, bytelen, uio);
727 1.58 yamt }
728 1.58 yamt if (error != 0 && overwrite) {
729 1.58 yamt /*
730 1.58 yamt * if we haven't initialized the pages yet,
731 1.58 yamt * do it now. it's safe to use memset here
732 1.58 yamt * because we just mapped the pages above.
733 1.58 yamt */
734 1.64 ad printf("%s: error=%d\n", __func__, error);
735 1.58 yamt memset(win, 0, bytelen);
736 1.58 yamt }
737 1.58 yamt ubc_release(win, flags);
738 1.58 yamt off += bytelen;
739 1.58 yamt todo -= bytelen;
740 1.58 yamt if (error != 0 && (flags & UBC_PARTIALOK) != 0) {
741 1.58 yamt break;
742 1.58 yamt }
743 1.58 yamt }
744 1.58 yamt
745 1.58 yamt return error;
746 1.58 yamt }
747 1.67 pooka
748 1.67 pooka
749 1.67 pooka /*
750 1.67 pooka * uvm_vnp_zerorange: set a range of bytes in a file to zero.
751 1.67 pooka */
752 1.67 pooka
753 1.67 pooka void
754 1.67 pooka uvm_vnp_zerorange(struct vnode *vp, off_t off, size_t len)
755 1.67 pooka {
756 1.67 pooka void *win;
757 1.67 pooka int flags;
758 1.67 pooka
759 1.67 pooka /*
760 1.67 pooka * XXXUBC invent kzero() and use it
761 1.67 pooka */
762 1.67 pooka
763 1.67 pooka while (len) {
764 1.67 pooka vsize_t bytelen = len;
765 1.67 pooka
766 1.67 pooka win = ubc_alloc(&vp->v_uobj, off, &bytelen, UVM_ADV_NORMAL,
767 1.67 pooka UBC_WRITE);
768 1.67 pooka memset(win, 0, bytelen);
769 1.67 pooka flags = UBC_WANT_UNMAP(vp) ? UBC_UNMAP : 0;
770 1.67 pooka ubc_release(win, flags);
771 1.67 pooka
772 1.67 pooka off += bytelen;
773 1.67 pooka len -= bytelen;
774 1.67 pooka }
775 1.67 pooka }
776