- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for readImg (0.15 sec)
-
src/net/http/serve_test.go
_, err := io.Copy(io.Discard, req.Body) if !errors.Is(err, os.ErrDeadlineExceeded) { t.Errorf("server timed out reading request body: got err %v; want os.ErrDeadlineExceeded", err) } res.Write([]byte(respBody)) }), func(ts *httptest.Server) { ts.Config.ReadHeaderTimeout = -1 // don't time out while reading headers ts.Config.ReadTimeout = timeout t.Logf("Server.Config.ReadTimeout = %v", timeout) })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/testdata/swagger.json
"type": "boolean" }, "secretFile": { "description": "Optional: SecretFile is the path to key ring for User, default is /etc/ceph/user.secret More info: https://examples.k8s.io/volumes/cephfs/README.md#how-to-use-it", "type": "string" }, "secretRef": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 229.4K bytes - Viewed (0) -
src/net/http/server.go
// WriteHeader, to make sure we don't consume the // remaining request body to try to advance to the next HTTP // request. Instead, when this is set, we stop reading // subsequent requests on this connection and stop reading // input from it. requestBodyLimitHit bool // trailers are the headers to be sent after the handler // finishes writing the body. This field is initialized from
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/net/http/transport_test.go
t.Fatalf("Do error = %v; want something containing %q", err, fakeErr.Error()) } if err := <-readBody; err == nil { t.Errorf("Unexpected success reading request body from handler; want 'unexpected EOF reading trailer'") } select { case <-didClose: default: t.Errorf("didn't see Body.Close") } } func TestTransportDialTLS(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/action/FessLabels.java
/** The key of the message: Purge User Before */ public static final String LABELS_PURGE_USER_INFO_DAY = "{labels.purgeUserInfoDay}"; /** The key of the message: Reading */ public static final String LABELS_READING = "{labels.reading}"; /** The key of the message: Role ID */ public static final String LABELS_ROLE_TYPE_IDS = "{labels.roleTypeIds}"; /** The key of the message: Script */
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Fri Mar 22 11:58:34 UTC 2024 - 146.4K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
} // For attachable volume types, lets check if volume is attached by reading from node lister. // This would avoid exponential back-off and creation of goroutine unnecessarily. We still // verify status of attached volume by directly reading from API server later on.This is necessarily // to ensure any race conditions because of cached state in the informer.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
cmd/object-handlers_test.go
} // read the response body. actualContent, err := io.ReadAll(rec.Body) if err != nil { t.Fatalf("Test %d: %s: Failed reading response body: <ERROR> %v", i+1, instanceType, err) } if rec.Code == http.StatusOK || rec.Code == http.StatusPartialContent { if !bytes.Equal(testCase.expectedContent, actualContent) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
} func (b *Builder) loadCachedVet(a *Action) error { c := cache.Default() list, _, err := cache.GetBytes(c, cache.Subkey(a.actionID, "srcfiles")) if err != nil { return fmt.Errorf("reading srcfiles list: %w", err) } var srcfiles []string for _, name := range strings.Split(string(list), "\n") { if name == "" { // end of list continue } if strings.HasPrefix(name, "./") {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
val response = call.execute() val inputStream = response.body.byteStream() assertThat(inputStream.read().toChar()).isEqualTo('A') call.cancel() assertFailsWith<IOException> { // Reading 'B' may succeed if it's buffered. inputStream.read() // But 'C' shouldn't be buffered (the response is throttled) and this should fail. inputStream.read() } inputStream.close()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// failure case of services simply not having completed a list operation that can reasonably be expected to succeed. // One common case this prevents is a kubelet restart reading pods before services and some pod not having the // KUBERNETES_SERVICE_HOST injected because we didn't wait a short time for services to sync before proceeding.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)