- Sort Score
- Result 10 results
- Languages All
Results 281 - 290 of 1,188 for rheader (0.04 sec)
-
cmd/healthcheck-handler.go
DeploymentType: r.Form.Get("deployment-type"), } result := objLayer.Health(ctx, opts) w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum)) w.Header().Set(xhttp.MinIOStorageClassDefaults, strconv.FormatBool(result.UsingDefaults)) // return how many drives are being healed if any if result.HealingDrives > 0 { w.Header().Set(xhttp.MinIOHealingDrives, strconv.Itoa(result.HealingDrives)) } if !result.Healthy {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/kuromoji/index/analysis/KuromojiIterationMarkCharFilterFactory.java
normalizeKana = settings.getAsBoolean("normalize_kana", JapaneseIterationMarkCharFilter.NORMALIZE_KANA_DEFAULT); } @Override public Reader create(Reader reader) { return new JapaneseIterationMarkCharFilter(reader, normalizeKanji, normalizeKana); }
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sat Mar 15 06:51:20 UTC 2025 - 1.8K bytes - Viewed (1) -
src/main/java/org/codelibs/core/io/FileUtil.java
} /** * Returns the contents read from the reader as a string. * * @param reader * the reader * @param initialCapacity * the initial buffer capacity * @return the string read from the reader */ protected static String read(final Reader reader, final int initialCapacity) { int bufferSize;
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 8.8K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/XmlFactory.java
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Apr 05 11:52:05 UTC 2025 - 3.9K bytes - Viewed (0) -
okhttp-zstd/src/test/java/okhttp3/zstd/ZstdInterceptorTest.kt
val s = "hello zstd world".encodeUtf8().zstdCompress() val response = response("https://example.com/", s) { header("Content-Encoding", "zstd") } val decompressed = zstdInterceptor.decompress(response) assertThat(decompressed.header("Content-Encoding")).isNull() val responseString = decompressed.body.string() assertThat(responseString).isEqualTo("hello zstd world") }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Aug 01 06:04:22 UTC 2025 - 4.8K bytes - Viewed (1) -
cmd/storage-rest-client.go
return *resp, nil } // where we keep old *Readers var readMsgpReaderPool = bpool.Pool[*msgp.Reader]{New: func() *msgp.Reader { return &msgp.Reader{} }} // mspNewReader returns a *Reader that reads from the provided reader. // The reader will be buffered. // Return with readMsgpReaderPoolPut when done. func msgpNewReader(r io.Reader) *msgp.Reader { p := readMsgpReaderPool.Get() if p.R == nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 08 02:38:41 UTC 2025 - 30.4K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/group/admin_group_details.jsp
<%-- Card Header --%> <div class="card-header"> <jsp:include page="/WEB-INF/view/common/admin/crud/header.jsp"></jsp:include> </div> <%-- Card Body --%>
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Feb 13 07:47:04 UTC 2020 - 4K bytes - Viewed (0) -
cmd/object-handlers_test.go
} readers := []io.Reader{} cumulativeSum := int64(0) for _, p := range oi.partLengths { readers = append(readers, NewDummyDataGen(p, cumulativeSum)) cumulativeSum += p } refReader := io.LimitReader(ioutilx.NewSkipReader(io.MultiReader(readers...), off), length) if ok, msg := cmpReaders(refReader, rec.Body); !ok {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 163.1K bytes - Viewed (0) -
cmd/object-handlers-common_test.go
recorder := httptest.NewRecorder() request := httptest.NewRequest(http.MethodHead, "/bucket/a", bytes.NewReader([]byte{})) request.Header.Set(xhttp.IfNoneMatch, tc.ifNoneMatch) request.Header.Set(xhttp.IfModifiedSince, tc.ifModifiedSince) request.Header.Set(xhttp.IfMatch, tc.ifMatch) request.Header.Set(xhttp.IfUnmodifiedSince, tc.ifUnmodifiedSince) actualFlag := checkPreconditions(t.Context(), recorder, request, tc.objInfo, ObjectOptions{})
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 5.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/BaseEncodingTest.java
// of // InputStream.read(byte[], int, int) // See https://github.com/google/guava/issues/3542 Reader reader = new StringReader(cannotDecode); InputStream decodingStream = encoding.decodingStream(reader); try { ByteStreams.exhaust(decodingStream); fail("Expected DecodingException"); } catch (DecodingException expected) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 24.7K bytes - Viewed (0)