Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 285 for bufs (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. src/main/java/jcifs/smb1/dcerpc/DcerpcPipeHandle.java

            if (isStart && !isDirect) { // start of new frag, do trans
                off = in.read(buf, 0, 1024);
            } else {
                off = in.readDirect(buf, 0, buf.length);
            }
    
            if (buf[0] != 5 && buf[1] != 0) {
                throw new IOException("Unexpected DCERPC PDU header");
            }
    
            flags = buf[3] & 0xFF;
            // next read is start of new frag
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  6. cmd/config-common.go

    		}
    
    		return nil, ObjectInfo{}, err
    	}
    	defer r.Close()
    
    	buf, err := io.ReadAll(r)
    	if err != nil {
    		return nil, ObjectInfo{}, err
    	}
    	if len(buf) == 0 {
    		return nil, ObjectInfo{}, errConfigNotFound
    	}
    	return buf, r.ObjInfo, nil
    }
    
    func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) {
    	buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 3.1K bytes
    - Click Count (0)
  7. internal/ringbuffer/ring_buffer.go

    	if r.w == r.r {
    		if r.isFull {
    			buf := getDst(r.size)
    			copy(buf, r.buf[r.r:])
    			copy(buf[r.size-r.r:], r.buf[:r.w])
    			return buf
    		}
    		return nil
    	}
    
    	if r.w > r.r {
    		buf := getDst(r.w - r.r)
    		copy(buf, r.buf[r.r:r.w])
    		return buf
    	}
    
    	n := r.size - r.r + r.w
    	buf := getDst(n)
    
    	if r.r+n < r.size {
    		copy(buf, r.buf[r.r:r.r+n])
    	} else {
    		c1 := r.size - r.r
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  8. cmd/os-dirent_namelen_linux.go

    	nameBuf := (*[unsafe.Sizeof(dirent.Name)]byte)(unsafe.Pointer(&dirent.Name[0]))
    	const nameBufLen = uint16(len(nameBuf))
    	limit := dirent.Reclen - fixedHdr
    	if limit > nameBufLen {
    		limit = nameBufLen
    	}
    	// Avoid bugs in long file names
    	// https://github.com/golang/tools/commit/5f9a5413737ba4b4f692214aebee582b47c8be74
    	nameLen := bytes.IndexByte(nameBuf[:limit], 0)
    	if nameLen < 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 1.5K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/eventbus/Subscriber.java

      static Subscriber create(EventBus bus, Object listener, Method method) {
        return isDeclaredThreadSafe(method)
            ? new Subscriber(bus, listener, method)
            : new SynchronizedSubscriber(bus, listener, method);
      }
    
      /** The event bus this subscriber belongs to. */
      @Weak private final EventBus bus;
    
      /** The object with the subscriber method. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/hash/HashingOutputStreamTest.java

        byte[] buf = new byte[] {'y', 'a', 'm', 's'};
        HashingOutputStream out = new HashingOutputStream(hashFunction, buffer);
        out.write(buf);
    
        verify(hashFunction).newHasher();
        verify(hasher).putBytes(buf, 0, buf.length);
        verifyNoMoreInteractions(hashFunction, hasher);
      }
    
      public void testWrite_putByteArrayAtPos() throws Exception {
        byte[] buf = new byte[] {'y', 'a', 'm', 's'};
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 3.2K bytes
    - Click Count (0)
Back to Top