Lines Matching refs:attempt
101 this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) {
103 if (closed_ && queue_size < attempt->elements_requested) {
105 // to reset the attempt tuple.
106 if (!attempt->tuples.empty()) {
108 for (int64 i = attempt->tuples.size() - 1; i >= 0; --i) {
111 Status s = GetElementComponent(attempt->tuples[i], j,
112 attempt->context, &element);
114 attempt->context->SetStatus(
127 attempt->tuples.clear();
128 attempt->elements_requested = queue_size;
136 if (attempt->context->status().ok()) {
137 attempt->context->SetStatus(errors::OutOfRange(
140 attempt->elements_requested, ", current size ",
151 DequeueLocked(attempt->context, &tuple);
152 attempt->tuples.push_back(tuple);
154 --attempt->elements_requested;
156 if (attempt->elements_requested == 0) {
157 // Finished. Allocate attempt->tuple and
158 // copy from attempt->tuples to attempt->tuple.
159 attempt->tuple.reserve(num_components());
160 std::vector<Tuple>& tuples = attempt->tuples;
185 attempt->context->SetStatus(attempt->context->allocate_temp(
187 if (!attempt->context->status().ok()) return kComplete;
193 attempt->context->SetStatus(SetElementZero(&element));
194 if (!attempt->context->status().ok()) return kComplete;
200 attempt->tuple.emplace_back(element);
207 attempt->context->SetStatus(CopyElementToLargerSlice(
208 tuples[index][i], &attempt->tuple[i], index));
210 attempt->context->SetStatus(
212 std::move(tuples[index][i]), &attempt->tuple[i],
215 if (!attempt->context->status().ok()) return kComplete;
218 tuple = attempt->tuple;
219 attempt->tuples.clear();
220 attempt->done_callback = [callback, tuple]() {
