- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 601 for second (3.42 sec)
-
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
fun emptyCache(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) cache.close() assertJournalEquals() } @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun recoverFromInitializationFailure(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) // Add an uncommitted entry. This will get detected on initialization, and the cache will
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
internal/grid/benchmark_test.go
b.Run("bytes", func(b *testing.B) { for par := 1; par <= 32; par *= 2 { b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) { defer timeout(60 * time.Second)() ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defer cancel() b.ReportAllocs() b.SetBytes(int64(len(payload) * 2)) b.ResetTimer() t := time.Now() var ops int64 var lat int64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/logging/OneLineLogFormat.kt
.appendLiteral(':') .appendValue(SECOND_OF_MINUTE, 2) .optionalStart() .appendFraction(NANO_OF_SECOND, 3, 3, true) .toFormatter() private val offset = ZoneOffset.systemDefault() override fun format(record: LogRecord): String { val message = formatMessage(record) val time = Instant.ofEpochMilli(record.millis).atZone(offset) return if (record.thrown != null) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/misc/Pair.java
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 3.6K bytes - Viewed (0) -
common-protos/k8s.io/api/autoscaling/v2/generated.proto
// * increase no more than 4 pods per 60 seconds // * double the number of pods per 60 seconds // No stabilization is used. // +optional optional HPAScalingRules scaleUp = 1; // scaleDown is scaling policy for scaling Down. // If not set, the default value is to allow to scale down to minReplicas pods, with a // 300 second stabilization window (i.e., the highest recommendation for
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21.3K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
""" |data: first event |id: 1 | |data: second event |id | |data: third event | | """.trimMargin(), ) assertThat(callbacks.remove()).isEqualTo(Event("1", null, "first event")) assertThat(callbacks.remove()).isEqualTo(Event(null, null, "second event")) assertThat(callbacks.remove()).isEqualTo(Event(null, null, "third event")) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
tensorflow/c/eager/tape.h
if (grad_it == gradients.end()) { result[i] = nullptr; } else { if (grad_it->second.size() > 1) { Gradient* grad = vspace.AggregateGradients(grad_it->second); grad_it->second.clear(); grad_it->second.push_back(grad); } result[i] = grad_it->second[0]; used_gradient_ids.insert(tensor_id); } } VLOG(1) << "Final gradients size: "
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Apr 02 12:40:29 GMT 2024 - 47.2K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
TestCallable secondCallable = new TestCallable(SettableFuture.<Void>create()); Future<?> second = serializer.submitAsync(secondCallable, directExecutor()); assertThat(secondCallable.called).isFalse(); assertThat(second.toString()).contains(secondCallable.toString()); firstFuture.set(null); assertThat(second.toString()).contains(secondCallable.future.toString()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
TestCallable secondCallable = new TestCallable(SettableFuture.<Void>create()); Future<?> second = serializer.submitAsync(secondCallable, directExecutor()); assertThat(secondCallable.called).isFalse(); assertThat(second.toString()).contains(secondCallable.toString()); firstFuture.set(null); assertThat(second.toString()).contains(secondCallable.future.toString()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
cmd/mrf.go
if wildcard.Match("tmp-old/*", u.object) { continue } } now := time.Now() if now.Sub(u.queued) < time.Second { // let recently failed networks to reconnect // making MRF wait for 1s before retrying, // i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0)