okio.Buffer.writeInt()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(111)

本文整理了Java中okio.Buffer.writeInt()方法的一些代码示例,展示了Buffer.writeInt()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Buffer.writeInt()方法的具体详情如下:
包路径:okio.Buffer
类名称:Buffer
方法名:writeInt

Buffer.writeInt介绍

暂无

代码示例

代码示例来源:origin: square/okio

@Override public long read(Buffer sink, long byteCount) throws IOException {
 if (bytesLeft == -1L) throw new IllegalStateException("closed");
 if (bytesLeft == 0L) return -1L;
 if (byteCount > Integer.MAX_VALUE) byteCount = Integer.MAX_VALUE;
 if (byteCount > bytesLeft) byteCount = bytesLeft;
 // Random is most efficient when computing 32 bits of randomness. Start with that.
 int ints = (int) (byteCount / 4);
 for (int i = 0; i < ints; i++) {
  sink.writeInt(random.nextInt());
 }
 // If we need 1, 2, or 3 bytes more, keep going. We'll discard 24, 16 or 8 random bits!
 int bytes = (int) (byteCount - ints * 4);
 if (bytes > 0) {
  int bits = random.nextInt();
  for (int i = 0; i < bytes; i++) {
   sink.writeByte(bits & 0xff);
   bits >>>= 8;
  }
 }
 bytesLeft -= byteCount;
 return byteCount;
}

代码示例来源:origin: square/okio

@Test public void gunzipWhenCRCIncorrect() {
 Buffer gzipped = new Buffer();
 gzipped.write(gzipHeader);
 gzipped.write(deflated);
 gzipped.writeInt(TestUtil.reverseBytes(0x1234567)); // wrong CRC
 gzipped.write(gzipTrailer.toByteArray(), 3, 4);
 try {
  gunzip(gzipped);
  fail();
 } catch (IOException e) {
  assertEquals("CRC: actual 0x37ad8f8d != expected 0x01234567", e.getMessage());
 }
}

代码示例来源:origin: square/okio

@Test public void gunzipWhenLengthIncorrect() {
 Buffer gzipped = new Buffer();
 gzipped.write(gzipHeader);
 gzipped.write(deflated);
 gzipped.write(gzipTrailer.toByteArray(), 0, 4);
 gzipped.writeInt(TestUtil.reverseBytes(0x123456)); // wrong length
 try {
  gunzip(gzipped);
  fail();
 } catch (IOException e) {
  assertEquals("ISIZE: actual 0x00000020 != expected 0x00123456", e.getMessage());
 }
}

代码示例来源:origin: huxq17/tractor

@Override public BufferedSink writeInt(int i) throws IOException {
 if (closed) throw new IllegalStateException("closed");
 buffer.writeInt(i);
 return emitCompleteSegments();
}

代码示例来源:origin: huxq17/tractor

@Override public Buffer writeIntLe(int i) {
 return writeInt(Util.reverseBytesInt(i));
}

代码示例来源:origin: huxq17/tractor

private void writeHeader() {
 // Write the Gzip header directly into the buffer for the sink to avoid handling IOException.
 Buffer buffer = this.sink.buffer();
 buffer.writeShort(0x1f8b); // Two-byte Gzip ID.
 buffer.writeByte(0x08); // 8 == Deflate compression method.
 buffer.writeByte(0x00); // No flags.
 buffer.writeInt(0x00); // No modification time.
 buffer.writeByte(0x00); // No extra flags.
 buffer.writeByte(0x00); // No OS.
}

代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch-http

break;
case I32:
 buffer.writeInt(Integer.parseInt(number));
 break;
case I64:

相关文章