Gecko [ 167.86.127.34 ]

Name	Size	Permission
cgo	[ DIR ]	drwxr-xr-x
debug	[ DIR ]	drwxr-xr-x
internal	[ DIR ]	drwxr-xr-x
msan	[ DIR ]	drwxr-xr-x
pprof	[ DIR ]	drwxr-xr-x
race	[ DIR ]	drwxr-xr-x
testdata	[ DIR ]	drwxr-xr-x
trace	[ DIR ]	drwxr-xr-x
HACKING.md	13.07 KB	-rw-r--r--
Makefile	178 B	-rw-r--r--
alg.go	10.18 KB	-rw-r--r--
asm.s	1.16 KB	-rw-r--r--
asm_386.s	40.2 KB	-rw-r--r--
asm_amd64.s	45.78 KB	-rw-r--r--
asm_arm.s	30.89 KB	-rw-r--r--
asm_arm64.s	33.12 KB	-rw-r--r--
asm_mips64x.s	22.45 KB	-rw-r--r--
asm_mipsx.s	24.72 KB	-rw-r--r--
asm_ppc64x.h	1023 B	-rw-r--r--
asm_ppc64x.s	29.39 KB	-rw-r--r--
asm_riscv64.s	17.38 KB	-rw-r--r--
asm_s390x.s	26.35 KB	-rw-r--r--
asm_wasm.s	9.65 KB	-rw-r--r--
atomic_arm64.s	259 B	-rw-r--r--
atomic_mips64x.s	296 B	-rw-r--r--
atomic_mipsx.s	258 B	-rw-r--r--
atomic_pointer.go	2.62 KB	-rw-r--r--
atomic_ppc64x.s	433 B	-rw-r--r--
atomic_riscv64.s	307 B	-rw-r--r--
auxv_none.go	358 B	-rw-r--r--
callers_test.go	7.7 KB	-rw-r--r--
cgo.go	2.01 KB	-rw-r--r--
cgo_mmap.go	2.38 KB	-rw-r--r--
cgo_ppc64x.go	411 B	-rw-r--r--
cgo_sigaction.go	3.09 KB	-rw-r--r--
cgocall.go	21.38 KB	-rw-r--r--
cgocallback.go	317 B	-rw-r--r--
cgocheck.go	6.8 KB	-rw-r--r--
chan.go	19.71 KB	-rw-r--r--
chan_test.go	21.27 KB	-rw-r--r--
chanbarrier_test.go	1.4 KB	-rw-r--r--
checkptr.go	2.5 KB	-rw-r--r--
checkptr_test.go	1.27 KB	-rw-r--r--
closure_test.go	936 B	-rw-r--r--
compiler.go	413 B	-rw-r--r--
complex.go	1.59 KB	-rw-r--r--
complex_test.go	1.05 KB	-rw-r--r--
cpuflags.go	740 B	-rw-r--r--
cpuflags_amd64.go	533 B	-rw-r--r--
cpuprof.go	6.65 KB	-rw-r--r--
cputicks.go	478 B	-rw-r--r--
crash_cgo_test.go	13.71 KB	-rw-r--r--
crash_nonunix_test.go	385 B	-rw-r--r--
crash_test.go	20.24 KB	-rw-r--r--
crash_unix_test.go	8.89 KB	-rw-r--r--
debug.go	1.63 KB	-rw-r--r--
debug_test.go	6.16 KB	-rw-r--r--
debugcall.go	2.83 KB	-rw-r--r--
debuglog.go	17.08 KB	-rw-r--r--
debuglog_off.go	356 B	-rw-r--r--
debuglog_on.go	1.09 KB	-rw-r--r--
debuglog_test.go	4.56 KB	-rw-r--r--
defer_test.go	9.98 KB	-rw-r--r--
defs1_linux.go	844 B	-rw-r--r--
defs1_netbsd_386.go	2.84 KB	-rw-r--r--
defs1_netbsd_amd64.go	3.07 KB	-rw-r--r--
defs1_netbsd_arm.go	2.96 KB	-rw-r--r--
defs1_netbsd_arm64.go	3.18 KB	-rw-r--r--
defs1_solaris_amd64.go	4.02 KB	-rw-r--r--
defs2_linux.go	3.51 KB	-rw-r--r--
defs3_linux.go	1.09 KB	-rw-r--r--
defs_aix.go	4.16 KB	-rw-r--r--
defs_aix_ppc64.go	3.61 KB	-rw-r--r--
defs_arm_linux.go	2.67 KB	-rw-r--r--
defs_darwin.go	3.84 KB	-rw-r--r--
defs_darwin_386.go	5.98 KB	-rw-r--r--
defs_darwin_amd64.go	6.07 KB	-rw-r--r--
defs_darwin_arm.go	3.78 KB	-rw-r--r--
defs_darwin_arm64.go	3.84 KB	-rw-r--r--
defs_dragonfly.go	2.54 KB	-rw-r--r--
defs_dragonfly_amd64.go	3.25 KB	-rw-r--r--
defs_freebsd.go	3.84 KB	-rw-r--r--
defs_freebsd_386.go	4.35 KB	-rw-r--r--
defs_freebsd_amd64.go	4.62 KB	-rw-r--r--
defs_freebsd_arm.go	3.68 KB	-rw-r--r--
defs_freebsd_arm64.go	4 KB	-rw-r--r--
defs_illumos_amd64.go	285 B	-rw-r--r--
defs_linux.go	3.04 KB	-rw-r--r--
defs_linux_386.go	4.05 KB	-rw-r--r--
defs_linux_amd64.go	4.56 KB	-rw-r--r--
defs_linux_arm.go	3.31 KB	-rw-r--r--
defs_linux_arm64.go	3.23 KB	-rw-r--r--
defs_linux_mips64x.go	3.04 KB	-rw-r--r--
defs_linux_mipsx.go	3.18 KB	-rw-r--r--
defs_linux_ppc64.go	3.28 KB	-rw-r--r--
defs_linux_ppc64le.go	3.28 KB	-rw-r--r--
defs_linux_riscv64.go	3.27 KB	-rw-r--r--
defs_linux_s390x.go	2.76 KB	-rw-r--r--
defs_netbsd.go	2.74 KB	-rw-r--r--
defs_netbsd_386.go	854 B	-rw-r--r--
defs_netbsd_amd64.go	1.01 KB	-rw-r--r--
defs_netbsd_arm.go	763 B	-rw-r--r--
defs_openbsd.go	2.6 KB	-rw-r--r--
defs_openbsd_386.go	2.63 KB	-rw-r--r--
defs_openbsd_amd64.go	2.83 KB	-rw-r--r--
defs_openbsd_arm.go	2.74 KB	-rw-r--r--
defs_openbsd_arm64.go	2.34 KB	-rw-r--r--
defs_plan9_386.go	1.47 KB	-rw-r--r--
defs_plan9_amd64.go	1.66 KB	-rw-r--r--
defs_plan9_arm.go	1.73 KB	-rw-r--r--
defs_solaris.go	3.33 KB	-rw-r--r--
defs_solaris_amd64.go	1003 B	-rw-r--r--
defs_windows.go	2.07 KB	-rw-r--r--
defs_windows_386.go	3.75 KB	-rw-r--r--
defs_windows_amd64.go	4.51 KB	-rw-r--r--
defs_windows_arm.go	3.59 KB	-rw-r--r--
duff_386.s	8.24 KB	-rw-r--r--
duff_amd64.s	5.53 KB	-rw-r--r--
duff_arm.s	7.11 KB	-rw-r--r--
duff_arm64.s	5.25 KB	-rw-r--r--
duff_mips64x.s	11.28 KB	-rw-r--r--
duff_ppc64x.s	2.45 KB	-rw-r--r--
duff_s390x.s	507 B	-rw-r--r--
env_plan9.go	855 B	-rw-r--r--
env_posix.go	1.82 KB	-rw-r--r--
env_test.go	1.28 KB	-rw-r--r--
error.go	7.26 KB	-rw-r--r--
example_test.go	1.34 KB	-rw-r--r--
export_aix_test.go	204 B	-rw-r--r--
export_arm_test.go	226 B	-rw-r--r--
export_darwin_test.go	351 B	-rw-r--r--
export_debug_test.go	5.28 KB	-rw-r--r--
export_debuglog_test.go	1.27 KB	-rw-r--r--
export_futex_test.go	529 B	-rw-r--r--
export_linux_test.go	429 B	-rw-r--r--
export_mmap_test.go	481 B	-rw-r--r--
export_solaris_test.go	282 B	-rw-r--r--
export_test.go	23.58 KB	-rw-r--r--
export_unix_test.go	2.28 KB	-rw-r--r--
export_windows_test.go	652 B	-rw-r--r--
extern.go	11.6 KB	-rw-r--r--
fastlog2.go	1.22 KB	-rw-r--r--
fastlog2_test.go	784 B	-rw-r--r--
fastlog2table.go	904 B	-rw-r--r--
float.go	1.35 KB	-rw-r--r--
funcdata.h	2.44 KB	-rw-r--r--
futex_test.go	2.1 KB	-rw-r--r--
gc_test.go	13.22 KB	-rw-r--r--
gcinfo_test.go	6.18 KB	-rw-r--r--
go_tls.h	366 B	-rw-r--r--
hash32.go	2.51 KB	-rw-r--r--
hash64.go	2.6 KB	-rw-r--r--
hash_test.go	17.54 KB	-rw-r--r--
heapdump.go	17.1 KB	-rw-r--r--
iface.go	15.78 KB	-rw-r--r--
iface_test.go	6.81 KB	-rw-r--r--
lfstack.go	1.77 KB	-rw-r--r--
lfstack_32bit.go	522 B	-rw-r--r--
lfstack_64bit.go	2.15 KB	-rw-r--r--
lfstack_test.go	2.78 KB	-rw-r--r--
libfuzzer.go	2.58 KB	-rw-r--r--
libfuzzer_amd64.s	940 B	-rw-r--r--
libfuzzer_arm64.s	751 B	-rw-r--r--
lock_futex.go	5.06 KB	-rw-r--r--
lock_js.go	5.45 KB	-rw-r--r--
lock_sema.go	6.6 KB	-rw-r--r--
malloc.go	48.32 KB	-rw-r--r--
malloc_test.go	9.37 KB	-rw-r--r--
map.go	42.13 KB	-rw-r--r--
map_benchmark_test.go	10.16 KB	-rw-r--r--
map_fast32.go	12.18 KB	-rw-r--r--
map_fast64.go	12.37 KB	-rw-r--r--
map_faststr.go	13.82 KB	-rw-r--r--
map_test.go	27.11 KB	-rw-r--r--
mbarrier.go	12.14 KB	-rw-r--r--
mbitmap.go	67.53 KB	-rw-r--r--
mcache.go	5.61 KB	-rw-r--r--
mcentral.go	7.14 KB	-rw-r--r--
mem_aix.go	1.93 KB	-rw-r--r--
mem_bsd.go	2.05 KB	-rw-r--r--
mem_darwin.go	1.88 KB	-rw-r--r--
mem_js.go	2.32 KB	-rw-r--r--
mem_linux.go	5.58 KB	-rw-r--r--
mem_plan9.go	4.53 KB	-rw-r--r--
mem_windows.go	3.86 KB	-rw-r--r--
memclr_386.s	2.4 KB	-rw-r--r--
memclr_amd64.s	3.65 KB	-rw-r--r--
memclr_arm.s	2.44 KB	-rw-r--r--
memclr_arm64.s	3.48 KB	-rw-r--r--
memclr_mips64x.s	785 B	-rw-r--r--
memclr_mipsx.s	1.24 KB	-rw-r--r--
memclr_plan9_386.s	905 B	-rw-r--r--
memclr_plan9_amd64.s	433 B	-rw-r--r--
memclr_ppc64x.s	4.2 KB	-rw-r--r--
memclr_riscv64.s	848 B	-rwxr-xr-x
memclr_s390x.s	1.89 KB	-rw-r--r--
memclr_wasm.s	544 B	-rw-r--r--
memmove_386.s	4.45 KB	-rw-r--r--
memmove_amd64.s	12.33 KB	-rw-r--r--
memmove_arm.s	5.9 KB	-rw-r--r--
memmove_arm64.s	3.56 KB	-rw-r--r--
memmove_linux_amd64_test.go	1.61 KB	-rw-r--r--
memmove_mips64x.s	1.82 KB	-rw-r--r--
memmove_mipsx.s	4.39 KB	-rw-r--r--
memmove_plan9_386.s	3.06 KB	-rw-r--r--
memmove_plan9_amd64.s	3.04 KB	-rw-r--r--
memmove_ppc64x.s	3.33 KB	-rw-r--r--
memmove_riscv64.s	1.81 KB	-rwxr-xr-x
memmove_s390x.s	2.92 KB	-rw-r--r--
memmove_test.go	10.97 KB	-rw-r--r--
memmove_wasm.s	1.74 KB	-rw-r--r--
mfinal.go	14.8 KB	-rw-r--r--
mfinal_test.go	5.85 KB	-rw-r--r--
mfixalloc.go	2.72 KB	-rw-r--r--
mgc.go	74.87 KB	-rw-r--r--
mgcmark.go	46.5 KB	-rw-r--r--
mgcscavenge.go	30.95 KB	-rw-r--r--
mgcscavenge_test.go	12.34 KB	-rw-r--r--
mgcstack.go	10.55 KB	-rw-r--r--
mgcsweep.go	14.79 KB	-rw-r--r--
mgcsweepbuf.go	5.98 KB	-rw-r--r--
mgcwork.go	14.24 KB	-rw-r--r--
mheap.go	61.5 KB	-rw-r--r--
mkduff.go	6.23 KB	-rw-r--r--
mkfastlog2table.go	1.32 KB	-rw-r--r--
mkpreempt.go	13.33 KB	-rw-r--r--
mksizeclasses.go	8.62 KB	-rw-r--r--
mmap.go	847 B	-rw-r--r--
mpagealloc.go	35.25 KB	-rw-r--r--
mpagealloc_32bit.go	3.75 KB	-rw-r--r--
mpagealloc_64bit.go	6.51 KB	-rw-r--r--
mpagealloc_test.go	28.88 KB	-rw-r--r--
mpagecache.go	5.03 KB	-rw-r--r--
mpagecache_test.go	9.93 KB	-rw-r--r--
mpallocbits.go	10.69 KB	-rw-r--r--
mpallocbits_test.go	12.93 KB	-rw-r--r--
mprof.go	24.06 KB	-rw-r--r--
mranges.go	5.41 KB	-rw-r--r--
msan.go	1.39 KB	-rw-r--r--
msan0.go	647 B	-rw-r--r--
msan_amd64.s	2.03 KB	-rw-r--r--
msan_arm64.s	1.69 KB	-rw-r--r--
msize.go	785 B	-rw-r--r--
mstats.go	22.62 KB	-rw-r--r--
mwbbuf.go	10.07 KB	-rw-r--r--
nbpipe_fcntl_libc_test.go	463 B	-rw-r--r--
nbpipe_fcntl_unix_test.go	445 B	-rw-r--r--
nbpipe_pipe.go	411 B	-rw-r--r--
nbpipe_pipe2.go	509 B	-rw-r--r--
nbpipe_test.go	2.17 KB	-rw-r--r--
net_plan9.go	645 B	-rw-r--r--
netpoll.go	14.46 KB	-rw-r--r--
netpoll_aix.go	4.64 KB	-rw-r--r--
netpoll_epoll.go	4 KB	-rw-r--r--
netpoll_fake.go	648 B	-rw-r--r--
netpoll_kqueue.go	4.39 KB	-rw-r--r--
netpoll_solaris.go	10.56 KB	-rw-r--r--
netpoll_stub.go	1.3 KB	-rw-r--r--
netpoll_windows.go	4.51 KB	-rw-r--r--
norace_linux_test.go	888 B	-rw-r--r--
norace_test.go	979 B	-rw-r--r--
numcpu_freebsd_test.go	381 B	-rw-r--r--
os2_aix.go	20.67 KB	-rw-r--r--
os2_freebsd.go	302 B	-rw-r--r--
os2_openbsd.go	296 B	-rw-r--r--
os2_plan9.go	1.48 KB	-rw-r--r--
os2_solaris.go	320 B	-rw-r--r--
os3_plan9.go	3.99 KB	-rw-r--r--
os3_solaris.go	16.92 KB	-rw-r--r--
os_aix.go	8.29 KB	-rw-r--r--
os_android.go	463 B	-rw-r--r--
os_darwin.go	10.59 KB	-rw-r--r--
os_darwin_arm.go	749 B	-rw-r--r--
os_darwin_arm64.go	416 B	-rw-r--r--
os_dragonfly.go	6.2 KB	-rw-r--r--
os_freebsd.go	10.97 KB	-rw-r--r--
os_freebsd2.go	478 B	-rw-r--r--
os_freebsd_amd64.go	529 B	-rw-r--r--
os_freebsd_arm.go	1.32 KB	-rw-r--r--
os_freebsd_arm64.go	2.97 KB	-rw-r--r--
os_freebsd_noauxv.go	254 B	-rw-r--r--
os_illumos.go	3.93 KB	-rw-r--r--
os_js.go	2.93 KB	-rw-r--r--
os_linux.go	13.16 KB	-rw-r--r--
os_linux_arm.go	1.35 KB	-rw-r--r--
os_linux_arm64.go	1.02 KB	-rw-r--r--
os_linux_be64.go	816 B	-rw-r--r--
os_linux_generic.go	916 B	-rw-r--r--
os_linux_mips64x.go	999 B	-rw-r--r--
os_linux_mipsx.go	1.05 KB	-rw-r--r--
os_linux_noauxv.go	307 B	-rw-r--r--
os_linux_novdso.go	298 B	-rw-r--r--
os_linux_ppc64x.go	527 B	-rw-r--r--
os_linux_riscv64.go	198 B	-rw-r--r--
os_linux_s390x.go	455 B	-rw-r--r--
os_linux_x86.go	2.69 KB	-rw-r--r--
os_netbsd.go	8.49 KB	-rw-r--r--
os_netbsd_386.go	588 B	-rw-r--r--
os_netbsd_amd64.go	585 B	-rw-r--r--
os_netbsd_arm.go	1.13 KB	-rw-r--r--
os_netbsd_arm64.go	827 B	-rw-r--r--
os_nonopenbsd.go	436 B	-rw-r--r--
os_only_solaris.go	356 B	-rw-r--r--
os_openbsd.go	7.81 KB	-rw-r--r--
os_openbsd_arm.go	749 B	-rw-r--r--
os_openbsd_arm64.go	714 B	-rw-r--r--
os_plan9.go	9.3 KB	-rw-r--r--
os_plan9_arm.go	462 B	-rw-r--r--
os_solaris.go	6.49 KB	-rw-r--r--
os_windows.go	37.01 KB	-rw-r--r--
os_windows_arm.go	511 B	-rw-r--r--
panic.go	42.23 KB	-rw-r--r--
panic32.go	4.79 KB	-rw-r--r--
plugin.go	4.16 KB	-rw-r--r--
preempt.go	14.72 KB	-rw-r--r--
preempt_386.s	983 B	-rw-r--r--
preempt_amd64.s	1.62 KB	-rw-r--r--
preempt_arm.s	1.48 KB	-rw-r--r--
preempt_arm64.s	2.8 KB	-rw-r--r--
preempt_mips64x.s	2.71 KB	-rw-r--r--
preempt_mipsx.s	2.68 KB	-rw-r--r--
preempt_nonwindows.go	289 B	-rw-r--r--
preempt_ppc64x.s	2.71 KB	-rw-r--r--
preempt_riscv64.s	197 B	-rw-r--r--
preempt_s390x.s	1.01 KB	-rw-r--r--
preempt_wasm.s	176 B	-rw-r--r--
print.go	5.98 KB	-rw-r--r--
proc.go	149.75 KB	-rw-r--r--
proc_runtime_test.go	820 B	-rw-r--r--
proc_test.go	22.89 KB	-rw-r--r--
profbuf.go	18.26 KB	-rw-r--r--
profbuf_test.go	8.65 KB	-rw-r--r--
proflabel.go	1.52 KB	-rw-r--r--
race.go	18.11 KB	-rw-r--r--
race0.go	2.61 KB	-rw-r--r--
race_amd64.s	13.59 KB	-rw-r--r--
race_arm64.s	13.53 KB	-rw-r--r--
race_ppc64le.s	17.93 KB	-rw-r--r--
rand_test.go	783 B	-rw-r--r--
rdebug.go	553 B	-rw-r--r--
relax_stub.go	597 B	-rw-r--r--
rt0_aix_ppc64.s	4.33 KB	-rw-r--r--
rt0_android_386.s	822 B	-rw-r--r--
rt0_android_amd64.s	754 B	-rw-r--r--
rt0_android_arm.s	843 B	-rw-r--r--
rt0_android_arm64.s	941 B	-rw-r--r--
rt0_darwin_386.s	452 B	-rw-r--r--
rt0_darwin_amd64.s	399 B	-rw-r--r--
rt0_darwin_arm.s	290 B	-rw-r--r--
rt0_darwin_arm64.s	2.32 KB	-rw-r--r--
rt0_dragonfly_amd64.s	448 B	-rw-r--r--
rt0_freebsd_386.s	454 B	-rw-r--r--
rt0_freebsd_amd64.s	442 B	-rw-r--r--
rt0_freebsd_arm.s	298 B	-rw-r--r--
rt0_freebsd_arm64.s	2.46 KB	-rw-r--r--
rt0_illumos_amd64.s	311 B	-rw-r--r--
rt0_js_wasm.s	2.3 KB	-rw-r--r--
rt0_linux_386.s	450 B	-rw-r--r--
rt0_linux_amd64.s	307 B	-rw-r--r--
rt0_linux_arm.s	1007 B	-rw-r--r--
rt0_linux_arm64.s	2.39 KB	-rw-r--r--
rt0_linux_mips64x.s	1015 B	-rw-r--r--
rt0_linux_mipsx.s	798 B	-rw-r--r--
rt0_linux_ppc64.s	705 B	-rw-r--r--
rt0_linux_ppc64le.s	3.72 KB	-rw-r--r--
rt0_linux_riscv64.s	370 B	-rw-r--r--
rt0_linux_s390x.s	676 B	-rw-r--r--
rt0_netbsd_386.s	452 B	-rw-r--r--
rt0_netbsd_amd64.s	309 B	-rw-r--r--
rt0_netbsd_arm.s	296 B	-rw-r--r--
rt0_netbsd_arm64.s	2.39 KB	-rw-r--r--
rt0_openbsd_386.s	454 B	-rw-r--r--
rt0_openbsd_amd64.s	311 B	-rw-r--r--
rt0_openbsd_arm.s	298 B	-rw-r--r--
rt0_openbsd_arm64.s	2.42 KB	-rw-r--r--
rt0_plan9_386.s	523 B	-rw-r--r--
rt0_plan9_amd64.s	481 B	-rw-r--r--
rt0_plan9_arm.s	397 B	-rw-r--r--
rt0_solaris_amd64.s	311 B	-rw-r--r--
rt0_windows_386.s	1.28 KB	-rw-r--r--
rt0_windows_amd64.s	1.15 KB	-rw-r--r--
rt0_windows_arm.s	386 B	-rw-r--r--
runtime-gdb.py	14.83 KB	-rw-r--r--
runtime-gdb_test.go	16.85 KB	-rw-r--r--
runtime-lldb_test.go	5.09 KB	-rw-r--r--
runtime.go	1.42 KB	-rw-r--r--
runtime1.go	11.97 KB	-rw-r--r--
runtime2.go	37.85 KB	-rw-r--r--
runtime_linux_test.go	1.46 KB	-rw-r--r--
runtime_mmap_test.go	1.82 KB	-rw-r--r--
runtime_test.go	7.81 KB	-rw-r--r--
runtime_unix_test.go	1.2 KB	-rw-r--r--
rwmutex.go	3.4 KB	-rw-r--r--
rwmutex_test.go	4.03 KB	-rw-r--r--
select.go	13.24 KB	-rw-r--r--
sema.go	15.95 KB	-rw-r--r--
sema_test.go	2.41 KB	-rw-r--r--
semasleep_test.go	1.62 KB	-rw-r--r--
sigaction.go	460 B	-rw-r--r--
signal_386.go	2.14 KB	-rw-r--r--
signal_aix_ppc64.go	3.55 KB	-rw-r--r--
signal_amd64.go	2.56 KB	-rw-r--r--
signal_arm.go	2.63 KB	-rw-r--r--
signal_arm64.go	3.12 KB	-rw-r--r--
signal_darwin.go	2.13 KB	-rw-r--r--
signal_darwin_386.go	2.33 KB	-rw-r--r--
signal_darwin_amd64.go	3.85 KB	-rw-r--r--
signal_darwin_arm.go	2.71 KB	-rw-r--r--
signal_darwin_arm64.go	3.6 KB	-rw-r--r--
signal_dragonfly.go	2.17 KB	-rw-r--r--
signal_dragonfly_amd64.go	2.01 KB	-rw-r--r--
signal_freebsd.go	2.2 KB	-rw-r--r--
signal_freebsd_386.go	1.55 KB	-rw-r--r--
signal_freebsd_amd64.go	2.03 KB	-rw-r--r--
signal_freebsd_arm.go	2.18 KB	-rw-r--r--
signal_freebsd_arm64.go	3.23 KB	-rw-r--r--
signal_linux_386.go	1.59 KB	-rw-r--r--
signal_linux_amd64.go	2.05 KB	-rw-r--r--
signal_linux_arm.go	2.13 KB	-rw-r--r--
signal_linux_arm64.go	2.95 KB	-rw-r--r--
signal_linux_mips64x.go	3.35 KB	-rw-r--r--
signal_linux_mipsx.go	3.67 KB	-rw-r--r--
signal_linux_ppc64x.go	3.42 KB	-rw-r--r--
signal_linux_riscv64.go	2.92 KB	-rw-r--r--
signal_linux_s390x.go	4.45 KB	-rw-r--r--
signal_mips64x.go	3.16 KB	-rw-r--r--
signal_mipsx.go	3.05 KB	-rw-r--r--
signal_netbsd.go	2.18 KB	-rw-r--r--
signal_netbsd_386.go	1.76 KB	-rw-r--r--
signal_netbsd_amd64.go	2.33 KB	-rw-r--r--
signal_netbsd_arm.go	2.3 KB	-rw-r--r--
signal_netbsd_arm64.go	3.4 KB	-rw-r--r--
signal_openbsd.go	2.15 KB	-rw-r--r--
signal_openbsd_386.go	1.58 KB	-rw-r--r--
signal_openbsd_amd64.go	2.04 KB	-rw-r--r--
signal_openbsd_arm.go	2.12 KB	-rw-r--r--
signal_openbsd_arm64.go	3.38 KB	-rw-r--r--
signal_plan9.go	1.93 KB	-rw-r--r--
signal_ppc64x.go	3.61 KB	-rw-r--r--
signal_riscv64.go	2.45 KB	-rw-r--r--
signal_solaris.go	4.5 KB	-rw-r--r--
signal_solaris_amd64.go	2.47 KB	-rw-r--r--
signal_unix.go	35.95 KB	-rw-r--r--
signal_windows.go	8.54 KB	-rw-r--r--
signal_windows_test.go	1.6 KB	-rw-r--r--
sigqueue.go	7.69 KB	-rw-r--r--
sigqueue_note.go	654 B	-rw-r--r--
sigqueue_plan9.go	3.31 KB	-rw-r--r--
sigtab_aix.go	11.3 KB	-rw-r--r--
sigtab_linux_generic.go	3.49 KB	-rw-r--r--
sigtab_linux_mipsx.go	5.89 KB	-rw-r--r--
sizeclasses.go	7.9 KB	-rw-r--r--
sizeof_test.go	839 B	-rw-r--r--
slice.go	6.88 KB	-rw-r--r--
slice_test.go	8.78 KB	-rw-r--r--
softfloat64.go	10.7 KB	-rw-r--r--
softfloat64_test.go	4.05 KB	-rw-r--r--
stack.go	39.14 KB	-rw-r--r--
stack_test.go	19.9 KB	-rw-r--r--
string.go	11.52 KB	-rw-r--r--
string_test.go	10.35 KB	-rw-r--r--
stubs.go	13.08 KB	-rw-r--r--
stubs2.go	1.04 KB	-rw-r--r--
stubs3.go	289 B	-rw-r--r--
stubs32.go	393 B	-rw-r--r--
stubs_386.go	490 B	-rw-r--r--
stubs_amd64.go	348 B	-rw-r--r--
stubs_arm.go	454 B	-rw-r--r--
stubs_arm64.go	256 B	-rw-r--r--
stubs_linux.go	646 B	-rw-r--r--
stubs_mips64x.go	283 B	-rw-r--r--
stubs_mipsx.go	279 B	-rw-r--r--
stubs_nonlinux.go	297 B	-rw-r--r--
stubs_ppc64x.go	296 B	-rw-r--r--
stubs_s390x.go	256 B	-rw-r--r--
symtab.go	28.32 KB	-rw-r--r--
symtab_test.go	4.1 KB	-rw-r--r--
sys_aix_ppc64.s	7.17 KB	-rw-r--r--
sys_arm.go	521 B	-rw-r--r--
sys_arm64.go	469 B	-rw-r--r--
sys_darwin.go	15.96 KB	-rw-r--r--
sys_darwin_32.go	533 B	-rw-r--r--
sys_darwin_386.s	18.55 KB	-rw-r--r--
sys_darwin_64.go	513 B	-rw-r--r--
sys_darwin_amd64.s	18.07 KB	-rw-r--r--
sys_darwin_arm.s	13.7 KB	-rw-r--r--
sys_darwin_arm64.s	15.84 KB	-rw-r--r--
sys_dragonfly_amd64.s	8.32 KB	-rw-r--r--
sys_freebsd_386.s	8.92 KB	-rw-r--r--
sys_freebsd_amd64.s	10.72 KB	-rw-r--r--
sys_freebsd_arm.s	10.64 KB	-rw-r--r--
sys_freebsd_arm64.s	10.75 KB	-rw-r--r--
sys_linux_386.s	17.57 KB	-rw-r--r--
sys_linux_amd64.s	17.07 KB	-rw-r--r--
sys_linux_arm.s	14.9 KB	-rw-r--r--
sys_linux_arm64.s	14.32 KB	-rw-r--r--
sys_linux_mips64x.s	12 KB	-rw-r--r--
sys_linux_mipsx.s	11.13 KB	-rw-r--r--
sys_linux_ppc64x.s	14.71 KB	-rw-r--r--
sys_linux_riscv64.s	10.38 KB	-rw-r--r--

