- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 304 for buf1 (0.04 sec)
-
cmd/metacache-stream.go
var current metacacheBlock var n int buf := bytebufferpool.Get() defer func() { buf.Reset() bytebufferpool.Put(buf) }() block := newMetacacheWriter(buf, 1<<20) defer block.Close() finishBlock := func() { if err := block.Close(); err != nil { w.streamErr = err return } current.data = buf.Bytes() w.streamErr = nextBlock(¤t)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ZipExtractor.java
final Map<String, String> map = new HashMap<>(); map.put(ExtractData.RESOURCE_NAME_KEY, filename); buf.append(extractor.getText(new IgnoreCloseInputStream(ais), map).getContent()); buf.append('\n'); } catch (final Exception e) { if (logger.isDebugEnabled()) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 4.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jul 22 06:56:21 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/xl-storage-format-utils_test.go
} else { versions = append(versions, fi) allVersionIDs = append(allVersionIDs, fi.VersionID) } } buf, err := xl.AppendTo(nil) if err != nil { t.Fatalf("Failed to serialize xlmeta %v", err) } fivs, err := getFileInfoVersions(buf, basefi.Volume, basefi.Name, false) if err != nil { t.Fatalf("getFileInfoVersions failed: %v", err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 7.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HuffmanTest.kt
for (i in s.indices) { assertRoundTrip(s.substring(0, i).encodeUtf8()) } val random = Random(123456789L) val buf = ByteArray(4096) random.nextBytes(buf) assertRoundTrip(buf.toByteString()) } private fun assertRoundTrip(data: ByteString) { val encodeBuffer = Buffer() encode(data, encodeBuffer)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Jan 04 05:32:07 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/xl-storage-format_test.go
b.Run("ToFileInfoNew", func(b *testing.B) { b.SetBytes(int64(size)) b.ResetTimer() b.ReportAllocs() for i := 0; i < b.N; i++ { buf, _, _ := isIndexedMetaV2(enc) if buf == nil { b.Fatal("buf == nil") } _, err = buf.ToFileInfo("volume", "path", ids[rng.Intn(size)], true) if err != nil { b.Fatal(err) } } })
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 17.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/TarExtractor.java
final Map<String, String> map = new HashMap<>(); map.put(ExtractData.RESOURCE_NAME_KEY, filename); buf.append(extractor.getText(new IgnoreCloseInputStream(ais), map).getContent()); buf.append('\n'); } catch (final Exception e) { if (logger.isDebugEnabled()) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/transformer/AbstractFessFileTransformer.java
// content final StringBuilder buf = new StringBuilder(content.length() + 1000); if (fessConfig.isCrawlerDocumentFileAppendBodyContent()) { buf.append(content); } if (fessConfig.isCrawlerDocumentFileAppendMetaContent()) { if (buf.length() > 0) { buf.append(' '); } buf.append(contentMeta); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 23.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/LabelTypeHelper.java
if (StringUtil.isNotBlank(normalizePath)) { buf.append(normalizePath); } } this.includedPaths = Pattern.compile(buf.toString()); } if (StringUtil.isNotBlank(excludedPaths)) { final StringBuilder buf = new StringBuilder(100); char split = 0;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/storage-rest-client.go
} // AppendFile - append to a file. func (client *storageRESTClient) AppendFile(ctx context.Context, volume string, path string, buf []byte) error { values := make(url.Values) values.Set(storageRESTVolume, volume) values.Set(storageRESTFilePath, path) reader := bytes.NewReader(buf) respBody, err := client.call(ctx, storageRESTMethodAppendFile, values, reader, -1) defer xhttp.DrainBody(respBody) return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0)