/external/pytorch/test/dynamo/ |
D | test_structured_trace.py | 177 {"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/ |
D | OpencensusTracer.java | 61 * <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/ |
D | ExponentialRetryAlgorithmTest.java | 76 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/ |
D | OpencensusTracerTest.java | 95 // 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/ |
D | ExponentialRetryAlgorithm.java | 41 * 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 …]
|
D | RetryingFuture.java | 45 * 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 …]
|
D | RetryAlgorithm.java | 39 * 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 …]
|
D | TimedAttemptSettings.java | 36 /** 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 …]
|
D | TimedRetryAlgorithmWithContext.java | 37 * 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/ |
D | fifo_queue.cc | 63 [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 …]
|
D | priority_queue.cc | 84 [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 …]
|
D | random_shuffle_queue_op.cc | 141 [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 …]
|
D | conditional_accumulator_base.cc | 45 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 …]
|
D | padding_fifo_queue.cc | 101 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/ |
D | SequenceReport.java | 49 // @@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/ |
D | Attempt.java | 25 * 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/ |
D | Attempt.java | 25 * 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/ |
D | assert.iterator-indexing.pass.cpp | 27 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/ |
D | assert.iterator-indexing.pass.cpp | 27 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/ |
D | assert.iterator-indexing.pass.cpp | 31 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/ |
D | assert.iterator-indexing.pass.cpp | 31 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/ |
D | tcp_stream_attempt_unittest.cc | 104 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 …]
|
D | tls_stream_attempt_unittest.cc | 102 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/ |
D | tcp_stream_attempt_unittest.cc | 104 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 …]
|
D | tls_stream_attempt_unittest.cc | 102 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 …]
|