- Sort Score
- Num 10 results
- Language All
Results 361 - 370 of 676 for cdone (0.02 seconds)
-
docs/changelogs/changelog_4x.md
is a view of what created it, we use _as_. * Fix: Permit response codes of zero for compatibility with OkHttp 3.x. * Fix: Change the return type of `MockWebServer.takeRequest()` to be nullable. * Fix: Make `Call.clone()` public to Kotlin callers. ## Version 4.0.0-RC1 _2019-06-03_ * First stable preview of OkHttp 4. ## Version 3.x [Change log](https://square.github.io/okhttp/changelog_3x/)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance.go
if quit { return } timer.Reset(randSleepFor()) } }() rebalanceLogEvent(ctx, "Pool %d rebalancing is started", poolIdx+1) for { select { case <-ctx.Done(): doneCh <- ctx.Err() return err default: } bucket, ok := z.nextRebalBucket(poolIdx) if !ok { // no more buckets to rebalance or target free_space/capacity reached break }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 28.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallKotlinTest.kt
server.enqueue(MockResponse(body = "def")) val request = Request(server.url("/")) val call = client.newCall(request) val response1 = call.execute() val cloned = call.clone() val response2 = cloned.execute() assertThat("abc").isEqualTo(response1.body.string()) assertThat("def").isEqualTo(response2.body.string()) } @Test @Flaky fun testMockWebserverRequest() {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 8.4K bytes - Click Count (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/MojoDescriptor.java
return v4Api; } /** * Creates a shallow copy of this mojo descriptor. */ @Override public MojoDescriptor clone() { try { return (MojoDescriptor) super.clone(); } catch (CloneNotSupportedException e) { throw new UnsupportedOperationException(e); } }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 21.7K bytes - Click Count (0) -
impl/maven-core/src/site/apt/index.apt
* {{{./extension.html}extension descriptor}} and {{{./core-extensions.html}core extensions}}, * {{{/guides/mini/guide-maven-classloading.html}classloader hierarchy}} done by <<<ClassRealmManager>>> component ({{{./apidocs/org/apache/maven/classrealm/ClassRealmManager.html}javadoc}}), with its <<<DefaultClassRealmManager>>> implementationCreated: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 5.3K bytes - Click Count (0) -
cmd/tier-sweeper.go
// 3. If bucket versioning is enabled and // a. version id is specified, remove its remote object. // b. version id is not specified, nothing to be done (a delete marker is added). delTier := false switch { case !os.Versioned, os.Suspended: // 1, 2.a, 2.b delTier = true case os.Versioned && os.VersionID != "": // 3.a delTier = true } if delTier {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Click Count (0) -
docs/distributed/DECOMMISSION.md
- On Kubernetes setups, the statefulset specification needs to be modified by changing the command line input for the MinIO container. Once the relevant changes are done, proceed to execute `kubectl apply -f statefulset.yaml`.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jul 11 14:59:49 GMT 2022 - 8.3K bytes - Click Count (0) -
cmd/untar.go
return err } wg.Add(1) go func(name string, fi fs.FileInfo, b []byte) { rc := disconnectReader{r: bytes.NewReader(b)} defer func() { rc.Close() <-asyncWriters wg.Done() xioutil.ODirectPoolMedium.Put(bufp) }() if err := putObject(&rc, fi, name); err != nil { if o.ignoreErrs { s3LogIf(ctx, err) return } asyncErrMu.Lock()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (2) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} /** * Tests that all listeners complete, even if they were added before or after the future was * finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully() throws InterruptedException, ExecutionException {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 6.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
transitionStates.add(state()); return directExecutor(); } } // Functional tests using real thread. We only verify publicly visible state. // Interaction assertions are done by the single-threaded unit tests. private static class DefaultService extends AbstractIdleService { @Override protected void startUp() throws Exception {} @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 7.5K bytes - Click Count (0)