- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for did (0.19 sec)
-
cmd/site-replication.go
p = pi } else { p = v } wg.Add(1) go func(pi madmin.PeerInfo, dID string) { defer wg.Done() admClient, err := c.getAdminClient(ctx, dID) if dID == peer.DeploymentID { admClient, err = c.getAdminClientWithEndpoint(ctx, dID, pi.Endpoint) } if err != nil { errs[dID] = errSRPeerResp(fmt.Errorf("unable to create admin client for %s: %w", pi.Name, err)) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
assertThat(cause) .hasMessageThat() .contains( "AsyncFunction.apply returned null instead of a Future. " + "Did you mean to return immediateFuture(null)?"); } } @J2ktIncompatible @GwtIncompatible // threads public void testCatchingAsync_interruptPropagatesToTransformingThread() throws Exception {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
assertThat(cause) .hasMessageThat() .contains( "AsyncFunction.apply returned null instead of a Future. " + "Did you mean to return immediateFuture(null)?"); } } @J2ktIncompatible @GwtIncompatible // threads public void testCatchingAsync_interruptPropagatesToTransformingThread() throws Exception {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
cmd/admin-handlers.go
hosts: hostMap, disks: diskMap, jobID: jobID, depID: dID, }) m.Merge(&mLocal) // Allow half the interval for collecting remote... cctx, cancel := context.WithTimeout(ctx, interval/2) mRemote := collectRemoteMetrics(cctx, types, collectMetricsOpts{ hosts: hostMap, disks: diskMap, jobID: jobID, depID: dID, }) cancel() m.Merge(&mRemote) if !byHost {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
src/cmd/cgo/internal/test/callback.go
if !x { t.Fatal("nestedCall did not call func") } } func testCallbackGC(t *testing.T) { nestedCall(runtime.GC) } func testCallbackPanic(t *testing.T) { // Make sure panic during callback unwinds properly. if lockedOSThread() { t.Fatal("locked OS thread on entry to TestCallbackPanic") } defer func() { s := recover() if s == nil { t.Fatal("did not panic") }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri May 12 12:00:02 GMT 2023 - 111.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
assertThat(response.header("Content-Encoding")).isEqualTo("gzip") assertThat(response.body.source().readByteString()).isEqualTo( gzippedBody.snapshot(), ) // The request did not offer gzip support. val recordedRequest = server.takeRequest() assertThat(recordedRequest.headers["Accept-Encoding"]).isNull() } @Test fun asyncResponseCanBeConsumedLater() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
cmd/object-handlers.go
return } else if ci.StatusCode == http.StatusNotModified { w.WriteHeader(ci.StatusCode) return } // We did not satisfy any requirement from the cache, update the cache. // this basically means that we do not have the Data for the object // cached yet update = true }) if !update {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/action/FessLabels.java
public static final String LABELS_next_page = "{labels.next_page}"; /** The key of the message: Your search - <b>{0}</b> - did not match any documents. */ public static final String LABELS_did_not_match = "{labels.did_not_match}"; /** The key of the message: Fess */ public static final String LABELS_search_title = "{labels.search_title}";
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Fri Mar 22 11:58:34 GMT 2024 - 146.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.30.md
([#122068](https://github.com/kubernetes/kubernetes/pull/122068), [@caohe](https://github.com/caohe)) - Fixed an issue where `AvailableBytes` sometimes did not report correctly on WindowsNodes when the `PodAndContainerStatsFromCRI` feature was enabled. ([#122846](https://github.com/kubernetes/kubernetes/pull/122846), [@marosset](https://github.com/marosset))
Plain Text - Registered: Fri May 03 09:05:14 GMT 2024 - Last Modified: Wed Apr 17 17:56:15 GMT 2024 - 227.9K bytes - Viewed (0) -
cmd/object-handlers_test.go
} // Since `apiRouter` satisfies `http.Handler` it has a // ServeHTTP to execute the logic of the handler. apiRouter.ServeHTTP(rec, req) if rec.Code != 200 { t.Errorf("Test %d: Did not receive a 200 response: %d", i+1, rec.Code) } contentLength = rec.Header().Get("Content-Length") } if contentLength != fmt.Sprintf("%d", objectLength(input)) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0)