Code Editor : time.go

// Copyright 2009 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// Time-related runtime and pieces of package time.

package runtime

import (
	"runtime/internal/atomic"
	"runtime/internal/sys"
	"unsafe"
)

// Package time knows the layout of this structure.
// If this struct changes, adjust ../time/sleep.go:/runtimeTimer.
type timer struct {
	// If this timer is on a heap, which P's heap it is on.
	// puintptr rather than *p to match uintptr in the versions
	// of this struct defined in other packages.
	pp puintptr

// Timer wakes up at when, and then at when+period, ... (period > 0 only)
	// each time calling f(arg, now) in the timer goroutine, so f must be
	// a well-behaved function and not block.
	when   int64
	period int64
	f      func(interface{}, uintptr)
	arg    interface{}
	seq    uintptr

// What to set the when field to in timerModifiedXX status.
	nextwhen int64

// The status field holds one of the values below.
	status uint32
}

// Code outside this file has to be careful in using a timer value.
//
// The pp, status, and nextwhen fields may only be used by code in this file.
//
// Code that creates a new timer value can set the when, period, f,
// arg, and seq fields.
// A new timer value may be passed to addtimer (called by time.startTimer).
// After doing that no fields may be touched.
//
// An active timer (one that has been passed to addtimer) may be
// passed to deltimer (time.stopTimer), after which it is no longer an
// active timer. It is an inactive timer.
// In an inactive timer the period, f, arg, and seq fields may be modified,
// but not the when field.
// It's OK to just drop an inactive timer and let the GC collect it.
// It's not OK to pass an inactive timer to addtimer.
// Only newly allocated timer values may be passed to addtimer.
//
// An active timer may be passed to modtimer. No fields may be touched.
// It remains an active timer.
//
// An inactive timer may be passed to resettimer to turn into an
// active timer with an updated when field.
// It's OK to pass a newly allocated timer value to resettimer.
//
// Timer operations are addtimer, deltimer, modtimer, resettimer,
// cleantimers, adjusttimers, and runtimer.
//
// We don't permit calling addtimer/deltimer/modtimer/resettimer simultaneously,
// but adjusttimers and runtimer can be called at the same time as any of those.
//
// Active timers live in heaps attached to P, in the timers field.
// Inactive timers live there too temporarily, until they are removed.
//
// addtimer:
//   timerNoStatus   -> timerWaiting
//   anything else   -> panic: invalid value
// deltimer:
//   timerWaiting         -> timerModifying -> timerDeleted
//   timerModifiedEarlier -> timerModifying -> timerDeleted
//   timerModifiedLater   -> timerModifying -> timerDeleted
//   timerNoStatus        -> do nothing
//   timerDeleted         -> do nothing
//   timerRemoving        -> do nothing
//   timerRemoved         -> do nothing
//   timerRunning         -> wait until status changes
//   timerMoving          -> wait until status changes
//   timerModifying       -> wait until status changes
// modtimer:
//   timerWaiting    -> timerModifying -> timerModifiedXX
//   timerModifiedXX -> timerModifying -> timerModifiedYY
//   timerNoStatus   -> timerModifying -> timerWaiting
//   timerRemoved    -> timerModifying -> timerWaiting
//   timerDeleted    -> timerModifying -> timerModifiedXX
//   timerRunning    -> wait until status changes
//   timerMoving     -> wait until status changes
//   timerRemoving   -> wait until status changes
//   timerModifying  -> wait until status changes
// cleantimers (looks in P's timer heap):
//   timerDeleted    -> timerRemoving -> timerRemoved
//   timerModifiedXX -> timerMoving -> timerWaiting
// adjusttimers (looks in P's timer heap):
//   timerDeleted    -> timerRemoving -> timerRemoved
//   timerModifiedXX -> timerMoving -> timerWaiting
// runtimer (looks in P's timer heap):
//   timerNoStatus   -> panic: uninitialized timer
//   timerWaiting    -> timerWaiting or
//   timerWaiting    -> timerRunning -> timerNoStatus or
//   timerWaiting    -> timerRunning -> timerWaiting
//   timerModifying  -> wait until status changes
//   timerModifiedXX -> timerMoving -> timerWaiting
//   timerDeleted    -> timerRemoving -> timerRemoved
//   timerRunning    -> panic: concurrent runtimer calls
//   timerRemoved    -> panic: inconsistent timer heap
//   timerRemoving   -> panic: inconsistent timer heap
//   timerMoving     -> panic: inconsistent timer heap

