Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 380 for nbuf (0.03 sec)

  1. android/guava/src/com/google/common/io/LineReader.java

          Java8Compatibility.clear(cbuf);
          // The default implementation of Reader#read(CharBuffer) allocates a
          // temporary char[], so we call Reader#read(char[], int, int) instead.
          int read = (reader != null) ? reader.read(buf, 0, buf.length) : readable.read(cbuf);
          if (read == -1) {
            lineBuf.finish();
            break;
          }
          lineBuf.add(buf, 0, read);
        }
        return lines.poll();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/io/LineBufferTest.java

          @Override
          public int read(CharBuffer cbuf) throws IOException {
            return reader.read(cbuf);
          }
        };
      }
    
      private static Reader getChunkedReader(String input, final int chunk) {
        return new FilterReader(new StringReader(input)) {
          @Override
          public int read(char[] cbuf, int off, int len) throws IOException {
            return super.read(cbuf, off, min(chunk, len));
          }
        };
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/LineBufferTest.java

          @Override
          public int read(CharBuffer cbuf) throws IOException {
            return reader.read(cbuf);
          }
        };
      }
    
      private static Reader getChunkedReader(String input, final int chunk) {
        return new FilterReader(new StringReader(input)) {
          @Override
          public int read(char[] cbuf, int off, int len) throws IOException {
            return super.read(cbuf, off, min(chunk, len));
          }
        };
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. src/archive/zip/writer.go

    	// The approach here is to write 8 byte sizes if needed without
    	// adding a zip64 extra in the local header (too late anyway).
    	var buf []byte
    	if w.isZip64() {
    		buf = make([]byte, dataDescriptor64Len)
    	} else {
    		buf = make([]byte, dataDescriptorLen)
    	}
    	b := writeBuf(buf)
    	b.uint32(dataDescriptorSignature) // de-facto standard, required by OS X
    	b.uint32(w.CRC32)
    	if w.isZip64() {
    		b.uint64(w.CompressedSize64)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  5. internal/jwt/parser.go

    	}
    	headerDec := buf[:n]
    	buf = buf[n:]
    
    	alg, _, _, err := jsonparser.Get(headerDec, "alg")
    	if err != nil {
    		return nil, &jwtgo.ValidationError{Inner: err, Errors: jwtgo.ValidationErrorMalformed}
    	}
    
    	n, err = base64DecodeBytes(token[i+1:j], buf)
    	if err != nil {
    		return nil, &jwtgo.ValidationError{Inner: err, Errors: jwtgo.ValidationErrorMalformed}
    	}
    
    	if err = claims.UnmarshalJSON(buf[:n]); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        assertEquals(-1, empty.read());
      }
    
      public void testExhaust_readable() throws IOException {
        CharBuffer buf = CharBuffer.wrap(ASCII);
        assertEquals(ASCII.length(), CharStreams.exhaust(buf));
        assertEquals(0, buf.remaining());
        assertEquals(0, CharStreams.exhaust(buf));
    
        CharBuffer empty = CharBuffer.wrap("");
        assertEquals(0, CharStreams.exhaust(empty));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/CharStreamsTest.java

        assertEquals(-1, empty.read());
      }
    
      public void testExhaust_readable() throws IOException {
        CharBuffer buf = CharBuffer.wrap(ASCII);
        assertEquals(ASCII.length(), CharStreams.exhaust(buf));
        assertEquals(0, buf.remaining());
        assertEquals(0, CharStreams.exhaust(buf));
    
        CharBuffer empty = CharBuffer.wrap("");
        assertEquals(0, CharStreams.exhaust(empty));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  8. src/archive/tar/reader.go

    	buf, err := readSpecialFile(r)
    	if err != nil {
    		return nil, err
    	}
    	sbuf := string(buf)
    
    	// For GNU PAX sparse format 0.0 support.
    	// This function transforms the sparse format 0.0 headers into format 0.1
    	// headers since 0.0 headers were not PAX compliant.
    	var sparseMap []string
    
    	paxHdrs := make(map[string]string)
    	for len(sbuf) > 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  9. 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)
  10. src/bufio/bufio_test.go

    			// and that the data is correct.
    
    			w.Reset()
    			buf := NewWriterSize(w, bs)
    			context := fmt.Sprintf("nwrite=%d bufsize=%d", nwrite, bs)
    			n, e1 := buf.Write(data[0:nwrite])
    			if e1 != nil || n != nwrite {
    				t.Errorf("%s: buf.Write %d = %d, %v", context, nwrite, n, e1)
    				continue
    			}
    			if e := buf.Flush(); e != nil {
    				t.Errorf("%s: buf.Flush = %v", context, e)
    			}
    
    			written := w.Bytes()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
Back to top