Home
last modified time | relevance | path

Searched refs:attempt (Results 1 – 25 of 865) sorted by relevance

12345678910>>...35

/external/tensorflow/tensorflow/core/kernels/
Dfifo_queue.cc62 [tuple, this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueue()
64 attempt->context->SetStatus( in TryEnqueue()
120 [tuple, this](Attempt* attempt) 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.cc83 [tuple, this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueue()
85 attempt->context->SetStatus( in TryEnqueue()
91 attempt->context->SetStatus(errors::InvalidArgument( in TryEnqueue()
148 [tuple, this, ctx](Attempt* attempt) 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()
166 attempt->context->SetStatus(errors::InvalidArgument( in TryEnqueueMany()
[all …]
Drandom_shuffle_queue_op.cc139 [tuple, this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueue()
141 attempt->context->SetStatus(errors::Cancelled( in TryEnqueue()
197 [tuple, this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryEnqueueMany()
199 attempt->context->SetStatus(errors::Cancelled( in TryEnqueueMany()
207 tuple[0].dim_size(0) - attempt->elements_requested; in TryEnqueueMany()
210 attempt->context->SetStatus(GetElementComponentFromBatch( in TryEnqueueMany()
211 tuple, index, i, attempt->context, &element)); in TryEnqueueMany()
212 if (!attempt->context->status().ok()) return kComplete; in TryEnqueueMany()
215 --attempt->elements_requested; in TryEnqueueMany()
216 if (attempt->elements_requested == 0) { in TryEnqueueMany()
[all …]
Dpadding_fifo_queue.cc101 this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryDequeueMany()
103 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
106 if (!attempt->tuples.empty()) { in TryDequeueMany()
108 for (int64 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()
136 if (attempt->context->status().ok()) { in TryDequeueMany()
[all …]
Dconditional_accumulator_base.cc82 [this](Attempt* attempt) 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()
118 attempt.cancellation_token == token) { in Cancel()
119 if (!attempt.is_cancelled) { in Cancel()
120 attempt.is_cancelled = true; in Cancel()
121 attempt.context->SetStatus( in Cancel()
123 std::swap(callback, attempt.done_callback); in Cancel()
Dqueue_base.cc196 for (Attempt& attempt : *attempts) { in Cancel()
197 if (attempt.cancellation_manager == cancellation_manager && in Cancel()
198 attempt.cancellation_token == token) { in Cancel()
199 if (!attempt.is_cancelled) { in Cancel()
200 attempt.is_cancelled = true; in Cancel()
202 attempt.context->SetStatus( in Cancel()
205 attempt.context->SetStatus( in Cancel()
208 std::swap(callback, attempt.done_callback); in Cancel()
225 for (Attempt& attempt : enqueue_attempts_) { in CloseAndCancel()
226 if (!attempt.is_cancelled) { in CloseAndCancel()
[all …]
/external/perfetto/src/profiling/memory/
Dscoped_spinlock.cc36 for (size_t attempt = 0; mode == Mode::Blocking || in LockSlow() local
37 attempt < kLockAttemptsPerSleep * kSleepAttempts; in LockSlow()
38 attempt++) { in LockSlow()
44 if (attempt && attempt % kLockAttemptsPerSleep == 0) in LockSlow()
/external/skqp/infra/bots/recipe_modules/run/
Dapi.py83 for attempt in xrange(attempts):
85 if attempt > 0:
86 step_name += ' (attempt %d)' % (attempt + 1)
90 if attempt > 0 and fail_build_on_failure:
91 del self._failed[-attempt:]
94 if attempt == attempts - 1:
98 between_attempts_fn(attempt+1)
/external/skia/infra/bots/recipe_modules/run/
Dapi.py83 for attempt in xrange(attempts):
85 if attempt > 0:
86 step_name += ' (attempt %d)' % (attempt + 1)
90 if attempt > 0 and fail_build_on_failure:
91 del self._failed[-attempt:]
94 if attempt == attempts - 1:
98 between_attempts_fn(attempt+1)
/external/chromium-trace/catapult/devil/docs/
Dadb_wrapper.md37 retries: (optional) Number of retries to attempt.
49 retries: (optional) Number of retries to attempt.
62 retries: (optional) Number of retries to attempt.
93 retries: (optional) Number of retries to attempt.
126 attempt. Otherwise, does nothing.
152 retries: (optional) Number of retries to attempt.
163 retries: (optional) Number of retries to attempt.
173 retries: (optional) Number of retries to attempt.
185 retries: (optional) Number of retries to attempt.
203 retries: (optional) Number of retries to attempt.
[all …]
/external/perfetto/src/tracing/core/
Dshared_memory_abi.cc34 inline void WaitBeforeNextAttempt(int attempt) { in WaitBeforeNextAttempt() argument
35 if (attempt < kRetryAttempts / 2) { in WaitBeforeNextAttempt()
38 base::SleepMicroseconds((unsigned(attempt) / 10) * 1000); in WaitBeforeNextAttempt()
165 for (int attempt = 0; attempt < kRetryAttempts; attempt++) { in TryAcquireChunk() local
200 WaitBeforeNextAttempt(attempt); in TryAcquireChunk()
243 for (int attempt = 0; attempt < kRetryAttempts; attempt++) { in ReleaseChunk() local
281 WaitBeforeNextAttempt(attempt); in ReleaseChunk()
/external/curl/tests/data/
Dtest14825 ftp://%HOSTIP:%FTPPORT/attempt/to/get/this/148 --ftp-create-dirs
43 CWD attempt
44 MKD attempt
45 CWD attempt
/external/syzkaller/vendor/google.golang.org/grpc/
Dstream.go303 attempt: &csAttempt{
316 cs.attempt.cs = cs
353 attempt *csAttempt // the active client stream attempt member
383 return cs.attempt.context()
387 m, err := cs.attempt.header()
398 return cs.attempt.trailer()
403 return cs.attempt.sendMsg(m)
408 return cs.attempt.recvMsg(m)
412 cs.attempt.closeSend()
436 cs.attempt.finish(err)
[all …]
Dcall.go76 if !cs.c.failFast && cs.attempt.s.Unprocessed() && firstAttempt {
84 if !cs.c.failFast && cs.attempt.s.Unprocessed() && firstAttempt {
/external/tensorflow/tensorflow/java/src/main/java/org/tensorflow/
DNativeLibrary.java208 for (int attempt = 0; attempt < 1000; attempt++) { in createTemporaryDirectory()
209 File temporaryDirectory = new File(baseDirectory, directoryName + attempt); in createTemporaryDirectory()
/external/autotest/server/site_tests/firmware_Cr50InvalidateRW/
Dfirmware_Cr50InvalidateRW.py98 attempt = i + 1
104 attempt, result)
114 if (attempt == corrupt_login) != (self.SUCCESS in result):
/external/vogar/src/vogar/monitor/
DHostMonitor.java53 for (int attempt = 0; true; attempt++) { in attach()
68 log.verbose("connection " + attempt + " to localhost:" in attach()
/external/ltp/testcases/commands/tpm-tools/tpmtoken/tpmtoken_import/
D00_Descriptions.txt18 tpmtoken_import attempt to import a certificate from a key file
20 tpmtoken_import attempt to import a key from a certificate file
/external/tensorflow/tensorflow/core/lib/io/snappy/
Dsnappy_buffers_test.cc121 for (int attempt = 0; attempt < 2; ++attempt) { in TestMultipleWrites() local
/external/autotest/server/site_tests/firmware_PDConnect/
Dfirmware_PDConnect.py32 for attempt in xrange(self.CONNECT_ITERATIONS):
33 logging.info('Disconnect/Connect iteration %d', attempt)
/external/autotest/server/site_tests/autoupdate_OmahaResponse/
Dcontrol.backoff_disabled.full8 PURPOSE = "Tests second update attempt succeeds if backoff is disabled."
14 Test we can update when we fail the first attempt and backoff is disabled.
Dcontrol.backoff_enabled.full7 PURPOSE = "Tests second update attempt fails if backoff is enabled."
14 Test we cannot update when we fail the first attempt and backoff is enabled.
/external/tensorflow/tensorflow/tools/ci_build/
DREADME.md68 multiple times. Each test log is specific to the shard, run, and attempt.
72 and attempt number.
75 run, and attempt to view its log. You can also type the desired shard,
76 run, or attempt number in the field above its grid.
/external/autotest/server/cros/chaos_lib/
Dchaos_analyzer_usage.txt1 …aos logs & packet captures and produce a consolidated analysis of each test attempt in a text file.
17 3. The analysis output for each attempt is stored in the same folder as the packet captures with th…
42 2015-04-06T19:35:07.151703-07:00 NOTICE autotest[12338]: Connection attempt 4
/external/skia/infra/bots/recipe_modules/run/examples/
Dfull.py44 def between_attempts_fn(attempt): argument
45 api.run(api.step, 'between_attempts #%d' % attempt,

12345678910>>...35