// Values for the timer status field.
const (
	// Timer has no status set yet.
	timerNoStatus = iota

// Waiting for timer to fire.
	// The timer is in some P's heap.
	timerWaiting

// Running the timer function.
	// A timer will only have this status briefly.
	timerRunning

// The timer is deleted and should be removed.
	// It should not be run, but it is still in some P's heap.
	timerDeleted

// The timer is being removed.
	// The timer will only have this status briefly.
	timerRemoving

// The timer has been stopped.
	// It is not in any P's heap.
	timerRemoved

// The timer is being modified.
	// The timer will only have this status briefly.
	timerModifying

// The timer has been modified to an earlier time.
	// The new when value is in the nextwhen field.
	// The timer is in some P's heap, possibly in the wrong place.
	timerModifiedEarlier

// The timer has been modified to the same or a later time.
	// The new when value is in the nextwhen field.
	// The timer is in some P's heap, possibly in the wrong place.
	timerModifiedLater

// The timer has been modified and is being moved.
	// The timer will only have this status briefly.
	timerMoving
)

// maxWhen is the maximum value for timer's when field.
const maxWhen = 1<<63 - 1

// verifyTimers can be set to true to add debugging checks that the
// timer heaps are valid.
const verifyTimers = false

// Package time APIs.
// Godoc uses the comments in package time, not these.

