Home
last modified time | relevance | path

Searched full:attempt (Results 1 – 25 of 9652) sorted by relevance

12345678910>>...387

/external/pytorch/test/dynamo/
Dtest_structured_trace.py177 {"dynamo_start": {"stack": "STACK"}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0}
178 …id": 0, "describer_id": "ID", "size": 4000000}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0}
179 …view_func": "VIEW_FUNC", "describer_id": "ID"}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0}
180 …criber_id": "ID", "id": 0, "source": "L['a']"}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0}
181 … 1000], "output": [1000, 1000]}}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0, "has_payload…
182 {"aot_forward_graph": {}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0, "has_payload": "HASH"}
183 …runnable", "encoding": "string"}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0, "has_payload…
184 {"inductor_post_grad_graph": {}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0, "has_payload":…
185 {"inductor_output_code": {"filename": "FILENAME"}, "frame_id": 0, "frame_compile_id": 0, "attempt":…
186 …cache_hash", "encoding": "json"}, "frame_id": 0, "frame_compile_id": 0, "attempt": 0, "has_payload…
[all …]
/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/tracing/
DOpencensusTracer.java61 * <dt>{@code attempt count}
64 * <dd>The status code of the last attempt
80 * <li>{@code Attempt cancelled} with the following attributes:
82 * <dt>{@code attempt}
83 * <dd>Zero based sequential attempt number
84 * <dt>{@code attempt request count}
85 * <dd>The number of requests sent in this attempt. This will only be set for client
87 * <dt>{@code attempt response count}
88 * <dd>The number of responses received in this attempt. This will only be set for server
91 * <dd>The UUID of the connection which the attempt was sent.
[all …]
/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/retrying/
DExponentialRetryAlgorithmTest.java76 TimedAttemptSettings attempt = algorithm.createFirstAttempt(); in testCreateFirstAttempt() local
79 assertEquals(0, attempt.getAttemptCount()); in testCreateFirstAttempt()
80 assertEquals(0, attempt.getOverallAttemptCount()); in testCreateFirstAttempt()
81 assertEquals(Duration.ZERO, attempt.getRetryDelay()); in testCreateFirstAttempt()
82 assertEquals(Duration.ZERO, attempt.getRandomizedRetryDelay()); in testCreateFirstAttempt()
83 assertEquals(Duration.ofMillis(1L), attempt.getRpcTimeout()); in testCreateFirstAttempt()
84 assertEquals(Duration.ZERO, attempt.getRetryDelay()); in testCreateFirstAttempt()
89 TimedAttemptSettings attempt = algorithm.createFirstAttempt(retryingContext); in testCreateFirstAttemptOverride() local
92 assertEquals(0, attempt.getAttemptCount()); in testCreateFirstAttemptOverride()
93 assertEquals(0, attempt.getOverallAttemptCount()); in testCreateFirstAttemptOverride()
[all …]
/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/tracing/
DOpencensusTracerTest.java95 // Attempt 0 in testUnarySuccessExample()
98 "Attempt failed, scheduling next attempt", in testUnarySuccessExample()
100 "attempt", AttributeValue.longAttributeValue(0), in testUnarySuccessExample()
106 // Attempt 1 in testUnarySuccessExample()
109 "Attempt succeeded", in testUnarySuccessExample()
111 "attempt", AttributeValue.longAttributeValue(1), in testUnarySuccessExample()
115 .putAttributes(ImmutableMap.of("attempt count", AttributeValue.longAttributeValue(2))); in testUnarySuccessExample()
149 // Attempt 0 - initial poll of the initial rpc in testLongRunningExample()
154 "attempt", AttributeValue.longAttributeValue(0), in testLongRunningExample()
160 // Attempt 1 - first real poll in testLongRunningExample()
[all …]
/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/retrying/
DExponentialRetryAlgorithm.java41 * attempt execution time.
53 * @param globalSettings global retry settings (attempt independent)
63 * Creates a first attempt {@link TimedAttemptSettings}. The first attempt is configured to be
66 * @return first attempt settings
82 * Creates a first attempt {@link TimedAttemptSettings}. The first attempt is configured to be
87 * @return first attempt settings
111 * Creates a next attempt {@link TimedAttemptSettings}. The implementation increments the current
112 * attempt count and uses randomized exponential backoff factor for calculating next attempt
115 * @param previousSettings previous attempt settings
116 * @return next attempt settings
[all …]
DRetryingFuture.java45 * Sets the attempt in a form of a future. This future represents a concrete retry attempt,
50 * @param attemptFuture the attempt future
57 /** Returns current (active) attempt settings. */
61 * Returns latest completed attempt result or {@code null} if the first attempt hasn't completed
73 * <p>The number of attempt results may be (and usually is) lower than the number of actual
74 * attempts, since only a completed attempt has a result and not all attempts complete (some of
80 * <li>If the first attempt hasn't completed yet, this method returns {@code null}.
81 * <li>Right after completion of each attempt this method starts returning a new already
82 * completed future, which represents the result of the latest completed attempt.
83 * <li>If it was the last attempt, the events happen in the following order: 1) the attempt
[all …]
DRetryAlgorithm.java39 * response, and the execution time settings of the previous attempt.
93 * Creates a first attempt {@link TimedAttemptSettings}.
95 * @return first attempt settings
104 * Creates a first attempt {@link TimedAttemptSettings}.
108 * @return first attempt settings
118 * Creates a next attempt {@link TimedAttemptSettings}. This method will return first non-null
121 * @param previousThrowable exception thrown by the previous attempt or null if a result was
123 * @param previousResponse response returned by the previous attempt or null if an exception was
125 * @param previousSettings previous attempt settings
126 * @return next attempt settings, can be {@code null}, if no there should be no new attempt
[all …]
DTimedAttemptSettings.java36 /** Timed attempt execution settings. Defines time-specific properties of a retry attempt. */
40 /** Returns global (attempt-independent) retry settings. */
49 /** Returns rpc timeout used for this attempt. */
53 * Returns randomized attempt delay. By default this value is calculated based on the {@code
54 * retryDelay} value, and is used as the actual attempt execution delay.
59 * The attempt count. It is a zero-based value (first attempt will have this value set to 0). For
65 * The overall attempt count. It is a zero-based value (first attempt will have this value set to
66 * 0). This will be the sum of all attempt counts for a streaming RPC and will be equal to {@link
72 * The start time of the first attempt. Note that this value is dependent on the actual {@link
85 /** Sets global (attempt-independent) retry settings. */
[all …]
DTimedRetryAlgorithmWithContext.java37 * attempt settings and current time:
40 * <li>Creating first attempt {@link TimedAttemptSettings}.
41 * <li>Accepting a task for retry so another attempt will be made.
44 * <li>Creating {@link TimedAttemptSettings} for each subsequent retry attempt.
55 * Creates a first attempt {@link TimedAttemptSettings}.
59 * @return first attempt settings
64 * Creates a next attempt {@link TimedAttemptSettings}, which defines properties of the next
65 * attempt.
69 * @param previousSettings previous attempt settings
70 * @return next attempt settings or {@code null} if the implementing algorithm does not provide
[all …]
/external/tensorflow/tensorflow/core/kernels/
Dfifo_queue.cc63 [tuple, this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueue()
65 attempt->context->SetStatus( in TryEnqueue()
120 [tuple, this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueueMany()
122 attempt->context->SetStatus( in TryEnqueueMany()
130 tuple[0].dim_size(0) - attempt->elements_requested; in TryEnqueueMany()
133 attempt->context->SetStatus(GetElementComponentFromBatch( in TryEnqueueMany()
134 tuple, index, i, attempt->context, &element)); in TryEnqueueMany()
135 if (!attempt->context->status().ok()) return kComplete; in TryEnqueueMany()
138 --attempt->elements_requested; in TryEnqueueMany()
139 if (attempt->elements_requested == 0) { in TryEnqueueMany()
[all …]
Dpriority_queue.cc84 [tuple, this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueue()
86 attempt->context->SetStatus( in TryEnqueue()
92 attempt->context->SetStatus(errors::InvalidArgument( in TryEnqueue()
148 [tuple, this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueueMany()
150 attempt->context->SetStatus( in TryEnqueueMany()
158 tuple[0].dim_size(0) - attempt->elements_requested; in TryEnqueueMany()
161 attempt->context->SetStatus(GetElementComponentFromBatch( in TryEnqueueMany()
162 tuple, index, 0, attempt->context, &priority_element)); in TryEnqueueMany()
163 if (!attempt->context->status().ok()) return kComplete; in TryEnqueueMany()
165 attempt->context->SetStatus(errors::InvalidArgument( in TryEnqueueMany()
[all …]
Drandom_shuffle_queue_op.cc141 [tuple, this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueue()
143 attempt->context->SetStatus(errors::Cancelled( in TryEnqueue()
200 [tuple, this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueueMany()
202 attempt->context->SetStatus(errors::Cancelled( in TryEnqueueMany()
210 tuple[0].dim_size(0) - attempt->elements_requested; in TryEnqueueMany()
213 attempt->context->SetStatus(GetElementComponentFromBatch( in TryEnqueueMany()
214 tuple, index, i, attempt->context, &element)); in TryEnqueueMany()
215 if (!attempt->context->status().ok()) return kComplete; in TryEnqueueMany()
218 --attempt->elements_requested; in TryEnqueueMany()
219 if (attempt->elements_requested == 0) { in TryEnqueueMany()
[all …]
Dconditional_accumulator_base.cc45 LOG(WARNING) << "Attempt to set current_global_step_ to smaller value: " in SetGlobalStep()
54 * Logs an attempt to extract the average gradient, and tries to flush all
56 * A TakeGrad attempt is blocked until num_required > counter_, i.e.,
60 * attempt is unblocked.
62 * callback: A callback to be executed after the attempt has been completed.
82 [this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryTakeGrad()
83 if (counter_ >= attempt->elements_requested) { in TryTakeGrad()
85 attempt->context, attempt->done_callback); in TryTakeGrad()
116 for (Attempt& attempt : takegrad_attempts_) { in Cancel()
117 if (attempt.cancellation_manager == cancellation_manager && in Cancel()
[all …]
Dpadding_fifo_queue.cc101 this](Attempt* attempt) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryDequeueMany()
103 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
105 // to reset the attempt tuple. in TryDequeueMany()
106 if (!attempt->tuples.empty()) { in TryDequeueMany()
108 for (int64_t i = attempt->tuples.size() - 1; i >= 0; --i) { in TryDequeueMany()
111 Status s = GetElementComponent(attempt->tuples[i], j, in TryDequeueMany()
112 attempt->context, &element); in TryDequeueMany()
114 attempt->context->SetStatus( in TryDequeueMany()
127 attempt->tuples.clear(); in TryDequeueMany()
128 attempt->elements_requested = queue_size; in TryDequeueMany()
[all …]
/external/sdk-platform-java/showcase/proto-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/
DSequenceReport.java49 // @@protoc_insertion_point(interface_extends:google.showcase.v1beta1.SequenceReport.Attempt)
54 * The attempt number - starting at 0.
64 * The deadline dictated by the attempt to the server.
73 * The deadline dictated by the attempt to the server.
82 * The deadline dictated by the attempt to the server.
91 * The time that the server responded to the RPC attempt. Used for
101 * The time that the server responded to the RPC attempt. Used for
111 * The time that the server responded to the RPC attempt. Used for
122 * receiving this attempt. Used for validating attempt delay backoff.
132 * receiving this attempt. Used for validating attempt delay backoff.
[all …]
/external/google-cloud-java/java-tasks/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/
DAttempt.java25 * The status of a task attempt.
28 * Protobuf type {@code google.cloud.tasks.v2beta3.Attempt}
30 public final class Attempt extends com.google.protobuf.GeneratedMessageV3 class
32 // @@protoc_insertion_point(message_implements:google.cloud.tasks.v2beta3.Attempt)
35 // Use Attempt.newBuilder() to construct.
36 private Attempt(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Attempt() method in Attempt
40 private Attempt() {} in Attempt() method in Attempt
45 return new Attempt(); in newInstance()
64 com.google.cloud.tasks.v2beta3.Attempt.class, in internalGetFieldAccessorTable()
65 com.google.cloud.tasks.v2beta3.Attempt.Builder.class); in internalGetFieldAccessorTable()
[all …]
/external/google-cloud-java/java-tasks/proto-google-cloud-tasks-v2/src/main/java/com/google/cloud/tasks/v2/
DAttempt.java25 * The status of a task attempt.
28 * Protobuf type {@code google.cloud.tasks.v2.Attempt}
30 public final class Attempt extends com.google.protobuf.GeneratedMessageV3 class
32 // @@protoc_insertion_point(message_implements:google.cloud.tasks.v2.Attempt)
35 // Use Attempt.newBuilder() to construct.
36 private Attempt(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Attempt() method in Attempt
40 private Attempt() {} in Attempt() method in Attempt
45 return new Attempt(); in newInstance()
64 com.google.cloud.tasks.v2.Attempt.class, in internalGetFieldAccessorTable()
65 com.google.cloud.tasks.v2.Attempt.Builder.class); in internalGetFieldAccessorTable()
[all …]
/external/cronet/stable/third_party/libc++/src/test/libcxx/strings/string.view/string.view.iterators/
Dassert.iterator-indexing.pass.cpp27 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
28 : "__bounded_iter::operator*: Attempt to dereference an iterator at the end"); in test_iterator()
34 reverse ? "__bounded_iter::operator+=: Attempt to rewind an iterator past the start" in test_iterator()
35 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
39 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
40 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
47 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
48 : "__bounded_iter::operator++: Attempt to advance an iterator past the end"; in test_iterator()
58 reverse ? "__bounded_iter::operator++: Attempt to advance an iterator past the end" in test_iterator()
59 : "__bounded_iter::operator--: Attempt to rewind an iterator past the start"; in test_iterator()
[all …]
/external/cronet/tot/third_party/libc++/src/test/libcxx/strings/string.view/string.view.iterators/
Dassert.iterator-indexing.pass.cpp27 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
28 : "__bounded_iter::operator*: Attempt to dereference an iterator at the end"); in test_iterator()
34 reverse ? "__bounded_iter::operator+=: Attempt to rewind an iterator past the start" in test_iterator()
35 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
39 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
40 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
47 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
48 : "__bounded_iter::operator++: Attempt to advance an iterator past the end"; in test_iterator()
58 reverse ? "__bounded_iter::operator++: Attempt to advance an iterator past the end" in test_iterator()
59 : "__bounded_iter::operator--: Attempt to rewind an iterator past the start"; in test_iterator()
[all …]
/external/cronet/tot/third_party/libc++/src/test/libcxx/containers/views/views.span/
Dassert.iterator-indexing.pass.cpp31 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
32 : "__bounded_iter::operator*: Attempt to dereference an iterator at the end"); in test_iterator()
38 reverse ? "__bounded_iter::operator+=: Attempt to rewind an iterator past the start" in test_iterator()
39 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
43 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
44 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
51 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
52 : "__bounded_iter::operator++: Attempt to advance an iterator past the end"; in test_iterator()
61 reverse ? "__bounded_iter::operator++: Attempt to advance an iterator past the end" in test_iterator()
62 : "__bounded_iter::operator--: Attempt to rewind an iterator past the start"; in test_iterator()
[all …]
/external/cronet/stable/third_party/libc++/src/test/libcxx/containers/views/views.span/
Dassert.iterator-indexing.pass.cpp31 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
32 : "__bounded_iter::operator*: Attempt to dereference an iterator at the end"); in test_iterator()
38 reverse ? "__bounded_iter::operator+=: Attempt to rewind an iterator past the start" in test_iterator()
39 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
43 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
44 : "__bounded_iter::operator->: Attempt to dereference an iterator at the end"); in test_iterator()
51 reverse ? "__bounded_iter::operator--: Attempt to rewind an iterator past the start" in test_iterator()
52 : "__bounded_iter::operator++: Attempt to advance an iterator past the end"; in test_iterator()
61 reverse ? "__bounded_iter::operator++: Attempt to advance an iterator past the end" in test_iterator()
62 : "__bounded_iter::operator--: Attempt to rewind an iterator past the start"; in test_iterator()
[all …]
/external/cronet/stable/net/socket/
Dtcp_stream_attempt_unittest.cc104 TcpStreamAttempt* attempt() { return attempt_.get(); } in attempt() function in net::__anone2b8c25c0111::StreamAttemptHelper
157 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
159 ASSERT_FALSE(helper.attempt()->connect_timing().connect_start.is_null()); in TEST_F()
160 ASSERT_FALSE(helper.attempt()->connect_timing().connect_end.is_null()); in TEST_F()
161 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
170 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_CONNECTING); in TEST_F()
176 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
178 ASSERT_FALSE(helper.attempt()->connect_timing().connect_start.is_null()); in TEST_F()
179 ASSERT_FALSE(helper.attempt()->connect_timing().connect_end.is_null()); in TEST_F()
180 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
[all …]
Dtls_stream_attempt_unittest.cc102 TlsStreamAttempt* attempt() { return attempt_.get(); } in attempt() function in net::__anonf18808080111::TlsStreamAttemptHelper
207 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
209 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
210 ValidateConnectTiming(helper.attempt()->connect_timing()); in TEST_F()
228 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
230 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
231 ValidateConnectTiming(helper.attempt()->connect_timing()); in TEST_F()
254 ValidateConnectTiming(helper.attempt()->connect_timing()); in TEST_F()
267 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_CONNECTING); in TEST_F()
269 // We don't provide SSLConfig yet so the attempt should not complete. in TEST_F()
[all …]
/external/cronet/tot/net/socket/
Dtcp_stream_attempt_unittest.cc104 TcpStreamAttempt* attempt() { return attempt_.get(); } in attempt() function in net::__anon23498a780111::StreamAttemptHelper
157 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
159 ASSERT_FALSE(helper.attempt()->connect_timing().connect_start.is_null()); in TEST_F()
160 ASSERT_FALSE(helper.attempt()->connect_timing().connect_end.is_null()); in TEST_F()
161 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
170 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_CONNECTING); in TEST_F()
176 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
178 ASSERT_FALSE(helper.attempt()->connect_timing().connect_start.is_null()); in TEST_F()
179 ASSERT_FALSE(helper.attempt()->connect_timing().connect_end.is_null()); in TEST_F()
180 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
[all …]
Dtls_stream_attempt_unittest.cc102 TlsStreamAttempt* attempt() { return attempt_.get(); } in attempt() function in net::__anon3218d0240111::TlsStreamAttemptHelper
207 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
209 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
210 ValidateConnectTiming(helper.attempt()->connect_timing()); in TEST_F()
228 helper.attempt()->ReleaseStreamSocket(); in TEST_F()
230 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_IDLE); in TEST_F()
231 ValidateConnectTiming(helper.attempt()->connect_timing()); in TEST_F()
254 ValidateConnectTiming(helper.attempt()->connect_timing()); in TEST_F()
267 ASSERT_EQ(helper.attempt()->GetLoadState(), LOAD_STATE_CONNECTING); in TEST_F()
269 // We don't provide SSLConfig yet so the attempt should not complete. in TEST_F()
[all …]

12345678910>>...387