]> Cypherpunks.ru repositories - gostls13.git/blob - src/runtime/malloc.go
[dev.cc] all: merge dev.power64 (7667e41f3ced) into dev.cc
[gostls13.git] / src / runtime / malloc.go
1 // Copyright 2014 The Go Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style
3 // license that can be found in the LICENSE file.
4
5 package runtime
6
7 import "unsafe"
8
9 const (
10         debugMalloc = false
11
12         flagNoScan = _FlagNoScan
13         flagNoZero = _FlagNoZero
14
15         maxTinySize   = _TinySize
16         tinySizeClass = _TinySizeClass
17         maxSmallSize  = _MaxSmallSize
18
19         pageShift = _PageShift
20         pageSize  = _PageSize
21         pageMask  = _PageMask
22
23         bitsPerPointer  = _BitsPerPointer
24         bitsMask        = _BitsMask
25         pointersPerByte = _PointersPerByte
26         maxGCMask       = _MaxGCMask
27         bitsDead        = _BitsDead
28         bitsPointer     = _BitsPointer
29         bitsScalar      = _BitsScalar
30
31         mSpanInUse = _MSpanInUse
32
33         concurrentSweep = _ConcurrentSweep
34 )
35
36 // Page number (address>>pageShift)
37 type pageID uintptr
38
39 // base address for all 0-byte allocations
40 var zerobase uintptr
41
42 // Allocate an object of size bytes.
43 // Small objects are allocated from the per-P cache's free lists.
44 // Large objects (> 32 kB) are allocated straight from the heap.
45 func mallocgc(size uintptr, typ *_type, flags uint32) unsafe.Pointer {
46         if size == 0 {
47                 return unsafe.Pointer(&zerobase)
48         }
49         size0 := size
50
51         if flags&flagNoScan == 0 && typ == nil {
52                 gothrow("malloc missing type")
53         }
54
55         // This function must be atomic wrt GC, but for performance reasons
56         // we don't acquirem/releasem on fast path. The code below does not have
57         // split stack checks, so it can't be preempted by GC.
58         // Functions like roundup/add are inlined. And systemstack/racemalloc are nosplit.
59         // If debugMalloc = true, these assumptions are checked below.
60         if debugMalloc {
61                 mp := acquirem()
62                 if mp.mallocing != 0 {
63                         gothrow("malloc deadlock")
64                 }
65                 mp.mallocing = 1
66                 if mp.curg != nil {
67                         mp.curg.stackguard0 = ^uintptr(0xfff) | 0xbad
68                 }
69         }
70
71         c := gomcache()
72         var s *mspan
73         var x unsafe.Pointer
74         if size <= maxSmallSize {
75                 if flags&flagNoScan != 0 && size < maxTinySize {
76                         // Tiny allocator.
77                         //
78                         // Tiny allocator combines several tiny allocation requests
79                         // into a single memory block. The resulting memory block
80                         // is freed when all subobjects are unreachable. The subobjects
81                         // must be FlagNoScan (don't have pointers), this ensures that
82                         // the amount of potentially wasted memory is bounded.
83                         //
84                         // Size of the memory block used for combining (maxTinySize) is tunable.
85                         // Current setting is 16 bytes, which relates to 2x worst case memory
86                         // wastage (when all but one subobjects are unreachable).
87                         // 8 bytes would result in no wastage at all, but provides less
88                         // opportunities for combining.
89                         // 32 bytes provides more opportunities for combining,
90                         // but can lead to 4x worst case wastage.
91                         // The best case winning is 8x regardless of block size.
92                         //
93                         // Objects obtained from tiny allocator must not be freed explicitly.
94                         // So when an object will be freed explicitly, we ensure that
95                         // its size >= maxTinySize.
96                         //
97                         // SetFinalizer has a special case for objects potentially coming
98                         // from tiny allocator, it such case it allows to set finalizers
99                         // for an inner byte of a memory block.
100                         //
101                         // The main targets of tiny allocator are small strings and
102                         // standalone escaping variables. On a json benchmark
103                         // the allocator reduces number of allocations by ~12% and
104                         // reduces heap size by ~20%.
105                         tinysize := uintptr(c.tinysize)
106                         if size <= tinysize {
107                                 tiny := unsafe.Pointer(c.tiny)
108                                 // Align tiny pointer for required (conservative) alignment.
109                                 if size&7 == 0 {
110                                         tiny = roundup(tiny, 8)
111                                 } else if size&3 == 0 {
112                                         tiny = roundup(tiny, 4)
113                                 } else if size&1 == 0 {
114                                         tiny = roundup(tiny, 2)
115                                 }
116                                 size1 := size + (uintptr(tiny) - uintptr(unsafe.Pointer(c.tiny)))
117                                 if size1 <= tinysize {
118                                         // The object fits into existing tiny block.
119                                         x = tiny
120                                         c.tiny = (*byte)(add(x, size))
121                                         c.tinysize -= uintptr(size1)
122                                         c.local_tinyallocs++
123                                         if debugMalloc {
124                                                 mp := acquirem()
125                                                 if mp.mallocing == 0 {
126                                                         gothrow("bad malloc")
127                                                 }
128                                                 mp.mallocing = 0
129                                                 if mp.curg != nil {
130                                                         mp.curg.stackguard0 = mp.curg.stack.lo + _StackGuard
131                                                 }
132                                                 // Note: one releasem for the acquirem just above.
133                                                 // The other for the acquirem at start of malloc.
134                                                 releasem(mp)
135                                                 releasem(mp)
136                                         }
137                                         return x
138                                 }
139                         }
140                         // Allocate a new maxTinySize block.
141                         s = c.alloc[tinySizeClass]
142                         v := s.freelist
143                         if v == nil {
144                                 systemstack(func() {
145                                         mCache_Refill(c, tinySizeClass)
146                                 })
147                                 s = c.alloc[tinySizeClass]
148                                 v = s.freelist
149                         }
150                         s.freelist = v.next
151                         s.ref++
152                         //TODO: prefetch v.next
153                         x = unsafe.Pointer(v)
154                         (*[2]uint64)(x)[0] = 0
155                         (*[2]uint64)(x)[1] = 0
156                         // See if we need to replace the existing tiny block with the new one
157                         // based on amount of remaining free space.
158                         if maxTinySize-size > tinysize {
159                                 c.tiny = (*byte)(add(x, size))
160                                 c.tinysize = uintptr(maxTinySize - size)
161                         }
162                         size = maxTinySize
163                 } else {
164                         var sizeclass int8
165                         if size <= 1024-8 {
166                                 sizeclass = size_to_class8[(size+7)>>3]
167                         } else {
168                                 sizeclass = size_to_class128[(size-1024+127)>>7]
169                         }
170                         size = uintptr(class_to_size[sizeclass])
171                         s = c.alloc[sizeclass]
172                         v := s.freelist
173                         if v == nil {
174                                 systemstack(func() {
175                                         mCache_Refill(c, int32(sizeclass))
176                                 })
177                                 s = c.alloc[sizeclass]
178                                 v = s.freelist
179                         }
180                         s.freelist = v.next
181                         s.ref++
182                         //TODO: prefetch
183                         x = unsafe.Pointer(v)
184                         if flags&flagNoZero == 0 {
185                                 v.next = nil
186                                 if size > 2*ptrSize && ((*[2]uintptr)(x))[1] != 0 {
187                                         memclr(unsafe.Pointer(v), size)
188                                 }
189                         }
190                 }
191                 c.local_cachealloc += intptr(size)
192         } else {
193                 var s *mspan
194                 systemstack(func() {
195                         s = largeAlloc(size, uint32(flags))
196                 })
197                 x = unsafe.Pointer(uintptr(s.start << pageShift))
198                 size = uintptr(s.elemsize)
199         }
200
201         if flags&flagNoScan != 0 {
202                 // All objects are pre-marked as noscan.
203                 goto marked
204         }
205
206         // If allocating a defer+arg block, now that we've picked a malloc size
207         // large enough to hold everything, cut the "asked for" size down to
208         // just the defer header, so that the GC bitmap will record the arg block
209         // as containing nothing at all (as if it were unused space at the end of
210         // a malloc block caused by size rounding).
211         // The defer arg areas are scanned as part of scanstack.
212         if typ == deferType {
213                 size0 = unsafe.Sizeof(_defer{})
214         }
215
216         // From here till marked label marking the object as allocated
217         // and storing type info in the GC bitmap.
218         {
219                 arena_start := uintptr(unsafe.Pointer(mheap_.arena_start))
220                 off := (uintptr(x) - arena_start) / ptrSize
221                 xbits := (*uint8)(unsafe.Pointer(arena_start - off/wordsPerBitmapByte - 1))
222                 shift := (off % wordsPerBitmapByte) * gcBits
223                 if debugMalloc && ((*xbits>>shift)&(bitMask|bitPtrMask)) != bitBoundary {
224                         println("runtime: bits =", (*xbits>>shift)&(bitMask|bitPtrMask))
225                         gothrow("bad bits in markallocated")
226                 }
227
228                 var ti, te uintptr
229                 var ptrmask *uint8
230                 if size == ptrSize {
231                         // It's one word and it has pointers, it must be a pointer.
232                         *xbits |= (bitsPointer << 2) << shift
233                         goto marked
234                 }
235                 if typ.kind&kindGCProg != 0 {
236                         nptr := (uintptr(typ.size) + ptrSize - 1) / ptrSize
237                         masksize := nptr
238                         if masksize%2 != 0 {
239                                 masksize *= 2 // repeated
240                         }
241                         masksize = masksize * pointersPerByte / 8 // 4 bits per word
242                         masksize++                                // unroll flag in the beginning
243                         if masksize > maxGCMask && typ.gc[1] != 0 {
244                                 // If the mask is too large, unroll the program directly
245                                 // into the GC bitmap. It's 7 times slower than copying
246                                 // from the pre-unrolled mask, but saves 1/16 of type size
247                                 // memory for the mask.
248                                 systemstack(func() {
249                                         unrollgcproginplace_m(x, typ, size, size0)
250                                 })
251                                 goto marked
252                         }
253                         ptrmask = (*uint8)(unsafe.Pointer(uintptr(typ.gc[0])))
254                         // Check whether the program is already unrolled
255                         // by checking if the unroll flag byte is set
256                         maskword := uintptr(atomicloadp(unsafe.Pointer(ptrmask)))
257                         if *(*uint8)(unsafe.Pointer(&maskword)) == 0 {
258                                 systemstack(func() {
259                                         unrollgcprog_m(typ)
260                                 })
261                         }
262                         ptrmask = (*uint8)(add(unsafe.Pointer(ptrmask), 1)) // skip the unroll flag byte
263                 } else {
264                         ptrmask = (*uint8)(unsafe.Pointer(typ.gc[0])) // pointer to unrolled mask
265                 }
266                 if size == 2*ptrSize {
267                         *xbits = *ptrmask | bitBoundary
268                         goto marked
269                 }
270                 te = uintptr(typ.size) / ptrSize
271                 // If the type occupies odd number of words, its mask is repeated.
272                 if te%2 == 0 {
273                         te /= 2
274                 }
275                 // Copy pointer bitmask into the bitmap.
276                 for i := uintptr(0); i < size0; i += 2 * ptrSize {
277                         v := *(*uint8)(add(unsafe.Pointer(ptrmask), ti))
278                         ti++
279                         if ti == te {
280                                 ti = 0
281                         }
282                         if i == 0 {
283                                 v |= bitBoundary
284                         }
285                         if i+ptrSize == size0 {
286                                 v &^= uint8(bitPtrMask << 4)
287                         }
288
289                         *xbits = v
290                         xbits = (*byte)(add(unsafe.Pointer(xbits), ^uintptr(0)))
291                 }
292                 if size0%(2*ptrSize) == 0 && size0 < size {
293                         // Mark the word after last object's word as bitsDead.
294                         *xbits = bitsDead << 2
295                 }
296         }
297 marked:
298         if raceenabled {
299                 racemalloc(x, size)
300         }
301
302         if debugMalloc {
303                 mp := acquirem()
304                 if mp.mallocing == 0 {
305                         gothrow("bad malloc")
306                 }
307                 mp.mallocing = 0
308                 if mp.curg != nil {
309                         mp.curg.stackguard0 = mp.curg.stack.lo + _StackGuard
310                 }
311                 // Note: one releasem for the acquirem just above.
312                 // The other for the acquirem at start of malloc.
313                 releasem(mp)
314                 releasem(mp)
315         }
316
317         if debug.allocfreetrace != 0 {
318                 tracealloc(x, size, typ)
319         }
320
321         if rate := MemProfileRate; rate > 0 {
322                 if size < uintptr(rate) && int32(size) < c.next_sample {
323                         c.next_sample -= int32(size)
324                 } else {
325                         mp := acquirem()
326                         profilealloc(mp, x, size)
327                         releasem(mp)
328                 }
329         }
330
331         if memstats.heap_alloc >= memstats.next_gc {
332                 gogc(0)
333         }
334
335         return x
336 }
337
338 // implementation of new builtin
339 func newobject(typ *_type) unsafe.Pointer {
340         flags := uint32(0)
341         if typ.kind&kindNoPointers != 0 {
342                 flags |= flagNoScan
343         }
344         return mallocgc(uintptr(typ.size), typ, flags)
345 }
346
347 // implementation of make builtin for slices
348 func newarray(typ *_type, n uintptr) unsafe.Pointer {
349         flags := uint32(0)
350         if typ.kind&kindNoPointers != 0 {
351                 flags |= flagNoScan
352         }
353         if int(n) < 0 || (typ.size > 0 && n > _MaxMem/uintptr(typ.size)) {
354                 panic("runtime: allocation size out of range")
355         }
356         return mallocgc(uintptr(typ.size)*n, typ, flags)
357 }
358
359 // rawmem returns a chunk of pointerless memory.  It is
360 // not zeroed.
361 func rawmem(size uintptr) unsafe.Pointer {
362         return mallocgc(size, nil, flagNoScan|flagNoZero)
363 }
364
365 // round size up to next size class
366 func goroundupsize(size uintptr) uintptr {
367         if size < maxSmallSize {
368                 if size <= 1024-8 {
369                         return uintptr(class_to_size[size_to_class8[(size+7)>>3]])
370                 }
371                 return uintptr(class_to_size[size_to_class128[(size-1024+127)>>7]])
372         }
373         if size+pageSize < size {
374                 return size
375         }
376         return (size + pageSize - 1) &^ pageMask
377 }
378
379 func profilealloc(mp *m, x unsafe.Pointer, size uintptr) {
380         c := mp.mcache
381         rate := MemProfileRate
382         if size < uintptr(rate) {
383                 // pick next profile time
384                 // If you change this, also change allocmcache.
385                 if rate > 0x3fffffff { // make 2*rate not overflow
386                         rate = 0x3fffffff
387                 }
388                 next := int32(fastrand1()) % (2 * int32(rate))
389                 // Subtract the "remainder" of the current allocation.
390                 // Otherwise objects that are close in size to sampling rate
391                 // will be under-sampled, because we consistently discard this remainder.
392                 next -= (int32(size) - c.next_sample)
393                 if next < 0 {
394                         next = 0
395                 }
396                 c.next_sample = next
397         }
398
399         mProf_Malloc(x, size)
400 }
401
402 // force = 1 - do GC regardless of current heap usage
403 // force = 2 - go GC and eager sweep
404 func gogc(force int32) {
405         // The gc is turned off (via enablegc) until the bootstrap has completed.
406         // Also, malloc gets called in the guts of a number of libraries that might be
407         // holding locks. To avoid deadlocks during stoptheworld, don't bother
408         // trying to run gc while holding a lock. The next mallocgc without a lock
409         // will do the gc instead.
410         mp := acquirem()
411         if gp := getg(); gp == mp.g0 || mp.locks > 1 || !memstats.enablegc || panicking != 0 || gcpercent < 0 {
412                 releasem(mp)
413                 return
414         }
415         releasem(mp)
416         mp = nil
417
418         semacquire(&worldsema, false)
419
420         if force == 0 && memstats.heap_alloc < memstats.next_gc {
421                 // typically threads which lost the race to grab
422                 // worldsema exit here when gc is done.
423                 semrelease(&worldsema)
424                 return
425         }
426
427         // Ok, we're doing it!  Stop everybody else
428         startTime := nanotime()
429         mp = acquirem()
430         mp.gcing = 1
431         releasem(mp)
432         systemstack(stoptheworld)
433         if mp != acquirem() {
434                 gothrow("gogc: rescheduled")
435         }
436
437         clearpools()
438
439         // Run gc on the g0 stack.  We do this so that the g stack
440         // we're currently running on will no longer change.  Cuts
441         // the root set down a bit (g0 stacks are not scanned, and
442         // we don't need to scan gc's internal state).  We also
443         // need to switch to g0 so we can shrink the stack.
444         n := 1
445         if debug.gctrace > 1 {
446                 n = 2
447         }
448         for i := 0; i < n; i++ {
449                 if i > 0 {
450                         startTime = nanotime()
451                 }
452                 // switch to g0, call gc, then switch back
453                 eagersweep := force >= 2
454                 systemstack(func() {
455                         gc_m(startTime, eagersweep)
456                 })
457         }
458
459         // all done
460         mp.gcing = 0
461         semrelease(&worldsema)
462         systemstack(starttheworld)
463         releasem(mp)
464         mp = nil
465
466         // now that gc is done, kick off finalizer thread if needed
467         if !concurrentSweep {
468                 // give the queued finalizers, if any, a chance to run
469                 Gosched()
470         }
471 }
472
473 // GC runs a garbage collection.
474 func GC() {
475         gogc(2)
476 }
477
478 // linker-provided
479 var noptrdata struct{}
480 var enoptrbss struct{}
481
482 // SetFinalizer sets the finalizer associated with x to f.
483 // When the garbage collector finds an unreachable block
484 // with an associated finalizer, it clears the association and runs
485 // f(x) in a separate goroutine.  This makes x reachable again, but
486 // now without an associated finalizer.  Assuming that SetFinalizer
487 // is not called again, the next time the garbage collector sees
488 // that x is unreachable, it will free x.
489 //
490 // SetFinalizer(x, nil) clears any finalizer associated with x.
491 //
492 // The argument x must be a pointer to an object allocated by
493 // calling new or by taking the address of a composite literal.
494 // The argument f must be a function that takes a single argument
495 // to which x's type can be assigned, and can have arbitrary ignored return
496 // values. If either of these is not true, SetFinalizer aborts the
497 // program.
498 //
499 // Finalizers are run in dependency order: if A points at B, both have
500 // finalizers, and they are otherwise unreachable, only the finalizer
501 // for A runs; once A is freed, the finalizer for B can run.
502 // If a cyclic structure includes a block with a finalizer, that
503 // cycle is not guaranteed to be garbage collected and the finalizer
504 // is not guaranteed to run, because there is no ordering that
505 // respects the dependencies.
506 //
507 // The finalizer for x is scheduled to run at some arbitrary time after
508 // x becomes unreachable.
509 // There is no guarantee that finalizers will run before a program exits,
510 // so typically they are useful only for releasing non-memory resources
511 // associated with an object during a long-running program.
512 // For example, an os.File object could use a finalizer to close the
513 // associated operating system file descriptor when a program discards
514 // an os.File without calling Close, but it would be a mistake
515 // to depend on a finalizer to flush an in-memory I/O buffer such as a
516 // bufio.Writer, because the buffer would not be flushed at program exit.
517 //
518 // It is not guaranteed that a finalizer will run if the size of *x is
519 // zero bytes.
520 //
521 // It is not guaranteed that a finalizer will run for objects allocated
522 // in initializers for package-level variables. Such objects may be
523 // linker-allocated, not heap-allocated.
524 //
525 // A single goroutine runs all finalizers for a program, sequentially.
526 // If a finalizer must run for a long time, it should do so by starting
527 // a new goroutine.
528 func SetFinalizer(obj interface{}, finalizer interface{}) {
529         e := (*eface)(unsafe.Pointer(&obj))
530         etyp := e._type
531         if etyp == nil {
532                 gothrow("runtime.SetFinalizer: first argument is nil")
533         }
534         if etyp.kind&kindMask != kindPtr {
535                 gothrow("runtime.SetFinalizer: first argument is " + *etyp._string + ", not pointer")
536         }
537         ot := (*ptrtype)(unsafe.Pointer(etyp))
538         if ot.elem == nil {
539                 gothrow("nil elem type!")
540         }
541
542         // find the containing object
543         _, base, _ := findObject(e.data)
544
545         if base == nil {
546                 // 0-length objects are okay.
547                 if e.data == unsafe.Pointer(&zerobase) {
548                         return
549                 }
550
551                 // Global initializers might be linker-allocated.
552                 //      var Foo = &Object{}
553                 //      func main() {
554                 //              runtime.SetFinalizer(Foo, nil)
555                 //      }
556                 // The segments are, in order: text, rodata, noptrdata, data, bss, noptrbss.
557                 if uintptr(unsafe.Pointer(&noptrdata)) <= uintptr(e.data) && uintptr(e.data) < uintptr(unsafe.Pointer(&enoptrbss)) {
558                         return
559                 }
560                 gothrow("runtime.SetFinalizer: pointer not in allocated block")
561         }
562
563         if e.data != base {
564                 // As an implementation detail we allow to set finalizers for an inner byte
565                 // of an object if it could come from tiny alloc (see mallocgc for details).
566                 if ot.elem == nil || ot.elem.kind&kindNoPointers == 0 || ot.elem.size >= maxTinySize {
567                         gothrow("runtime.SetFinalizer: pointer not at beginning of allocated block")
568                 }
569         }
570
571         f := (*eface)(unsafe.Pointer(&finalizer))
572         ftyp := f._type
573         if ftyp == nil {
574                 // switch to system stack and remove finalizer
575                 systemstack(func() {
576                         removefinalizer(e.data)
577                 })
578                 return
579         }
580
581         if ftyp.kind&kindMask != kindFunc {
582                 gothrow("runtime.SetFinalizer: second argument is " + *ftyp._string + ", not a function")
583         }
584         ft := (*functype)(unsafe.Pointer(ftyp))
585         ins := *(*[]*_type)(unsafe.Pointer(&ft.in))
586         if ft.dotdotdot || len(ins) != 1 {
587                 gothrow("runtime.SetFinalizer: cannot pass " + *etyp._string + " to finalizer " + *ftyp._string)
588         }
589         fint := ins[0]
590         switch {
591         case fint == etyp:
592                 // ok - same type
593                 goto okarg
594         case fint.kind&kindMask == kindPtr:
595                 if (fint.x == nil || fint.x.name == nil || etyp.x == nil || etyp.x.name == nil) && (*ptrtype)(unsafe.Pointer(fint)).elem == ot.elem {
596                         // ok - not same type, but both pointers,
597                         // one or the other is unnamed, and same element type, so assignable.
598                         goto okarg
599                 }
600         case fint.kind&kindMask == kindInterface:
601                 ityp := (*interfacetype)(unsafe.Pointer(fint))
602                 if len(ityp.mhdr) == 0 {
603                         // ok - satisfies empty interface
604                         goto okarg
605                 }
606                 if _, ok := assertE2I2(ityp, obj); ok {
607                         goto okarg
608                 }
609         }
610         gothrow("runtime.SetFinalizer: cannot pass " + *etyp._string + " to finalizer " + *ftyp._string)
611 okarg:
612         // compute size needed for return parameters
613         nret := uintptr(0)
614         for _, t := range *(*[]*_type)(unsafe.Pointer(&ft.out)) {
615                 nret = round(nret, uintptr(t.align)) + uintptr(t.size)
616         }
617         nret = round(nret, ptrSize)
618
619         // make sure we have a finalizer goroutine
620         createfing()
621
622         systemstack(func() {
623                 if !addfinalizer(e.data, (*funcval)(f.data), nret, fint, ot) {
624                         gothrow("runtime.SetFinalizer: finalizer already set")
625                 }
626         })
627 }
628
629 // round n up to a multiple of a.  a must be a power of 2.
630 func round(n, a uintptr) uintptr {
631         return (n + a - 1) &^ (a - 1)
632 }
633
634 // Look up pointer v in heap.  Return the span containing the object,
635 // the start of the object, and the size of the object.  If the object
636 // does not exist, return nil, nil, 0.
637 func findObject(v unsafe.Pointer) (s *mspan, x unsafe.Pointer, n uintptr) {
638         c := gomcache()
639         c.local_nlookup++
640         if ptrSize == 4 && c.local_nlookup >= 1<<30 {
641                 // purge cache stats to prevent overflow
642                 lock(&mheap_.lock)
643                 purgecachedstats(c)
644                 unlock(&mheap_.lock)
645         }
646
647         // find span
648         arena_start := uintptr(unsafe.Pointer(mheap_.arena_start))
649         arena_used := uintptr(unsafe.Pointer(mheap_.arena_used))
650         if uintptr(v) < arena_start || uintptr(v) >= arena_used {
651                 return
652         }
653         p := uintptr(v) >> pageShift
654         q := p - arena_start>>pageShift
655         s = *(**mspan)(add(unsafe.Pointer(mheap_.spans), q*ptrSize))
656         if s == nil {
657                 return
658         }
659         x = unsafe.Pointer(uintptr(s.start) << pageShift)
660
661         if uintptr(v) < uintptr(x) || uintptr(v) >= uintptr(unsafe.Pointer(s.limit)) || s.state != mSpanInUse {
662                 s = nil
663                 x = nil
664                 return
665         }
666
667         n = uintptr(s.elemsize)
668         if s.sizeclass != 0 {
669                 x = add(x, (uintptr(v)-uintptr(x))/n*n)
670         }
671         return
672 }
673
674 var fingCreate uint32
675
676 func createfing() {
677         // start the finalizer goroutine exactly once
678         if fingCreate == 0 && cas(&fingCreate, 0, 1) {
679                 go runfinq()
680         }
681 }
682
683 // This is the goroutine that runs all of the finalizers
684 func runfinq() {
685         var (
686                 frame    unsafe.Pointer
687                 framecap uintptr
688         )
689
690         for {
691                 lock(&finlock)
692                 fb := finq
693                 finq = nil
694                 if fb == nil {
695                         gp := getg()
696                         fing = gp
697                         fingwait = true
698                         gp.issystem = true
699                         goparkunlock(&finlock, "finalizer wait")
700                         gp.issystem = false
701                         continue
702                 }
703                 unlock(&finlock)
704                 if raceenabled {
705                         racefingo()
706                 }
707                 for fb != nil {
708                         for i := int32(0); i < fb.cnt; i++ {
709                                 f := (*finalizer)(add(unsafe.Pointer(&fb.fin), uintptr(i)*unsafe.Sizeof(finalizer{})))
710
711                                 framesz := unsafe.Sizeof((interface{})(nil)) + uintptr(f.nret)
712                                 if framecap < framesz {
713                                         // The frame does not contain pointers interesting for GC,
714                                         // all not yet finalized objects are stored in finq.
715                                         // If we do not mark it as FlagNoScan,
716                                         // the last finalized object is not collected.
717                                         frame = mallocgc(framesz, nil, flagNoScan)
718                                         framecap = framesz
719                                 }
720
721                                 if f.fint == nil {
722                                         gothrow("missing type in runfinq")
723                                 }
724                                 switch f.fint.kind & kindMask {
725                                 case kindPtr:
726                                         // direct use of pointer
727                                         *(*unsafe.Pointer)(frame) = f.arg
728                                 case kindInterface:
729                                         ityp := (*interfacetype)(unsafe.Pointer(f.fint))
730                                         // set up with empty interface
731                                         (*eface)(frame)._type = &f.ot.typ
732                                         (*eface)(frame).data = f.arg
733                                         if len(ityp.mhdr) != 0 {
734                                                 // convert to interface with methods
735                                                 // this conversion is guaranteed to succeed - we checked in SetFinalizer
736                                                 *(*fInterface)(frame) = assertE2I(ityp, *(*interface{})(frame))
737                                         }
738                                 default:
739                                         gothrow("bad kind in runfinq")
740                                 }
741                                 reflectcall(unsafe.Pointer(f.fn), frame, uint32(framesz), uint32(framesz))
742
743                                 // drop finalizer queue references to finalized object
744                                 f.fn = nil
745                                 f.arg = nil
746                                 f.ot = nil
747                         }
748                         fb.cnt = 0
749                         next := fb.next
750                         lock(&finlock)
751                         fb.next = finc
752                         finc = fb
753                         unlock(&finlock)
754                         fb = next
755                 }
756         }
757 }
758
759 var persistent struct {
760         lock mutex
761         pos  unsafe.Pointer
762         end  unsafe.Pointer
763 }
764
765 // Wrapper around sysAlloc that can allocate small chunks.
766 // There is no associated free operation.
767 // Intended for things like function/type/debug-related persistent data.
768 // If align is 0, uses default align (currently 8).
769 func persistentalloc(size, align uintptr, stat *uint64) unsafe.Pointer {
770         const (
771                 chunk    = 256 << 10
772                 maxBlock = 64 << 10 // VM reservation granularity is 64K on windows
773         )
774
775         if align != 0 {
776                 if align&(align-1) != 0 {
777                         gothrow("persistentalloc: align is not a power of 2")
778                 }
779                 if align > _PageSize {
780                         gothrow("persistentalloc: align is too large")
781                 }
782         } else {
783                 align = 8
784         }
785
786         if size >= maxBlock {
787                 return sysAlloc(size, stat)
788         }
789
790         lock(&persistent.lock)
791         persistent.pos = roundup(persistent.pos, align)
792         if uintptr(persistent.pos)+size > uintptr(persistent.end) {
793                 persistent.pos = sysAlloc(chunk, &memstats.other_sys)
794                 if persistent.pos == nil {
795                         unlock(&persistent.lock)
796                         gothrow("runtime: cannot allocate memory")
797                 }
798                 persistent.end = add(persistent.pos, chunk)
799         }
800         p := persistent.pos
801         persistent.pos = add(persistent.pos, size)
802         unlock(&persistent.lock)
803
804         if stat != &memstats.other_sys {
805                 xadd64(stat, int64(size))
806                 xadd64(&memstats.other_sys, -int64(size))
807         }
808         return p
809 }