h.BytesDone = h.ResumeBytesDone
	h.BytesFailed = h.ResumeBytesFailed
	h.BytesSkipped = h.ResumeBytesSkipped
}

// bucketDone should be called when a bucket is done healing.
// Adds the bucket to the list of healed buckets and updates resume numbers.
func (h *healingTracker) bucketDone(bucket string) {
	h.mu.Lock()
	defer h.mu.Unlock()

	h.ResumeItemsHealed = h.ItemsHealed
	h.ResumeItemsFailed = h.ItemsFailed

		return true
	}
	return false
}

func (p poolMeta) isBucketDecommissioned(idx int, bucket string) bool {
	return p.Pools[idx].Decommission.isBucketDecommissioned(bucket)
}

func (p *poolMeta) BucketDone(idx int, bucket decomBucketInfo) bool {
	if p.Pools[idx].Decommission == nil {
		// Decommission not in progress.
		return false
	}
	return p.Pools[idx].Decommission.bucketPop(bucket.String())
}

			continue
		}

		select {
		// If context is canceled don't mark as done...
		case <-ctx.Done():
			return ctx.Err()
		default:
			tracker.bucketDone(bucket)
			healingLogIf(ctx, tracker.update(ctx))
		}
	}
	if retErr != nil {
		return retErr
	}

	// Last sanity check
	if len(tracker.QueuedBuckets) > 0 {

        }
        break;
      }
      prevBucketNode = bucketNode;
    }

    int valueBucket = node.valueHash & mask;
    prevBucketNode = null;
    for (Node<K, V> bucketNode = hashTableVToK[valueBucket];
        true;
        bucketNode = bucketNode.nextInVToKBucket) {
      if (bucketNode == node) {
        if (prevBucketNode == null) {