(req *request)
| 169 | } |
| 170 | |
| 171 | func (l *loader) request(req *request) { |
| 172 | err := l.mutate(req) |
| 173 | if err == nil { |
| 174 | atomic.AddUint64(&l.nquads, uint64(len(req.Set))) |
| 175 | atomic.AddUint64(&l.txns, 1) |
| 176 | l.deregister(req) |
| 177 | return |
| 178 | } |
| 179 | handleError(err, false) |
| 180 | atomic.AddUint64(&l.aborts, 1) |
| 181 | l.retryRequestsWg.Add(1) |
| 182 | go l.infinitelyRetry(req) |
| 183 | } |
| 184 | |
| 185 | func getTypeVal(val *api.Value) (types.Val, error) { |
| 186 | p := dql.TypeValFrom(val) |
no test coverage detected