canRetryObject returns whether the given error is retriable for the object given by "oid". If the an OID has met its retry limit, then it will not be able to be retried again. If so, canRetryObject returns whether or not that given error "err" is retriable.
(oid string, err error)
| 1043 | // able to be retried again. If so, canRetryObject returns whether or not that |
| 1044 | // given error "err" is retriable. |
| 1045 | func (q *TransferQueue) canRetryObject(oid string, err error) bool { |
| 1046 | if count, ok := q.rc.CanRetry(oid); !ok { |
| 1047 | tracerx.Printf("tq: refusing to retry %q, too many retries (%d)", oid, count) |
| 1048 | return false |
| 1049 | } |
| 1050 | |
| 1051 | return q.canRetry(err) |
| 1052 | } |
| 1053 | |
| 1054 | func (q *TransferQueue) canRetryObjectLater(oid string, err error) (time.Time, bool) { |
| 1055 | if count, ok := q.rc.CanRetry(oid); !ok { |
no test coverage detected