// time.now is implemented in assembly.

// timeSleep puts the current goroutine to sleep for at least ns nanoseconds.
//go:linkname timeSleep time.Sleep
func timeSleep(ns int64) {
	if ns <= 0 {
		return
	}

gp := getg()
	t := gp.timer
	if t == nil {
		t = new(timer)
		gp.timer = t
	}
	t.f = goroutineReady
	t.arg = gp
	t.nextwhen = nanotime() + ns
	gopark(resetForSleep, unsafe.Pointer(t), waitReasonSleep, traceEvGoSleep, 1)
}

// resetForSleep is called after the goroutine is parked for timeSleep.
// We can't call resettimer in timeSleep itself because if this is a short
// sleep and there are many goroutines then the P can wind up running the
// timer function, goroutineReady, before the goroutine has been parked.
func resetForSleep(gp *g, ut unsafe.Pointer) bool {
	t := (*timer)(ut)
	resettimer(t, t.nextwhen)
	return true
}

// startTimer adds t to the timer heap.
//go:linkname startTimer time.startTimer
func startTimer(t *timer) {
	if raceenabled {
		racerelease(unsafe.Pointer(t))
	}
	addtimer(t)
}

// stopTimer stops a timer.
// It reports whether t was stopped before being run.
//go:linkname stopTimer time.stopTimer
func stopTimer(t *timer) bool {
	return deltimer(t)
}

