()
| 239 | } |
| 240 | |
| 241 | func (m *XidMap) dbWriter() { |
| 242 | defer m.wg.Done() |
| 243 | for buf := range m.kvChan { |
| 244 | for _, kv := range buf { |
| 245 | x.Panic(m.writer.Set(kv.key, kv.value)) |
| 246 | } |
| 247 | } |
| 248 | } |
| 249 | |
| 250 | // AssignUid creates new or looks up existing XID to UID mappings. It also returns if |
| 251 | // UID was created. |