Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 304 for buf1 (0.05 sec)

  1. 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)
  2. 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(&current)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  3. 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)
  4. src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java

                                final StringBuilder buf = new StringBuilder(1000);
                                buf.append("[SEARCH TIMEOUT] {\"exec_time\":").append(execTime)//
                                        .append(",\"request\":").append(searchRequestBuilder.toString())//
                                        .append(",\"response\":").append(r.toString()).append('}');
                                logger.warn(buf.toString());
                            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jul 22 06:56:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. internal/http/request-recorder.go

    // RequestRecorder - records the
    // of a given io.Reader
    type RequestRecorder struct {
    	// Data source to record
    	io.Reader
    	// Response body should be logged
    	LogBody bool
    
    	// internal recording buffer
    	buf bytes.Buffer
    	// total bytes read including header size
    	bytesRead int
    }
    
    // Close is a no operation closer
    func (r *RequestRecorder) Close() error {
    	// no-op
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top