12345678910111213141516171819202122232425262728293031323334353637 |
- //go:build race
- // +build race
- package decoder
- import (
- "sync"
- "unsafe"
- "github.com/goccy/go-json/internal/runtime"
- )
- var decMu sync.RWMutex
- func CompileToGetDecoder(typ *runtime.Type) (Decoder, error) {
- typeptr := uintptr(unsafe.Pointer(typ))
- if typeptr > typeAddr.MaxTypeAddr {
- return compileToGetDecoderSlowPath(typeptr, typ)
- }
- index := (typeptr - typeAddr.BaseTypeAddr) >> typeAddr.AddrShift
- decMu.RLock()
- if dec := cachedDecoder[index]; dec != nil {
- decMu.RUnlock()
- return dec, nil
- }
- decMu.RUnlock()
- dec, err := compileHead(typ, map[uintptr]Decoder{})
- if err != nil {
- return nil, err
- }
- decMu.Lock()
- cachedDecoder[index] = dec
- decMu.Unlock()
- return dec, nil
- }
|