(id string, err error)
| 201 | } |
| 202 | |
| 203 | func (f *FileLocker) Error(id string, err error) { |
| 204 | if err == nil { |
| 205 | return |
| 206 | } |
| 207 | f.Lock() |
| 208 | defer f.Unlock() |
| 209 | if info, ok := f.nodes[id]; ok { |
| 210 | info.Error = err.Error() |
| 211 | logger.Error(fmt.Sprintf("error during asynchronous file processing node=%s: %s", id, err.Error())) |
| 212 | } |
| 213 | } |
| 214 | |
| 215 | func (f *FileLocker) Remove(id string) { |
| 216 | f.Lock() |
no outgoing calls
no test coverage detected