Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 303 for buf2 (0.04 sec)

  1. guava/src/com/google/common/io/ByteStreams.java

          byte[] buf = new byte[min(bufSize, MAX_ARRAY_LEN - totalLen)];
          bufs.add(buf);
          int off = 0;
          while (off < buf.length) {
            // always OK to fill buf; its size plus the rest of bufs is never more than MAX_ARRAY_LEN
            int r = in.read(buf, off, buf.length - off);
            if (r == -1) {
              return combineBuffers(bufs, totalLen);
            }
            off += r;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  2. internal/ioutil/ioutil.go

    	}
    
    	var written int64
    	for {
    		buf := alignedBuf
    		if totalSize > 0 {
    			remaining := totalSize - written
    			if remaining < int64(len(buf)) {
    				buf = buf[:remaining]
    			}
    		}
    
    		nr, err := io.ReadFull(r, buf)
    		eof := errors.Is(err, io.EOF) || errors.Is(err, io.ErrUnexpectedEOF)
    		if err != nil && !eof {
    			return written, err
    		}
    
    		buf = buf[:nr]
    		var (
    			n  int
    			un int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  3. cmd/os_unix.go

    		}
    
    	}
    	defer syscall.Close(fd)
    
    	bufp := direntPool.Get().(*[]byte)
    	defer direntPool.Put(bufp)
    	buf := *bufp
    
    	boff := 0 // starting read position in buf
    	nbuf := 0 // end valid data in buf
    
    	for {
    		if boff >= nbuf {
    			boff = 0
    			stop := globalOSMetrics.time(osMetricReadDirent)
    			nbuf, err = syscall.ReadDirent(fd, buf)
    			stop()
    			if err != nil {
    				if isSysErrNotDir(err) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  4. internal/ioutil/ioutil_test.go

    		t.Errorf("Error creating tmp file: %v", err)
    	}
    	defer f.Close()
    	defer os.Remove(f.Name())
    
    	r := strings.NewReader("hello world")
    
    	bufp := ODirectPoolSmall.Get().(*[]byte)
    	defer ODirectPoolSmall.Put(bufp)
    
    	written, err := CopyAligned(f, io.LimitReader(r, 5), *bufp, r.Size(), f)
    	if !errors.Is(err, io.ErrUnexpectedEOF) {
    		t.Errorf("Expected io.ErrUnexpectedEOF, but got %v", err)
    	}
    	if written != 5 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    	stat, err := f.Stat()
    	if err != nil {
    		buf, err = io.ReadAll(f)
    		return buf, dmTime, osErrToFileErr(err)
    	}
    	if stat.IsDir() {
    		return nil, dmTime, errFileNotFound
    	}
    
    	// Read into appropriate buffer.
    	sz := stat.Size()
    	if sz <= metaDataReadDefault {
    		buf = metaDataPoolGet()
    		buf = buf[:sz]
    	} else {
    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    		// We use 2 buffers, so we always have a full buffer of input.
    		pool := globalBytePoolCap.Load()
    		bufA := pool.Get()
    		bufB := pool.Get()
    		defer pool.Put(bufA)
    		defer pool.Put(bufB)
    		ra, err := readahead.NewReaderBuffer(data, [][]byte{bufA[:fi.Erasure.BlockSize], bufB[:fi.Erasure.BlockSize]})
    		if err == nil {
    			toEncode = ra
    			defer ra.Close()
    		}
    		bugLogIf(ctx, err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    	bufp := poolBuf8k.Get().(*[]byte)
    	buf := *bufp
    	defer poolBuf8k.Put(bufp)
    	for {
    		_, err := io.ReadFull(respBody, tmp[:])
    		if err != nil {
    			return err
    		}
    		// Check if we have a response ready or a filler byte.
    		switch tmp[0] {
    		case 0:
    			// 0 is unbuffered, copy the rest.
    			_, err := io.CopyBuffer(w, respBody, buf)
    			if err == io.EOF {
    				return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/dcerpc/DcerpcMessage.java

    
        void encode_header ( NdrBuffer buf ) {
            buf.enc_ndr_small(5); /* RPC version */
            buf.enc_ndr_small(0); /* minor version */
            buf.enc_ndr_small(this.ptype);
            buf.enc_ndr_small(this.flags);
            buf.enc_ndr_long(0x00000010); /* Little-endian / ASCII / IEEE */
            buf.enc_ndr_short(this.length);
            buf.enc_ndr_short(0); /* length of auth_value */
            buf.enc_ndr_long(this.call_id);
        }
    
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                buf.append(',');
                buf.append("\"page_number\":");
                buf.append(currentPageNumber);
                buf.append(',');
                buf.append("\"record_count\":");
                buf.append(allRecordCount);
                buf.append(',');
                buf.append("\"record_count_relation\":");
                buf.append(escapeJson(allRecordCountRelation));
                buf.append(',');
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 50.3K bytes
    - Viewed (0)
  10. cmd/data-usage-cache_gen_test.go

    	v := allTierStats{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeallTierStats Msgsize() is inaccurate")
    	}
    
    	vn := allTierStats{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 19K bytes
    - Viewed (0)
Back to top