// resetTimer resets an inactive timer, adding it to the heap.
//go:linkname resetTimer time.resetTimer
func resetTimer(t *timer, when int64) {
	if raceenabled {
		racerelease(unsafe.Pointer(t))
	}
	resettimer(t, when)
}

// Go runtime.

// Ready the goroutine arg.
func goroutineReady(arg interface{}, seq uintptr) {
	goready(arg.(*g), 0)
}

// addtimer adds a timer to the current P.
// This should only be called with a newly created timer.
// That avoids the risk of changing the when field of a timer in some P's heap,
// which could cause the heap to become unsorted.
func addtimer(t *timer) {
	// when must never be negative; otherwise runtimer will overflow
	// during its delta calculation and never expire other runtime timers.
	if t.when < 0 {
		t.when = maxWhen
	}
	if t.status != timerNoStatus {
		throw("addtimer called with initialized timer")
	}
	t.status = timerWaiting

when := t.when

pp := getg().m.p.ptr()
	lock(&pp.timersLock)
	cleantimers(pp)
	doaddtimer(pp, t)
	unlock(&pp.timersLock)

wakeNetPoller(when)
}

// doaddtimer adds t to the current P's heap.
// The caller must have locked the timers for pp.
func doaddtimer(pp *p, t *timer) {
	// Timers rely on the network poller, so make sure the poller
	// has started.
	if netpollInited == 0 {
		netpollGenericInit()
	}

if t.pp != 0 {
		throw("doaddtimer: P already set in timer")
	}
	t.pp.set(pp)
	i := len(pp.timers)
	pp.timers = append(pp.timers, t)
	siftupTimer(pp.timers, i)
	if t == pp.timers[0] {
		atomic.Store64(&pp.timer0When, uint64(t.when))
	}
	atomic.Xadd(&pp.numTimers, 1)
}

