Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 399 for nbuf (0.02 seconds)

  1. internal/handlers/forwarder.go

    	}
    
    	return f
    }
    
    type bufPool struct {
    	sz   int
    	pool bpool.Pool[*[]byte]
    }
    
    func (b *bufPool) Put(buf []byte) {
    	if cap(buf) < b.sz || cap(buf) > b.sz*2 {
    		// Buffer too small or will likely leak memory after being expanded.
    		// Drop it.
    		return
    	}
    	b.pool.Put(&buf)
    }
    
    func (b *bufPool) Get() []byte {
    	bufp := b.pool.Get()
    	if bufp == nil || cap(*bufp) < b.sz {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/job/SuggestJob.java

            buf.append("WEB-INF");
            buf.append(File.separator);
            buf.append("env");
            buf.append(File.separator);
            buf.append(getExecuteType());
            buf.append(File.separator);
            buf.append("resources");
            buf.append(cpSeparator);
            // WEB-INF/classes
            buf.append("WEB-INF");
            buf.append(File.separator);
            buf.append("classes");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiItem.java

        public String toLineString() {
            final StringBuilder buf = new StringBuilder(100);
            if (isUpdated()) {
                buf.append(quoteEscape(newToken));
                buf.append(',');
                buf.append(quoteEscape(newSegmentation));
                buf.append(',');
                buf.append(quoteEscape(newReading));
                buf.append(',');
                buf.append(quoteEscape(newPos));
            } else {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  4. cmd/xl-storage-format-utils.go

    	var fi FileInfo
    	var err error
    	var inData xlMetaInlineData
    	if buf, data, e := isIndexedMetaV2(xlMetaBuf); e != nil {
    		return FileInfo{}, e
    	} else if buf != nil {
    		inData = data
    		fi, err = buf.ToFileInfo(volume, path, versionID, true)
    		if len(buf) != 0 && errors.Is(err, errFileNotFound) {
    			// This special case is needed to handle len(xlMeta.versions) == 0
    			return FileInfo{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/session/Smb2LogoffRequestTest.java

            Smb2LogoffRequest req = newRequest();
            byte[] buf = new byte[offset + 8]; // extra space for safety
    
            // Act
            int written = req.writeBytesWireFormat(buf, offset);
    
            // Assert: should write exactly 4 bytes
            assertEquals(4, written, "Should report 4 bytes written");
            // StructureSize (2 bytes, LE) == 4
            assertEquals(4, SMBUtil.readInt2(buf, offset));
            // Reserved (2 bytes, LE) == 0
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

            buf.append("WEB-INF");
            buf.append(File.separator);
            buf.append("env");
            buf.append(File.separator);
            buf.append(getExecuteType());
            buf.append(File.separator);
            buf.append("resources");
            buf.append(cpSeparator);
            // WEB-INF/classes
            buf.append("WEB-INF");
            buf.append(File.separator);
            buf.append("classes");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  7. cmd/bitrot-whole.go

    	buf        []byte          // Holds bit-rot verified data
    }
    
    func (b *wholeBitrotReader) ReadAt(buf []byte, offset int64) (n int, err error) {
    	if b.buf == nil {
    		b.buf = make([]byte, b.tillOffset-offset)
    		if _, err := b.disk.ReadFile(context.TODO(), b.volume, b.filePath, offset, b.buf, b.verifier); err != nil {
    			return 0, err
    		}
    	}
    	if len(b.buf) < len(buf) {
    		return 0, errLessData
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

         */
        private StringBuilder createStringBuffer(final Object keyObj, final long time) {
            final StringBuilder buf = new StringBuilder(1000);
            buf.append("url:").append(getUrl(keyObj));
            buf.append('\t');
            buf.append("time:").append(FessFunctions.formatDate(new Date(time)));
            return buf;
        }
    
        /**
         * Extracts the URL string from a crawler object for logging purposes.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 17.4K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb1/dcerpc/DcerpcMessage.java

        void encode_header(final NdrBuffer buf) {
            buf.enc_ndr_small(5); /* RPC version */
            buf.enc_ndr_small(0); /* minor version */
            buf.enc_ndr_small(ptype);
            buf.enc_ndr_small(flags);
            buf.enc_ndr_long(0x00000010); /* Little-endian / ASCII / IEEE */
            buf.enc_ndr_short(length);
            buf.enc_ndr_short(0); /* length of auth_value */
            buf.enc_ndr_long(call_id);
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  10. cmd/streaming-v4-unsigned.go

    // the incoming AWS Signature V4 streaming signature.
    func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) {
    	// First, if there is any unread data, copy it to the client
    	// provided buffer.
    	if cr.offset > 0 {
    		n = copy(buf, cr.buffer[cr.offset:])
    		if n == len(buf) {
    			cr.offset += n
    			return n, nil
    		}
    		cr.offset = 0
    		buf = buf[n:]
    	}
    	// mustRead reads from input and compares against provided slice.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
Back to Top