Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 74 for read_bytes (0.09 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/url/-Url.kt

          } else {
            encodedCharBuffer.writeString(input, i, i + Character.charCount(codePoint), charset)
          }
    
          while (!encodedCharBuffer.exhausted()) {
            val b = encodedCharBuffer.readByte().toInt() and 0xff
            writeByte('%'.code)
            writeByte(HEX_DIGITS[b shr 4 and 0xf].code)
            writeByte(HEX_DIGITS[b and 0xf].code)
          }
        } else {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 09 12:33:05 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader.go

    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    	// Read until next line.
    	in, err := r.buf.ReadBytes('\n')
    	dst = append(dst, in...)
    	return dst, err
    }
    
    // csvSplitSize is the size of each block.
    // Blocks will read this much and find the first following newline.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_gen.go

    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *xlMetaBuf) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 []byte
    		zb0001, err = dc.ReadBytes([]byte((*z)))
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = xlMetaBuf(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/io/FileUtil.java

            }
        }
    
        /**
         * ファイルの内容をバイト配列に読み込んで返します。
         *
         * @param file
         *            ファイル。{@literal null}であってはいけません
         * @return ファイルの内容を読み込んだバイト配列
         */
        public static byte[] readBytes(final File file) {
            assertArgumentNotNull("file", file);
    
            final FileInputStream is = InputStreamUtil.create(file);
            try {
                final FileChannel channel = is.getChannel();
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt

        byteCount: Long,
        sink: BufferedSink,
      ) {
        var node = root
        var accumulator = 0
        var accumulatorBitCount = 0
        for (i in 0 until byteCount) {
          val byteIn = source.readByte() and 0xff
          accumulator = accumulator shl 8 or byteIn
          accumulatorBitCount += 8
          while (accumulatorBitCount >= 8) {
            val childIndex = (accumulator ushr (accumulatorBitCount - 8)) and 0xff
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. internal/ringbuffer/ring_buffer.go

    		c2 := n - c1
    		copy(p[c1:], r.buf[0:c2])
    	}
    	r.r = (r.r + n) % r.size
    
    	r.isFull = false
    
    	return n, r.readErr(true)
    }
    
    // ReadByte reads and returns the next byte from the input or ErrIsEmpty.
    func (r *RingBuffer) ReadByte() (b byte, err error) {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if err = r.readErr(true); err != nil {
    		return 0, err
    	}
    	for r.w == r.r && !r.isFull {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/LittleEndianDataInputStream.java

      @Override
      public char readChar() throws IOException {
        return (char) readUnsignedShort();
      }
    
      @CanIgnoreReturnValue // to skip a byte
      @Override
      public byte readByte() throws IOException {
        return (byte) readUnsignedByte();
      }
    
      @CanIgnoreReturnValue // to skip a byte
      @Override
      public boolean readBoolean() throws IOException {
        return readUnsignedByte() != 0;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  8. cmd/storage-datatypes_gen.go

    		return
    	}
    	if dc.IsNil() {
    		err = dc.ReadNil()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		z.Data = nil
    	} else {
    		z.Data, err = dc.ReadBytes(z.Data)
    		if err != nil {
    			err = msgp.WrapError(err, "Data")
    			return
    		}
    		if z.Data == nil {
    			z.Data = make([]byte, 0)
    		}
    	}
    	z.NumVersions, err = dc.ReadInt()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/hash/BloomFilter.java

          // add non-stateless strategies (for which we've reserved negative ordinals; see
          // Strategy.ordinal()).
          strategyOrdinal = din.readByte();
          numHashFunctions = UnsignedBytes.toInt(din.readByte());
          dataLength = din.readInt();
    
          Strategy strategy = BloomFilterStrategies.values()[strategyOrdinal];
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v1_gen.go

    				zb0002, err = dc.ReadUint()
    				if err != nil {
    					err = msgp.WrapError(err, "Algorithm")
    					return
    				}
    				z.Algorithm = BitrotAlgorithm(zb0002)
    			}
    		case "Hash":
    			z.Hash, err = dc.ReadBytes(z.Hash)
    			if err != nil {
    				err = msgp.WrapError(err, "Hash")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top