// deltimer deletes the timer t. It may be on some other P, so we can't
// actually remove it from the timers heap. We can only mark it as deleted.
// It will be removed in due course by the P whose heap it is on.
// Reports whether the timer was removed before it was run.
func deltimer(t *timer) bool {
	for {
		switch s := atomic.Load(&t.status); s {
		case timerWaiting, timerModifiedLater:
			// Prevent preemption while the timer is in timerModifying.
			// This could lead to a self-deadlock. See #38070.
			mp := acquirem()
			if atomic.Cas(&t.status, s, timerModifying) {
				// Must fetch t.pp before changing status,
				// as cleantimers in another goroutine
				// can clear t.pp of a timerDeleted timer.
				tpp := t.pp.ptr()
				if !atomic.Cas(&t.status, timerModifying, timerDeleted) {
					badTimer()
				}
				releasem(mp)
				atomic.Xadd(&tpp.deletedTimers, 1)
				// Timer was not yet run.
				return true
			} else {
				releasem(mp)
			}
		case timerModifiedEarlier:
			// Prevent preemption while the timer is in timerModifying.
			// This could lead to a self-deadlock. See #38070.
			mp := acquirem()
			if atomic.Cas(&t.status, s, timerModifying) {
				// Must fetch t.pp before setting status
				// to timerDeleted.
				tpp := t.pp.ptr()
				atomic.Xadd(&tpp.adjustTimers, -1)
				if !atomic.Cas(&t.status, timerModifying, timerDeleted) {
					badTimer()
				}
				releasem(mp)
				atomic.Xadd(&tpp.deletedTimers, 1)
				// Timer was not yet run.
				return true
			} else {
				releasem(mp)
			}
		case timerDeleted, timerRemoving, timerRemoved:
			// Timer was already run.
			return false
		case timerRunning, timerMoving:
			// The timer is being run or moved, by a different P.
			// Wait for it to complete.
			osyield()
		case timerNoStatus:
			// Removing timer that was never added or
			// has already been run. Also see issue 21874.
			return false
		case timerModifying:
			// Simultaneous calls to deltimer and modtimer.
			// Wait for the other call to complete.
			osyield()
		default:
			badTimer()
		}
	}
}

// dodeltimer removes timer i from the current P's heap.
// We are locked on the P when this is called.
// It reports whether it saw no problems due to races.
// The caller must have locked the timers for pp.
func dodeltimer(pp *p, i int) {
	if t := pp.timers[i]; t.pp.ptr() != pp {
		throw("dodeltimer: wrong P")
	} else {
		t.pp = 0
	}
	last := len(pp.timers) - 1
	if i != last {
		pp.timers[i] = pp.timers[last]
	}
	pp.timers[last] = nil
	pp.timers = pp.timers[:last]
	if i != last {
		// Moving to i may have moved the last timer to a new parent,
		// so sift up to preserve the heap guarantee.
		siftupTimer(pp.timers, i)
		siftdownTimer(pp.timers, i)
	}
	if i == 0 {
		updateTimer0When(pp)
	}
	atomic.Xadd(&pp.numTimers, -1)
}

// dodeltimer0 removes timer 0 from the current P's heap.
// We are locked on the P when this is called.
// It reports whether it saw no problems due to races.
// The caller must have locked the timers for pp.
func dodeltimer0(pp *p) {
	if t := pp.timers[0]; t.pp.ptr() != pp {
		throw("dodeltimer0: wrong P")
	} else {
		t.pp = 0
	}
	last := len(pp.timers) - 1
	if last > 0 {
		pp.timers[0] = pp.timers[last]
	}
	pp.timers[last] = nil
	pp.timers = pp.timers[:last]
	if last > 0 {
		siftdownTimer(pp.timers, 0)
	}
	updateTimer0When(pp)
	atomic.Xadd(&pp.numTimers, -1)
}

// modtimer modifies an existing timer.
// This is called by the netpoll code.
func modtimer(t *timer, when, period int64, f func(interface{}, uintptr), arg interface{}, seq uintptr) {
	if when < 0 {
		when = maxWhen
	}

status := uint32(timerNoStatus)
	wasRemoved := false
	var mp *m
loop:
	for {
		switch status = atomic.Load(&t.status); status {
		case timerWaiting, timerModifiedEarlier, timerModifiedLater:
			// Prevent preemption while the timer is in timerModifying.
			// This could lead to a self-deadlock. See #38070.
			mp = acquirem()
			if atomic.Cas(&t.status, status, timerModifying) {
				break loop
			}
			releasem(mp)
		case timerNoStatus, timerRemoved:
			// Prevent preemption while the timer is in timerModifying.
			// This could lead to a self-deadlock. See #38070.
			mp = acquirem()

// Timer was already run and t is no longer in a heap.
			// Act like addtimer.
			if atomic.Cas(&t.status, status, timerModifying) {
				wasRemoved = true
				break loop
			}
			releasem(mp)
		case timerDeleted:
			// Prevent preemption while the timer is in timerModifying.
			// This could lead to a self-deadlock. See #38070.
			mp = acquirem()
			if atomic.Cas(&t.status, status, timerModifying) {
				atomic.Xadd(&t.pp.ptr().deletedTimers, -1)
				break loop
			}
			releasem(mp)
		case timerRunning, timerRemoving, timerMoving:
			// The timer is being run or moved, by a different P.
			// Wait for it to complete.
			osyield()
		case timerModifying:
			// Multiple simultaneous calls to modtimer.
			// Wait for the other call to complete.
			osyield()
		default:
			badTimer()
		}
	}

t.period = period
	t.f = f
	t.arg = arg
	t.seq = seq

if wasRemoved {
		t.when = when
		pp := getg().m.p.ptr()
		lock(&pp.timersLock)
		doaddtimer(pp, t)
		unlock(&pp.timersLock)
		if !atomic.Cas(&t.status, timerModifying, timerWaiting) {
			badTimer()
		}
		releasem(mp)
		wakeNetPoller(when)
	} else {
		// The timer is in some other P's heap, so we can't change
		// the when field. If we did, the other P's heap would
		// be out of order. So we put the new when value in the
		// nextwhen field, and let the other P set the when field
		// when it is prepared to resort the heap.
		t.nextwhen = when

newStatus := uint32(timerModifiedLater)
		if when < t.when {
			newStatus = timerModifiedEarlier
		}

// Update the adjustTimers field.  Subtract one if we
		// are removing a timerModifiedEarlier, add one if we
		// are adding a timerModifiedEarlier.
		adjust := int32(0)
		if status == timerModifiedEarlier {
			adjust--
		}
		if newStatus == timerModifiedEarlier {
			adjust++
		}
		if adjust != 0 {
			atomic.Xadd(&t.pp.ptr().adjustTimers, adjust)
		}

// Set the new status of the timer.
		if !atomic.Cas(&t.status, timerModifying, newStatus) {
			badTimer()
		}
		releasem(mp)

// If the new status is earlier, wake up the poller.
		if newStatus == timerModifiedEarlier {
			wakeNetPoller(when)
		}
	}
}

// resettimer resets the time when a timer should fire.
// If used for an inactive timer, the timer will become active.
// This should be called instead of addtimer if the timer value has been,
// or may have been, used previously.
func resettimer(t *timer, when int64) {
	modtimer(t, when, t.period, t.f, t.arg, t.seq)
}

