(typ super.Type)
| 455 | } |
| 456 | |
| 457 | func (d *Decoder) enter(typ super.Type) { |
| 458 | // Even though type decoding is single threaded, workers processing a |
| 459 | // previous batch can be accessing the types map (via LookupType) while |
| 460 | // the single thread is extending it so these accesses are protected |
| 461 | // with the mutex. |
| 462 | d.mu.Lock() |
| 463 | d.types = append(d.types, typ) |
| 464 | d.mu.Unlock() |
| 465 | } |
no outgoing calls
no test coverage detected