allocators.go

     1  // Copyright 2022 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 main
     6  
     7  // TODO: should we share backing storage for similarly-shaped types?
     8  // e.g. []*Value and []*Block, or even []int32 and []bool.
     9  
    10  import (
    11  	"bytes"
    12  	"fmt"
    13  	"go/format"
    14  	"io"
    15  	"log"
    16  	"os"
    17  )
    18  
    19  type allocator struct {
    20  	name     string // name for alloc/free functions
    21  	typ      string // the type they return/accept
    22  	mak      string // code to make a new object (takes power-of-2 size as fmt arg)
    23  	capacity string // code to calculate the capacity of an object. Should always report a power of 2.
    24  	resize   string // code to shrink to sub-power-of-two size (takes size as fmt arg)
    25  	clear    string // code for clearing object before putting it on the free list
    26  	minLog   int    // log_2 of minimum allocation size
    27  	maxLog   int    // log_2 of maximum allocation size
    28  }
    29  
    30  type derived struct {
    31  	name string // name for alloc/free functions
    32  	typ  string // the type they return/accept
    33  	base string // underlying allocator
    34  }
    35  
    36  func genAllocators() {
    37  	allocators := []allocator{
    38  		{
    39  			name:     "ValueSlice",
    40  			typ:      "[]*Value",
    41  			capacity: "cap(%s)",
    42  			mak:      "make([]*Value, %s)",
    43  			resize:   "%s[:%s]",
    44  			clear:    "clear(%s)",
    45  			minLog:   5,
    46  			maxLog:   32,
    47  		},
    48  		{
    49  			name:     "LimitSlice",
    50  			typ:      "[]limit", // the limit type is basically [4]uint64.
    51  			capacity: "cap(%s)",
    52  			mak:      "make([]limit, %s)",
    53  			resize:   "%s[:%s]",
    54  			clear:    "clear(%s)",
    55  			minLog:   3,
    56  			maxLog:   30,
    57  		},
    58  		{
    59  			name:     "SparseSet",
    60  			typ:      "*sparseSet",
    61  			capacity: "%s.cap()",
    62  			mak:      "newSparseSet(%s)",
    63  			resize:   "", // larger-sized sparse sets are ok
    64  			clear:    "%s.clear()",
    65  			minLog:   5,
    66  			maxLog:   32,
    67  		},
    68  		{
    69  			name:     "SparseMap",
    70  			typ:      "*sparseMap",
    71  			capacity: "%s.cap()",
    72  			mak:      "newSparseMap(%s)",
    73  			resize:   "", // larger-sized sparse maps are ok
    74  			clear:    "%s.clear()",
    75  			minLog:   5,
    76  			maxLog:   32,
    77  		},
    78  		{
    79  			name:     "SparseMapPos",
    80  			typ:      "*sparseMapPos",
    81  			capacity: "%s.cap()",
    82  			mak:      "newSparseMapPos(%s)",
    83  			resize:   "", // larger-sized sparse maps are ok
    84  			clear:    "%s.clear()",
    85  			minLog:   5,
    86  			maxLog:   32,
    87  		},
    88  	}
    89  	deriveds := []derived{
    90  		{
    91  			name: "BlockSlice",
    92  			typ:  "[]*Block",
    93  			base: "ValueSlice",
    94  		},
    95  		{
    96  			name: "Int64",
    97  			typ:  "[]int64",
    98  			base: "LimitSlice",
    99  		},
   100  		{
   101  			name: "IntSlice",
   102  			typ:  "[]int",
   103  			base: "LimitSlice",
   104  		},
   105  		{
   106  			name: "Int32Slice",
   107  			typ:  "[]int32",
   108  			base: "LimitSlice",
   109  		},
   110  		{
   111  			name: "Int8Slice",
   112  			typ:  "[]int8",
   113  			base: "LimitSlice",
   114  		},
   115  		{
   116  			name: "BoolSlice",
   117  			typ:  "[]bool",
   118  			base: "LimitSlice",
   119  		},
   120  		{
   121  			name: "IDSlice",
   122  			typ:  "[]ID",
   123  			base: "LimitSlice",
   124  		},
   125  		{
   126  			name: "UintSlice",
   127  			typ:  "[]uint",
   128  			base: "LimitSlice",
   129  		},
   130  	}
   131  
   132  	w := new(bytes.Buffer)
   133  	fmt.Fprintf(w, "// Code generated from _gen/allocators.go using 'go generate'; DO NOT EDIT.\n")
   134  	fmt.Fprintln(w)
   135  	fmt.Fprintln(w, "package ssa")
   136  
   137  	fmt.Fprintln(w, "import (")
   138  	fmt.Fprintln(w, "\"internal/unsafeheader\"")
   139  	fmt.Fprintln(w, "\"math/bits\"")
   140  	fmt.Fprintln(w, "\"sync\"")
   141  	fmt.Fprintln(w, "\"unsafe\"")
   142  	fmt.Fprintln(w, ")")
   143  	for _, a := range allocators {
   144  		genAllocator(w, a)
   145  	}
   146  	for _, d := range deriveds {
   147  		for _, base := range allocators {
   148  			if base.name == d.base {
   149  				genDerived(w, d, base)
   150  				break
   151  			}
   152  		}
   153  	}
   154  	// gofmt result
   155  	b := w.Bytes()
   156  	var err error
   157  	b, err = format.Source(b)
   158  	if err != nil {
   159  		fmt.Printf("%s\n", w.Bytes())
   160  		panic(err)
   161  	}
   162  
   163  	if err := os.WriteFile(outFile("allocators.go"), b, 0666); err != nil {
   164  		log.Fatalf("can't write output: %v\n", err)
   165  	}
   166  }
   167  func genAllocator(w io.Writer, a allocator) {
   168  	fmt.Fprintf(w, "var poolFree%s [%d]sync.Pool\n", a.name, a.maxLog-a.minLog)
   169  	fmt.Fprintf(w, "func (c *Cache) alloc%s(n int) %s {\n", a.name, a.typ)
   170  	fmt.Fprintf(w, "var s %s\n", a.typ)
   171  	fmt.Fprintf(w, "n2 := n\n")
   172  	fmt.Fprintf(w, "if n2 < %d { n2 = %d }\n", 1<<a.minLog, 1<<a.minLog)
   173  	fmt.Fprintf(w, "b := bits.Len(uint(n2-1))\n")
   174  	fmt.Fprintf(w, "v := poolFree%s[b-%d].Get()\n", a.name, a.minLog)
   175  	fmt.Fprintf(w, "if v == nil {\n")
   176  	fmt.Fprintf(w, "  s = %s\n", fmt.Sprintf(a.mak, "1<<b"))
   177  	fmt.Fprintf(w, "} else {\n")
   178  	if a.typ[0] == '*' {
   179  		fmt.Fprintf(w, "s = v.(%s)\n", a.typ)
   180  	} else {
   181  		fmt.Fprintf(w, "sp := v.(*%s)\n", a.typ)
   182  		fmt.Fprintf(w, "s = *sp\n")
   183  		fmt.Fprintf(w, "*sp = nil\n")
   184  		fmt.Fprintf(w, "c.hdr%s = append(c.hdr%s, sp)\n", a.name, a.name)
   185  	}
   186  	fmt.Fprintf(w, "}\n")
   187  	if a.resize != "" {
   188  		fmt.Fprintf(w, "s = %s\n", fmt.Sprintf(a.resize, "s", "n"))
   189  	}
   190  	fmt.Fprintf(w, "return s\n")
   191  	fmt.Fprintf(w, "}\n")
   192  	fmt.Fprintf(w, "func (c *Cache) free%s(s %s) {\n", a.name, a.typ)
   193  	fmt.Fprintf(w, "%s\n", fmt.Sprintf(a.clear, "s"))
   194  	fmt.Fprintf(w, "b := bits.Len(uint(%s) - 1)\n", fmt.Sprintf(a.capacity, "s"))
   195  	if a.typ[0] == '*' {
   196  		fmt.Fprintf(w, "poolFree%s[b-%d].Put(s)\n", a.name, a.minLog)
   197  	} else {
   198  		fmt.Fprintf(w, "var sp *%s\n", a.typ)
   199  		fmt.Fprintf(w, "if len(c.hdr%s) == 0 {\n", a.name)
   200  		fmt.Fprintf(w, "  sp = new(%s)\n", a.typ)
   201  		fmt.Fprintf(w, "} else {\n")
   202  		fmt.Fprintf(w, "  sp = c.hdr%s[len(c.hdr%s)-1]\n", a.name, a.name)
   203  		fmt.Fprintf(w, "  c.hdr%s[len(c.hdr%s)-1] = nil\n", a.name, a.name)
   204  		fmt.Fprintf(w, "  c.hdr%s = c.hdr%s[:len(c.hdr%s)-1]\n", a.name, a.name, a.name)
   205  		fmt.Fprintf(w, "}\n")
   206  		fmt.Fprintf(w, "*sp = s\n")
   207  		fmt.Fprintf(w, "poolFree%s[b-%d].Put(sp)\n", a.name, a.minLog)
   208  	}
   209  	fmt.Fprintf(w, "}\n")
   210  }
   211  func genDerived(w io.Writer, d derived, base allocator) {
   212  	fmt.Fprintf(w, "func (c *Cache) alloc%s(n int) %s {\n", d.name, d.typ)
   213  	if d.typ[:2] != "[]" || base.typ[:2] != "[]" {
   214  		panic(fmt.Sprintf("bad derived types: %s %s", d.typ, base.typ))
   215  	}
   216  	fmt.Fprintf(w, "var base %s\n", base.typ[2:])
   217  	fmt.Fprintf(w, "var derived %s\n", d.typ[2:])
   218  	fmt.Fprintf(w, "if unsafe.Sizeof(base)%%unsafe.Sizeof(derived) != 0 { panic(\"bad\") }\n")
   219  	fmt.Fprintf(w, "scale := unsafe.Sizeof(base)/unsafe.Sizeof(derived)\n")
   220  	fmt.Fprintf(w, "b := c.alloc%s(int((uintptr(n)+scale-1)/scale))\n", base.name)
   221  	fmt.Fprintf(w, "s := unsafeheader.Slice {\n")
   222  	fmt.Fprintf(w, "  Data: unsafe.Pointer(&b[0]),\n")
   223  	fmt.Fprintf(w, "  Len: n,\n")
   224  	fmt.Fprintf(w, "  Cap: cap(b)*int(scale),\n")
   225  	fmt.Fprintf(w, "  }\n")
   226  	fmt.Fprintf(w, "return *(*%s)(unsafe.Pointer(&s))\n", d.typ)
   227  	fmt.Fprintf(w, "}\n")
   228  	fmt.Fprintf(w, "func (c *Cache) free%s(s %s) {\n", d.name, d.typ)
   229  	fmt.Fprintf(w, "var base %s\n", base.typ[2:])
   230  	fmt.Fprintf(w, "var derived %s\n", d.typ[2:])
   231  	fmt.Fprintf(w, "scale := unsafe.Sizeof(base)/unsafe.Sizeof(derived)\n")
   232  	fmt.Fprintf(w, "b := unsafeheader.Slice {\n")
   233  	fmt.Fprintf(w, "  Data: unsafe.Pointer(&s[0]),\n")
   234  	fmt.Fprintf(w, "  Len: int((uintptr(len(s))+scale-1)/scale),\n")
   235  	fmt.Fprintf(w, "  Cap: int((uintptr(cap(s))+scale-1)/scale),\n")
   236  	fmt.Fprintf(w, "  }\n")
   237  	fmt.Fprintf(w, "c.free%s(*(*%s)(unsafe.Pointer(&b)))\n", base.name, base.typ)
   238  	fmt.Fprintf(w, "}\n")
   239  }
   240
View as plain text