// cleantimers cleans up the head of the timer queue. This speeds up
// programs that create and delete timers; leaving them in the heap
// slows down addtimer. Reports whether no timer problems were found.
// The caller must have locked the timers for pp.
func cleantimers(pp *p) {
	for {
		if len(pp.timers) == 0 {
			return
		}
		t := pp.timers[0]
		if t.pp.ptr() != pp {
			throw("cleantimers: bad p")
		}
		switch s := atomic.Load(&t.status); s {
		case timerDeleted:
			if !atomic.Cas(&t.status, s, timerRemoving) {
				continue
			}
			dodeltimer0(pp)
			if !atomic.Cas(&t.status, timerRemoving, timerRemoved) {
				badTimer()
			}
			atomic.Xadd(&pp.deletedTimers, -1)
		case timerModifiedEarlier, timerModifiedLater:
			if !atomic.Cas(&t.status, s, timerMoving) {
				continue
			}
			// Now we can change the when field.
			t.when = t.nextwhen
			// Move t to the right position.
			dodeltimer0(pp)
			doaddtimer(pp, t)
			if s == timerModifiedEarlier {
				atomic.Xadd(&pp.adjustTimers, -1)
			}
			if !atomic.Cas(&t.status, timerMoving, timerWaiting) {
				badTimer()
			}
		default:
			// Head of timers does not need adjustment.
			return
		}
	}
}

// moveTimers moves a slice of timers to pp. The slice has been taken
// from a different P.
// This is currently called when the world is stopped, but the caller
// is expected to have locked the timers for pp.
func moveTimers(pp *p, timers []*timer) {
	for _, t := range timers {
	loop:
		for {
			switch s := atomic.Load(&t.status); s {
			case timerWaiting:
				t.pp = 0
				doaddtimer(pp, t)
				break loop
			case timerModifiedEarlier, timerModifiedLater:
				if !atomic.Cas(&t.status, s, timerMoving) {
					continue
				}
				t.when = t.nextwhen
				t.pp = 0
				doaddtimer(pp, t)
				if !atomic.Cas(&t.status, timerMoving, timerWaiting) {
					badTimer()
				}
				break loop
			case timerDeleted:
				if !atomic.Cas(&t.status, s, timerRemoved) {
					continue
				}
				t.pp = 0
				// We no longer need this timer in the heap.
				break loop
			case timerModifying:
				// Loop until the modification is complete.
				osyield()
			case timerNoStatus, timerRemoved:
				// We should not see these status values in a timers heap.
				badTimer()
			case timerRunning, timerRemoving, timerMoving:
				// Some other P thinks it owns this timer,
				// which should not happen.
				badTimer()
			default:
				badTimer()
			}
		}
	}
}

// adjusttimers looks through the timers in the current P's heap for
// any timers that have been modified to run earlier, and puts them in
// the correct place in the heap. While looking for those timers,
// it also moves timers that have been modified to run later,
// and removes deleted timers. The caller must have locked the timers for pp.
func adjusttimers(pp *p) {
	if len(pp.timers) == 0 {
		return
	}
	if atomic.Load(&pp.adjustTimers) == 0 {
		if verifyTimers {
			verifyTimerHeap(pp)
		}
		return
	}
	var moved []*timer
loop:
	for i := 0; i < len(pp.timers); i++ {
		t := pp.timers[i]
		if t.pp.ptr() != pp {
			throw("adjusttimers: bad p")
		}
		switch s := atomic.Load(&t.status); s {
		case timerDeleted:
			if atomic.Cas(&t.status, s, timerRemoving) {
				dodeltimer(pp, i)
				if !atomic.Cas(&t.status, timerRemoving, timerRemoved) {
					badTimer()
				}
				atomic.Xadd(&pp.deletedTimers, -1)
				// Look at this heap position again.
				i--
			}
		case timerModifiedEarlier, timerModifiedLater:
			if atomic.Cas(&t.status, s, timerMoving) {
				// Now we can change the when field.
				t.when = t.nextwhen
				// Take t off the heap, and hold onto it.
				// We don't add it back yet because the
				// heap manipulation could cause our
				// loop to skip some other timer.
				dodeltimer(pp, i)
				moved = append(moved, t)
				if s == timerModifiedEarlier {
					if n := atomic.Xadd(&pp.adjustTimers, -1); int32(n) <= 0 {
						break loop
					}
				}
				// Look at this heap position again.
				i--
			}
		case timerNoStatus, timerRunning, timerRemoving, timerRemoved, timerMoving:
			badTimer()
		case timerWaiting:
			// OK, nothing to do.
		case timerModifying:
			// Check again after modification is complete.
			osyield()
			i--
		default:
			badTimer()
		}
	}

if len(moved) > 0 {
		addAdjustedTimers(pp, moved)
	}

if verifyTimers {
		verifyTimerHeap(pp)
	}
}

// addAdjustedTimers adds any timers we adjusted in adjusttimers
// back to the timer heap.
func addAdjustedTimers(pp *p, moved []*timer) {
	for _, t := range moved {
		doaddtimer(pp, t)
		if !atomic.Cas(&t.status, timerMoving, timerWaiting) {
			badTimer()
		}
	}
}

// nobarrierWakeTime looks at P's timers and returns the time when we
// should wake up the netpoller. It returns 0 if there are no timers.
// This function is invoked when dropping a P, and must run without
// any write barriers. Therefore, if there are any timers that needs
// to be moved earlier, it conservatively returns the current time.
// The netpoller M will wake up and adjust timers before sleeping again.
//go:nowritebarrierrec
func nobarrierWakeTime(pp *p) int64 {
	if atomic.Load(&pp.adjustTimers) > 0 {
		return nanotime()
	} else {
		return int64(atomic.Load64(&pp.timer0When))
	}
}

// runtimer examines the first timer in timers. If it is ready based on now,
// it runs the timer and removes or updates it.
// Returns 0 if it ran a timer, -1 if there are no more timers, or the time
// when the first timer should run.
// The caller must have locked the timers for pp.
// If a timer is run, this will temporarily unlock the timers.
//go:systemstack
func runtimer(pp *p, now int64) int64 {
	for {
		t := pp.timers[0]
		if t.pp.ptr() != pp {
			throw("runtimer: bad p")
		}
		switch s := atomic.Load(&t.status); s {
		case timerWaiting:
			if t.when > now {
				// Not ready to run.
				return t.when
			}

if !atomic.Cas(&t.status, s, timerRunning) {
				continue
			}
			// Note that runOneTimer may temporarily unlock
			// pp.timersLock.
			runOneTimer(pp, t, now)
			return 0

case timerDeleted:
			if !atomic.Cas(&t.status, s, timerRemoving) {
				continue
			}
			dodeltimer0(pp)
			if !atomic.Cas(&t.status, timerRemoving, timerRemoved) {
				badTimer()
			}
			atomic.Xadd(&pp.deletedTimers, -1)
			if len(pp.timers) == 0 {
				return -1
			}

case timerModifiedEarlier, timerModifiedLater:
			if !atomic.Cas(&t.status, s, timerMoving) {
				continue
			}
			t.when = t.nextwhen
			dodeltimer0(pp)
			doaddtimer(pp, t)
			if s == timerModifiedEarlier {
				atomic.Xadd(&pp.adjustTimers, -1)
			}
			if !atomic.Cas(&t.status, timerMoving, timerWaiting) {
				badTimer()
			}

case timerModifying:
			// Wait for modification to complete.
			osyield()

case timerNoStatus, timerRemoved:
			// Should not see a new or inactive timer on the heap.
			badTimer()
		case timerRunning, timerRemoving, timerMoving:
			// These should only be set when timers are locked,
			// and we didn't do it.
			badTimer()
		default:
			badTimer()
		}
	}
}

