136865Sdfr/*-
236865Sdfr * Copyright (c) 1982, 1986 The Regents of the University of California.
336865Sdfr * Copyright (c) 1989, 1990 William Jolitz
436865Sdfr * Copyright (c) 1994 John Dyson
536865Sdfr * All rights reserved.
636865Sdfr *
736865Sdfr * This code is derived from software contributed to Berkeley by
836865Sdfr * the Systems Programming Group of the University of Utah Computer
936865Sdfr * Science Department, and William Jolitz.
1036865Sdfr *
1136865Sdfr * Redistribution and use in source and binary forms, with or without
1236865Sdfr * modification, are permitted provided that the following conditions
1336865Sdfr * are met:
1436865Sdfr * 1. Redistributions of source code must retain the above copyright
1536865Sdfr *    notice, this list of conditions and the following disclaimer.
1636865Sdfr * 2. Redistributions in binary form must reproduce the above copyright
1736865Sdfr *    notice, this list of conditions and the following disclaimer in the
1836865Sdfr *    documentation and/or other materials provided with the distribution.
1936865Sdfr * 3. All advertising materials mentioning features or use of this software
2036865Sdfr *    must display the following acknowledgement:
2136865Sdfr *	This product includes software developed by the University of
2236865Sdfr *	California, Berkeley and its contributors.
2336865Sdfr * 4. Neither the name of the University nor the names of its contributors
2436865Sdfr *    may be used to endorse or promote products derived from this software
2536865Sdfr *    without specific prior written permission.
2636865Sdfr *
2736865Sdfr * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
2836865Sdfr * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
2936865Sdfr * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
3036865Sdfr * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
3136865Sdfr * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
3236865Sdfr * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
3336865Sdfr * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
3436865Sdfr * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
3536865Sdfr * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
3636865Sdfr * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
3736865Sdfr * SUCH DAMAGE.
3836865Sdfr *
3936865Sdfr *	from: @(#)vm_machdep.c	7.3 (Berkeley) 5/13/91
4036865Sdfr *	Utah $Hdr: vm_machdep.c 1.16.1.1 89/06/23$
4150477Speter * $FreeBSD$
4236865Sdfr */
43139825Simp/*-
4436865Sdfr * Copyright (c) 1994, 1995, 1996 Carnegie-Mellon University.
4536865Sdfr * All rights reserved.
4636865Sdfr *
4736865Sdfr * Author: Chris G. Demetriou
48126474Sgrehan *
4936865Sdfr * Permission to use, copy, modify and distribute this software and
5036865Sdfr * its documentation is hereby granted, provided that both the copyright
5136865Sdfr * notice and this permission notice appear in all copies of the
5236865Sdfr * software, derivative works or modified versions, and any portions
5336865Sdfr * thereof, and that both notices appear in supporting documentation.
54126474Sgrehan *
55126474Sgrehan * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
56126474Sgrehan * CONDITION.  CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
5736865Sdfr * FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
58126474Sgrehan *
5936865Sdfr * Carnegie Mellon requests users of this software to return to
6036865Sdfr *
6136865Sdfr *  Software Distribution Coordinator  or  Software.Distribution@CS.CMU.EDU
6236865Sdfr *  School of Computer Science
6336865Sdfr *  Carnegie Mellon University
6436865Sdfr *  Pittsburgh PA 15213-3890
6536865Sdfr *
6636865Sdfr * any improvements or extensions that they make and grant Carnegie the
6736865Sdfr * rights to redistribute these changes.
6836865Sdfr */
6936865Sdfr
7036865Sdfr#include <sys/param.h>
7136865Sdfr#include <sys/systm.h>
7236865Sdfr#include <sys/proc.h>
7336865Sdfr#include <sys/malloc.h>
7460041Sphk#include <sys/bio.h>
7536865Sdfr#include <sys/buf.h>
7685201Smp#include <sys/ktr.h>
7785201Smp#include <sys/lock.h>
7867365Sjhb#include <sys/mutex.h>
7936865Sdfr#include <sys/vnode.h>
8036865Sdfr#include <sys/vmmeter.h>
8136865Sdfr#include <sys/kernel.h>
82119563Salc#include <sys/mbuf.h>
83122780Salc#include <sys/sf_buf.h>
8436865Sdfr#include <sys/sysctl.h>
85199135Skib#include <sys/sysent.h>
8654207Speter#include <sys/unistd.h>
8736865Sdfr
8836865Sdfr#include <machine/cpu.h>
8941499Sdfr#include <machine/fpu.h>
9097397Sbenno#include <machine/frame.h>
9136865Sdfr#include <machine/md_var.h>
92138129Sdas#include <machine/pcb.h>
9336865Sdfr
9478342Sbenno#include <dev/ofw/openfirm.h>
9578342Sbenno
9636865Sdfr#include <vm/vm.h>
9736865Sdfr#include <vm/vm_param.h>
9836865Sdfr#include <vm/vm_kern.h>
9936865Sdfr#include <vm/vm_page.h>
10036865Sdfr#include <vm/vm_map.h>
10136865Sdfr#include <vm/vm_extern.h>
10236865Sdfr
10336865Sdfr/*
104190681Snwhitehorn * On systems without a direct mapped region (e.g. PPC64),
105190681Snwhitehorn * we use the same code as the Book E implementation. Since
106190681Snwhitehorn * we need to have runtime detection of this, define some machinery
107190681Snwhitehorn * for sf_bufs in this case, and ignore it on systems with direct maps.
108190681Snwhitehorn */
109190681Snwhitehorn
110190681Snwhitehorn#ifndef NSFBUFS
111256792Snwhitehorn#define NSFBUFS		(512 + maxusers * 16)
112190681Snwhitehorn#endif
113190681Snwhitehorn
114255786Sglebiusstatic int nsfbufs;
115255786Sglebiusstatic int nsfbufspeak;
116255786Sglebiusstatic int nsfbufsused;
117255786Sglebius
118255786SglebiusSYSCTL_INT(_kern_ipc, OID_AUTO, nsfbufs, CTLFLAG_RDTUN, &nsfbufs, 0,
119255786Sglebius    "Maximum number of sendfile(2) sf_bufs available");
120255786SglebiusSYSCTL_INT(_kern_ipc, OID_AUTO, nsfbufspeak, CTLFLAG_RD, &nsfbufspeak, 0,
121255786Sglebius    "Number of sendfile(2) sf_bufs at peak usage");
122255786SglebiusSYSCTL_INT(_kern_ipc, OID_AUTO, nsfbufsused, CTLFLAG_RD, &nsfbufsused, 0,
123255786Sglebius    "Number of sendfile(2) sf_bufs in use");
124255786Sglebius
125190681Snwhitehornstatic void sf_buf_init(void *arg);
126190681SnwhitehornSYSINIT(sock_sf, SI_SUB_MBUF, SI_ORDER_ANY, sf_buf_init, NULL);
127190681Snwhitehorn
128190681SnwhitehornLIST_HEAD(sf_head, sf_buf);
129190681Snwhitehorn
130190681Snwhitehorn/* A hash table of active sendfile(2) buffers */
131190681Snwhitehornstatic struct sf_head *sf_buf_active;
132190681Snwhitehornstatic u_long sf_buf_hashmask;
133190681Snwhitehorn
134190681Snwhitehorn#define SF_BUF_HASH(m)  (((m) - vm_page_array) & sf_buf_hashmask)
135190681Snwhitehorn
136190681Snwhitehornstatic TAILQ_HEAD(, sf_buf) sf_buf_freelist;
137190681Snwhitehornstatic u_int sf_buf_alloc_want;
138190681Snwhitehorn
139190681Snwhitehorn/*
140190681Snwhitehorn * A lock used to synchronize access to the hash table and free list
141190681Snwhitehorn */
142190681Snwhitehornstatic struct mtx sf_buf_lock;
143190681Snwhitehorn
144209975Snwhitehorn#ifdef __powerpc64__
145209975Snwhitehornextern uintptr_t tocbase;
146209975Snwhitehorn#endif
147190681Snwhitehorn
148209975Snwhitehorn
149190681Snwhitehorn/*
15036865Sdfr * Finish a fork operation, with process p2 nearly set up.
15136865Sdfr * Copy and update the pcb, set up the stack so that the child
15236865Sdfr * ready to run and return to user mode.
15336865Sdfr */
15436865Sdfrvoid
15590361Sjuliancpu_fork(struct thread *td1, struct proc *p2, struct thread *td2, int flags)
15636865Sdfr{
15784977Sbenno	struct	trapframe *tf;
15884977Sbenno	struct	callframe *cf;
15990643Sbenno	struct	pcb *pcb;
16084977Sbenno
16191467Sbenno	KASSERT(td1 == curthread || td1 == &thread0,
16290643Sbenno	    ("cpu_fork: p1 not curproc and not proc0"));
163209975Snwhitehorn	CTR3(KTR_PROC, "cpu_fork: called td1=%p p2=%p flags=%x",
164209975Snwhitehorn	    td1, p2, flags);
16584977Sbenno
16684977Sbenno	if ((flags & RFPROC) == 0)
16784977Sbenno		return;
16884977Sbenno
169127582Speter	pcb = (struct pcb *)((td2->td_kstack +
170209975Snwhitehorn	    td2->td_kstack_pages * PAGE_SIZE - sizeof(struct pcb)) & ~0x2fUL);
17190643Sbenno	td2->td_pcb = pcb;
17284977Sbenno
17390643Sbenno	/* Copy the pcb */
17490643Sbenno	bcopy(td1->td_pcb, pcb, sizeof(struct pcb));
17584977Sbenno
17684977Sbenno	/*
17790643Sbenno	 * Create a fresh stack for the new process.
17884977Sbenno	 * Copy the trap frame for the return to user mode as if from a
17984977Sbenno	 * syscall.  This copies most of the user mode register values.
18084977Sbenno	 */
18190643Sbenno	tf = (struct trapframe *)pcb - 1;
18290643Sbenno	bcopy(td1->td_frame, tf, sizeof(*tf));
18384977Sbenno
18497397Sbenno	/* Set up trap frame. */
18597397Sbenno	tf->fixreg[FIRSTARG] = 0;
18697397Sbenno	tf->fixreg[FIRSTARG + 1] = 0;
18797397Sbenno	tf->cr &= ~0x10000000;
18890643Sbenno
18990643Sbenno	td2->td_frame = tf;
19090643Sbenno
19190643Sbenno	cf = (struct callframe *)tf - 1;
192132520Sgrehan	memset(cf, 0, sizeof(struct callframe));
193209975Snwhitehorn	#ifdef __powerpc64__
194209975Snwhitehorn	cf->cf_toc = tocbase;
195209975Snwhitehorn	#endif
19691467Sbenno	cf->cf_func = (register_t)fork_return;
19791467Sbenno	cf->cf_arg0 = (register_t)td2;
19891467Sbenno	cf->cf_arg1 = (register_t)tf;
19984977Sbenno
20091467Sbenno	pcb->pcb_sp = (register_t)cf;
201255273Snwhitehorn	KASSERT(pcb->pcb_sp % 16 == 0, ("stack misaligned"));
202209975Snwhitehorn	#ifdef __powerpc64__
203209975Snwhitehorn	pcb->pcb_lr = ((register_t *)fork_trampoline)[0];
204209975Snwhitehorn	pcb->pcb_toc = ((register_t *)fork_trampoline)[1];
205209975Snwhitehorn	#else
20691467Sbenno	pcb->pcb_lr = (register_t)fork_trampoline;
207209975Snwhitehorn	#endif
208256792Snwhitehorn	#ifdef AIM
209209975Snwhitehorn	pcb->pcb_cpu.aim.usr_vsid = 0;
210256792Snwhitehorn	#endif
21184977Sbenno
212170305Sjeff	/* Setup to release spin count in fork_exit(). */
213144637Sjhb	td2->td_md.md_spinlock_count = 1;
214144637Sjhb	td2->td_md.md_saved_msr = PSL_KERNSET;
215144637Sjhb
21690643Sbenno	/*
21790643Sbenno 	 * Now cpu_switch() can schedule the new process.
21890643Sbenno	 */
21936865Sdfr}
22036865Sdfr
22136865Sdfr/*
22236865Sdfr * Intercept the return address from a freshly forked process that has NOT
22336865Sdfr * been scheduled yet.
22436865Sdfr *
22536865Sdfr * This is needed to make kernel threads stay in kernel mode.
22636865Sdfr */
22736865Sdfrvoid
228256792Snwhitehorncpu_set_fork_handler(struct thread *td, void (*func)(void *), void *arg)
22936865Sdfr{
230256792Snwhitehorn	struct callframe *cf;
23184977Sbenno
232209975Snwhitehorn	CTR4(KTR_PROC, "%s called with td=%p func=%p arg=%p",
233209975Snwhitehorn	    __func__, td, func, arg);
23484977Sbenno
23591467Sbenno	cf = (struct callframe *)td->td_pcb->pcb_sp;
23684977Sbenno
23791467Sbenno	cf->cf_func = (register_t)func;
23891467Sbenno	cf->cf_arg0 = (register_t)arg;
23936865Sdfr}
24036865Sdfr
24136865Sdfrvoid
242256792Snwhitehorncpu_exit(struct thread *td)
24336865Sdfr{
244256792Snwhitehorn
24536865Sdfr}
24636865Sdfr
24736865Sdfr/*
248190681Snwhitehorn * Allocate a pool of sf_bufs (sendfile(2) or "super-fast" if you prefer. :-))
249119563Salc */
250190681Snwhitehornstatic void
251190681Snwhitehornsf_buf_init(void *arg)
252190681Snwhitehorn{
253256792Snwhitehorn	struct sf_buf *sf_bufs;
254256792Snwhitehorn	vm_offset_t sf_base;
255256792Snwhitehorn	int i;
256190681Snwhitehorn
257190681Snwhitehorn	/* Don't bother on systems with a direct map */
258190681Snwhitehorn	if (hw_direct_map)
259190681Snwhitehorn		return;
260190681Snwhitehorn
261256792Snwhitehorn	nsfbufs = NSFBUFS;
262256792Snwhitehorn	TUNABLE_INT_FETCH("kern.ipc.nsfbufs", &nsfbufs);
263190681Snwhitehorn
264256792Snwhitehorn	sf_buf_active = hashinit(nsfbufs, M_TEMP, &sf_buf_hashmask);
265256792Snwhitehorn	TAILQ_INIT(&sf_buf_freelist);
266256792Snwhitehorn	sf_base = kva_alloc(nsfbufs * PAGE_SIZE);
267256792Snwhitehorn	sf_bufs = malloc(nsfbufs * sizeof(struct sf_buf), M_TEMP,
268256792Snwhitehorn	    M_NOWAIT | M_ZERO);
269190681Snwhitehorn
270256792Snwhitehorn	for (i = 0; i < nsfbufs; i++) {
271256792Snwhitehorn		sf_bufs[i].kva = sf_base + i * PAGE_SIZE;
272256792Snwhitehorn		TAILQ_INSERT_TAIL(&sf_buf_freelist, &sf_bufs[i], free_entry);
273256792Snwhitehorn	}
274256792Snwhitehorn	sf_buf_alloc_want = 0;
275256792Snwhitehorn	mtx_init(&sf_buf_lock, "sf_buf", NULL, MTX_DEF);
276190681Snwhitehorn}
277190681Snwhitehorn
278190681Snwhitehorn/*
279190681Snwhitehorn * Get an sf_buf from the freelist. Will block if none are available.
280190681Snwhitehorn */
281119563Salcstruct sf_buf *
282190681Snwhitehornsf_buf_alloc(struct vm_page *m, int flags)
283119563Salc{
284256792Snwhitehorn	struct sf_head *hash_list;
285256792Snwhitehorn	struct sf_buf *sf;
286256792Snwhitehorn	int error;
287119563Salc
288190681Snwhitehorn	if (hw_direct_map) {
289190681Snwhitehorn		/* Shortcut the direct mapped case */
290190681Snwhitehorn		return ((struct sf_buf *)m);
291190681Snwhitehorn	}
292190681Snwhitehorn
293256792Snwhitehorn	hash_list = &sf_buf_active[SF_BUF_HASH(m)];
294256792Snwhitehorn	mtx_lock(&sf_buf_lock);
295256792Snwhitehorn	LIST_FOREACH(sf, hash_list, list_entry) {
296256792Snwhitehorn		if (sf->m == m) {
297256792Snwhitehorn			sf->ref_count++;
298256792Snwhitehorn			if (sf->ref_count == 1) {
299256792Snwhitehorn				TAILQ_REMOVE(&sf_buf_freelist, sf, free_entry);
300256792Snwhitehorn				nsfbufsused++;
301256792Snwhitehorn				nsfbufspeak = imax(nsfbufspeak, nsfbufsused);
302256792Snwhitehorn			}
303256792Snwhitehorn			goto done;
304256792Snwhitehorn		}
305256792Snwhitehorn	}
306190681Snwhitehorn
307256792Snwhitehorn	while ((sf = TAILQ_FIRST(&sf_buf_freelist)) == NULL) {
308256792Snwhitehorn		if (flags & SFB_NOWAIT)
309256792Snwhitehorn			goto done;
310190681Snwhitehorn
311256792Snwhitehorn		sf_buf_alloc_want++;
312256792Snwhitehorn		SFSTAT_INC(sf_allocwait);
313256792Snwhitehorn		error = msleep(&sf_buf_freelist, &sf_buf_lock,
314256792Snwhitehorn		    (flags & SFB_CATCH) ? PCATCH | PVM : PVM, "sfbufa", 0);
315256792Snwhitehorn		sf_buf_alloc_want--;
316190681Snwhitehorn
317256792Snwhitehorn		/*
318256792Snwhitehorn		 * If we got a signal, don't risk going back to sleep.
319256792Snwhitehorn		 */
320256792Snwhitehorn		if (error)
321256792Snwhitehorn			goto done;
322256792Snwhitehorn	}
323190681Snwhitehorn
324256792Snwhitehorn	TAILQ_REMOVE(&sf_buf_freelist, sf, free_entry);
325256792Snwhitehorn	if (sf->m != NULL)
326256792Snwhitehorn		LIST_REMOVE(sf, list_entry);
327190681Snwhitehorn
328256792Snwhitehorn	LIST_INSERT_HEAD(hash_list, sf, list_entry);
329256792Snwhitehorn	sf->ref_count = 1;
330256792Snwhitehorn	sf->m = m;
331256792Snwhitehorn	nsfbufsused++;
332256792Snwhitehorn	nsfbufspeak = imax(nsfbufspeak, nsfbufsused);
333256792Snwhitehorn	pmap_qenter(sf->kva, &sf->m, 1);
334190681Snwhitehorndone:
335256792Snwhitehorn	mtx_unlock(&sf_buf_lock);
336256792Snwhitehorn	return (sf);
337119563Salc}
338119563Salc
339119563Salc/*
340256792Snwhitehorn * Detach mapped page and release resources back to the system.
341190681Snwhitehorn *
342190681Snwhitehorn * Remove a reference from the given sf_buf, adding it to the free
343190681Snwhitehorn * list when its reference count reaches zero. A freed sf_buf still,
344190681Snwhitehorn * however, retains its virtual-to-physical mapping until it is
345190681Snwhitehorn * recycled or reactivated by sf_buf_alloc(9).
346119563Salc */
347119563Salcvoid
348127086Salcsf_buf_free(struct sf_buf *sf)
349119563Salc{
350190681Snwhitehorn	if (hw_direct_map)
351190681Snwhitehorn		return;
352190681Snwhitehorn
353256792Snwhitehorn	mtx_lock(&sf_buf_lock);
354256792Snwhitehorn	sf->ref_count--;
355256792Snwhitehorn	if (sf->ref_count == 0) {
356256792Snwhitehorn		TAILQ_INSERT_TAIL(&sf_buf_freelist, sf, free_entry);
357256792Snwhitehorn		nsfbufsused--;
358190681Snwhitehorn
359256792Snwhitehorn		if (sf_buf_alloc_want > 0)
360256792Snwhitehorn			wakeup(&sf_buf_freelist);
361256792Snwhitehorn	}
362256792Snwhitehorn	mtx_unlock(&sf_buf_lock);
363119563Salc}
364119563Salc
365119563Salc/*
36636865Sdfr * Software interrupt handler for queued VM system processing.
367126474Sgrehan */
368126474Sgrehanvoid
369126474Sgrehanswi_vm(void *dummy)
370126474Sgrehan{
371209950Snwhitehorn
37236865Sdfr	if (busdma_swi_pending != 0)
37336865Sdfr		busdma_swi();
37436865Sdfr}
37536865Sdfr
37636865Sdfr/*
37736865Sdfr * Tell whether this address is in some physical memory region.
37836865Sdfr * Currently used by the kernel coredump code in order to avoid
37936865Sdfr * dumping the ``ISA memory hole'' which could cause indefinite hangs,
38036865Sdfr * or other unpredictable behaviour.
38136865Sdfr */
38236865Sdfrint
383256792Snwhitehornis_physical_memory(vm_offset_t addr)
38436865Sdfr{
385256792Snwhitehorn
38636865Sdfr	/*
38736865Sdfr	 * stuff other tests for known memory-mapped devices (PCI?)
38836865Sdfr	 * here
38936865Sdfr	 */
390256792Snwhitehorn	return (1);
39136865Sdfr}
39299659Sbenno
39399659Sbenno/*
394209975Snwhitehorn * CPU threading functions related to the VM layer. These could be used
395209975Snwhitehorn * to map the SLB bits required for the kernel stack instead of forcing a
396209975Snwhitehorn * fixed-size KVA.
39799659Sbenno */
39899659Sbenno
39999659Sbennovoid
400119004Smarcelcpu_thread_swapin(struct thread *td)
401119004Smarcel{
402256792Snwhitehorn
40399659Sbenno}
40499659Sbenno
40599659Sbennovoid
406119004Smarcelcpu_thread_swapout(struct thread *td)
407119004Smarcel{
408256792Snwhitehorn
409119004Smarcel}
410119004Smarcel
411