def "exceed retry count of #retryCount throws last exception"() {
        given:
        def closure = Mock(Closure)

        when:
        RetryUtil.retry(retryCount, closure)

        then:
        def exception = thrown(Exception)
        exception.message == "Exception for retry #${retryCount - 1}"
        interaction {
            retryCount.times { retryIndex ->
                1 * closure.call() >> {

        def retryCount = 0

        when:
        httpResponse.statusCode = 500
        storage.objects().list("test").executeUnparsed()

        then:
        4 * credential.intercept(*_)
        3 * credential.handleResponse(*_) >> { args ->
            retryCount++
            if (retryCount > 2) {
                httpResponse.statusCode = 200

    private RetryUtil() {}

    static int retry(int retries = 3, int waitMsBetweenRetries = 0, Closure closure) {
        int retryCount = 0
        Throwable lastException = null

        while (retryCount++ < retries) {
            try {
                closure.call()
                return retryCount
            } catch (Throwable e) {
                lastException = e
                Thread.sleep(waitMsBetweenRetries)

					log.Errorf(err.Error())
					retryCount++
					// Max retry 5 times
					if retryCount > 4 {
						a.abortCh <- errAbort
						log.Warnf("Graceful termination logic ended prematurely, error while obtaining downstream_cx_active stat (Max retry %d exceeded)", retryCount)
						break graceful_loop
					}
					log.Warnf("Retrying (%d attempt) to obtain active connections...", retryCount)
					continue graceful_loop
				}

                if (retryCount > maxRetryCount) {
                    throw e;
                }
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to invoke actionGet. count:{}", retryCount, e);
                }

                ThreadUtil.sleep(RandomUtils.nextLong(retryInterval + retryCount * 1000L, retryInterval + retryCount * 1000L * 2L));
                retryCount++;

			Host: addr,
		}

		retryCount := g.retryCount
		for i := 0; i < retryCount; i++ {
			g.errs[index].Err = nil
			if err := f(); err != nil {
				g.errs[index].Err = err

				if contextCanceled(ctx) {
					// context already canceled no retries.
					retryCount = 0
				}

				// Last iteration log the error.
				if i == retryCount-1 {

	defer q.queue.Done(key)

	err := q.workFn(key)
	if err != nil {
		retryCount := q.queue.NumRequeues(key) + 1
		if retryCount < q.maxAttempts {
			q.log.Errorf("error handling %v, retrying (retry count: %d): %v", formatKey(key), retryCount, err)
			q.queue.AddRateLimited(key)
			// Return early, so we do not call Forget(), allowing the rate limiting to backoff
			return true

// MRFReplicateEntry mrf entry to save to disk
type MRFReplicateEntry struct {
	Bucket     string `json:"bucket" msg:"b"`
	Object     string `json:"object" msg:"o"`
	versionID  string `json:"-"`
	RetryCount int    `json:"retryCount" msg:"rc"`
	sz         int64  `json:"-"`
}

// MRFReplicateEntries has the map of MRF entries to save to disk
type MRFReplicateEntries struct {

						if err != nil {
							err = msgp.WrapError(err, "Entries", za0001, "Object")
							return
						}
					case "rc":
						za0002.RetryCount, err = dc.ReadInt()
						if err != nil {
							err = msgp.WrapError(err, "Entries", za0001, "RetryCount")
							return
						}
					default:
						err = dc.Skip()
						if err != nil {
							err = msgp.WrapError(err, "Entries", za0001)
							return

        }

        @SuppressWarnings("ThreadPriorityCheck")
        private int writeWithNonBlockingRetry() throws IOException {
            int count = 0;
            int retryCount = 0;
            while (count == 0 && retryCount++ < RETRIES_WHEN_BUFFER_FULL) {
                count = socket.write(buffer);
                if (count < 0) {
                    throw new EOFException();