// runOneTimer runs a single timer.
// The caller must have locked the timers for pp.
// This will temporarily unlock the timers while running the timer function.
//go:systemstack
func runOneTimer(pp *p, t *timer, now int64) {
	if raceenabled {
		ppcur := getg().m.p.ptr()
		if ppcur.timerRaceCtx == 0 {
			ppcur.timerRaceCtx = racegostart(funcPC(runtimer) + sys.PCQuantum)
		}
		raceacquirectx(ppcur.timerRaceCtx, unsafe.Pointer(t))
	}

f := t.f
	arg := t.arg
	seq := t.seq

if t.period > 0 {
		// Leave in heap but adjust next time to fire.
		delta := t.when - now
		t.when += t.period * (1 + -delta/t.period)
		siftdownTimer(pp.timers, 0)
		if !atomic.Cas(&t.status, timerRunning, timerWaiting) {
			badTimer()
		}
		updateTimer0When(pp)
	} else {
		// Remove from heap.
		dodeltimer0(pp)
		if !atomic.Cas(&t.status, timerRunning, timerNoStatus) {
			badTimer()
		}
	}

if raceenabled {
		// Temporarily use the current P's racectx for g0.
		gp := getg()
		if gp.racectx != 0 {
			throw("runOneTimer: unexpected racectx")
		}
		gp.racectx = gp.m.p.ptr().timerRaceCtx
	}

unlock(&pp.timersLock)

f(arg, seq)

lock(&pp.timersLock)

if raceenabled {
		gp := getg()
		gp.racectx = 0
	}
}

// clearDeletedTimers removes all deleted timers from the P's timer heap.
// This is used to avoid clogging up the heap if the program
// starts a lot of long-running timers and then stops them.
// For example, this can happen via context.WithTimeout.
//
// This is the only function that walks through the entire timer heap,
// other than moveTimers which only runs when the world is stopped.
//
// The caller must have locked the timers for pp.
func clearDeletedTimers(pp *p) {
	cdel := int32(0)
	cearlier := int32(0)
	to := 0
	changedHeap := false
	timers := pp.timers
nextTimer:
	for _, t := range timers {
		for {
			switch s := atomic.Load(&t.status); s {
			case timerWaiting:
				if changedHeap {
					timers[to] = t
					siftupTimer(timers, to)
				}
				to++
				continue nextTimer
			case timerModifiedEarlier, timerModifiedLater:
				if atomic.Cas(&t.status, s, timerMoving) {
					t.when = t.nextwhen
					timers[to] = t
					siftupTimer(timers, to)
					to++
					changedHeap = true
					if !atomic.Cas(&t.status, timerMoving, timerWaiting) {
						badTimer()
					}
					if s == timerModifiedEarlier {
						cearlier++
					}
					continue nextTimer
				}
			case timerDeleted:
				if atomic.Cas(&t.status, s, timerRemoving) {
					t.pp = 0
					cdel++
					if !atomic.Cas(&t.status, timerRemoving, timerRemoved) {
						badTimer()
					}
					changedHeap = true
					continue nextTimer
				}
			case timerModifying:
				// Loop until modification complete.
				osyield()
			case timerNoStatus, timerRemoved:
				// We should not see these status values in a timer heap.
				badTimer()
			case timerRunning, timerRemoving, timerMoving:
				// Some other P thinks it owns this timer,
				// which should not happen.
				badTimer()
			default:
				badTimer()
			}
		}
	}

// Set remaining slots in timers slice to nil,
	// so that the timer values can be garbage collected.
	for i := to; i < len(timers); i++ {
		timers[i] = nil
	}

atomic.Xadd(&pp.deletedTimers, -cdel)
	atomic.Xadd(&pp.numTimers, -cdel)
	atomic.Xadd(&pp.adjustTimers, -cearlier)

timers = timers[:to]
	pp.timers = timers
	updateTimer0When(pp)

if verifyTimers {
		verifyTimerHeap(pp)
	}
}

// verifyTimerHeap verifies that the timer heap is in a valid state.
// This is only for debugging, and is only called if verifyTimers is true.
// The caller must have locked the timers.
func verifyTimerHeap(pp *p) {
	for i, t := range pp.timers {
		if i == 0 {
			// First timer has no parent.
			continue
		}

// The heap is 4-ary. See siftupTimer and siftdownTimer.
		p := (i - 1) / 4
		if t.when < pp.timers[p].when {
			print("bad timer heap at ", i, ": ", p, ": ", pp.timers[p].when, ", ", i, ": ", t.when, "\n")
			throw("bad timer heap")
		}
	}
	if numTimers := int(atomic.Load(&pp.numTimers)); len(pp.timers) != numTimers {
		println("timer heap len", len(pp.timers), "!= numTimers", numTimers)
		throw("bad timer heap len")
	}
}

// updateTimer0When sets the P's timer0When field.
// The caller must have locked the timers for pp.
func updateTimer0When(pp *p) {
	if len(pp.timers) == 0 {
		atomic.Store64(&pp.timer0When, 0)
	} else {
		atomic.Store64(&pp.timer0When, uint64(pp.timers[0].when))
	}
}

// timeSleepUntil returns the time when the next timer should fire,
// and the P that holds the timer heap that that timer is on.
// This is only called by sysmon and checkdead.
func timeSleepUntil() (int64, *p) {
	next := int64(maxWhen)
	var pret *p

// Prevent allp slice changes. This is like retake.
	lock(&allpLock)
	for _, pp := range allp {
		if pp == nil {
			// This can happen if procresize has grown
			// allp but not yet created new Ps.
			continue
		}

c := atomic.Load(&pp.adjustTimers)
		if c == 0 {
			w := int64(atomic.Load64(&pp.timer0When))
			if w != 0 && w < next {
				next = w
				pret = pp
			}
			continue
		}

lock(&pp.timersLock)
		for _, t := range pp.timers {
			switch s := atomic.Load(&t.status); s {
			case timerWaiting:
				if t.when < next {
					next = t.when
				}
			case timerModifiedEarlier, timerModifiedLater:
				if t.nextwhen < next {
					next = t.nextwhen
				}
				if s == timerModifiedEarlier {
					c--
				}
			}
			// The timers are sorted, so we only have to check
			// the first timer for each P, unless there are
			// some timerModifiedEarlier timers. The number
			// of timerModifiedEarlier timers is in the adjustTimers
			// field, used to initialize c, above.
			//
			// We don't worry about cases like timerModifying.
			// New timers can show up at any time,
			// so this function is necessarily imprecise.
			// Do a signed check here since we aren't
			// synchronizing the read of pp.adjustTimers
			// with the check of a timer status.
			if int32(c) <= 0 {
				break
			}
		}
		unlock(&pp.timersLock)
	}
	unlock(&allpLock)

return next, pret
}

// Heap maintenance algorithms.
// These algorithms check for slice index errors manually.
// Slice index error can happen if the program is using racy
// access to timers. We don't want to panic here, because
// it will cause the program to crash with a mysterious
// "panic holding locks" message. Instead, we panic while not
// holding a lock.

func siftupTimer(t []*timer, i int) {
	if i >= len(t) {
		badTimer()
	}
	when := t[i].when
	tmp := t[i]
	for i > 0 {
		p := (i - 1) / 4 // parent
		if when >= t[p].when {
			break
		}
		t[i] = t[p]
		i = p
	}
	if tmp != t[i] {
		t[i] = tmp
	}
}

func siftdownTimer(t []*timer, i int) {
	n := len(t)
	if i >= n {
		badTimer()
	}
	when := t[i].when
	tmp := t[i]
	for {
		c := i*4 + 1 // left child
		c3 := c + 2  // mid child
		if c >= n {
			break
		}
		w := t[c].when
		if c+1 < n && t[c+1].when < w {
			w = t[c+1].when
			c++
		}
		if c3 < n {
			w3 := t[c3].when
			if c3+1 < n && t[c3+1].when < w3 {
				w3 = t[c3+1].when
				c3++
			}
			if w3 < w {
				w = w3
				c = c3
			}
		}
		if w >= when {
			break
		}
		t[i] = t[c]
		i = c
	}
	if tmp != t[i] {
		t[i] = tmp
	}
}

// badTimer is called if the timer data structures have been corrupted,
// presumably due to racy use by the program. We panic here rather than
// panicing due to invalid slice access while holding locks.
// See issue #25686.
func badTimer() {
	throw("timer data corruption")
}

${this.title}

Code Editor : time.go