本文整理了Java中net.openhft.chronicle.bytes.Bytes.writeByte()
方法的一些代码示例,展示了Bytes.writeByte()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bytes.writeByte()
方法的具体详情如下:
包路径:net.openhft.chronicle.bytes.Bytes
类名称:Bytes
方法名:writeByte
暂无
代码示例来源:origin: OpenHFT/Chronicle-Queue
private void doRollback(boolean interrupted) {
if (interrupted)
LOG.warn("Thread is interrupted. Can't guarantee complete message, so not committing");
// zero out all contents...
for (long i = position; i <= wire.bytes().writePosition(); i++)
wire.bytes().writeByte(i, (byte) 0);
position = lastPosition;
wire.bytes().writePosition(position);
((AbstractWire) wire).forceNotInsideHeader();
}
代码示例来源:origin: net.openhft/chronicle-map
@Override
public void write(Bytes out, @NotNull Boolean toWrite) {
out.writeByte((byte) (toWrite ? 'Y' : 0));
}
代码示例来源:origin: net.openhft/chronicle-bytes
public static void setCharAt(@NotNull Appendable sb, int index, char ch)
throws IllegalArgumentException, BufferOverflowException {
if (sb instanceof StringBuilder)
((StringBuilder) sb).setCharAt(index, ch);
else if (sb instanceof Bytes)
((Bytes) sb).writeByte(index, ch);
else
throw new IllegalArgumentException("" + sb.getClass());
}
代码示例来源:origin: net.openhft/chronicle-bytes
default void read(@NotNull Bytes bytes, int length) {
int len2 = (int) Math.min(length, readRemaining());
for (int i = 0; i < len2; i++)
bytes.writeByte(readByte());
}
代码示例来源:origin: net.openhft/chronicle-map
private void writePayload(Bytes payload, Bytes destination) {
destination.writeByte(BOOTSTRAP_TIME_HUNK);
destination.write(payload, payload.readPosition(), payload.readRemaining());
}
代码示例来源:origin: com.wavefront/proxy
@Override
public void write(Bytes out, @NotNull HistogramKey toWrite) {
int accumulatorKeySize = 5;
out.writeByte(toWrite.granularityOrdinal);
out.writeInt(toWrite.binId);
accumulatorKeySize += 2 + toWrite.metric.length();
writeString(out, toWrite.metric);
accumulatorKeySize += 2 + (toWrite.source == null ? 0 : toWrite.source.length());
writeString(out, toWrite.source);
short numTags = toWrite.tags == null ? 0 : (short) toWrite.tags.length;
accumulatorKeySize += 2;
out.writeShort(numTags);
for (short i = 0; i < numTags; ++i) {
accumulatorKeySize += 2 + (toWrite.tags[i] == null ? 0 : toWrite.tags[i].length());
writeString(out, toWrite.tags[i]);
}
accumulatorKeySizes.update(accumulatorKeySize);
}
}
代码示例来源:origin: wavefrontHQ/java
@Override
public void write(Bytes out, @NotNull HistogramKey toWrite) {
int accumulatorKeySize = 5;
out.writeByte(toWrite.granularityOrdinal);
out.writeInt(toWrite.binId);
accumulatorKeySize += 2 + toWrite.metric.length();
writeString(out, toWrite.metric);
accumulatorKeySize += 2 + (toWrite.source == null ? 0 : toWrite.source.length());
writeString(out, toWrite.source);
short numTags = toWrite.tags == null ? 0 : (short) toWrite.tags.length;
accumulatorKeySize += 2;
out.writeShort(numTags);
for (short i = 0; i < numTags; ++i) {
accumulatorKeySize += 2 + (toWrite.tags[i] == null ? 0 : toWrite.tags[i].length());
writeString(out, toWrite.tags[i]);
}
accumulatorKeySizes.update(accumulatorKeySize);
}
}
代码示例来源:origin: net.openhft/chronicle-map
void updateReplicationState(byte identifier, long timestamp) {
initDelayedUpdateChecksum(true);
Bytes segmentBytes = s.segmentBytesForWrite();
segmentBytes.writePosition(replicationBytesOffset);
segmentBytes.writeLong(timestamp);
segmentBytes.writeByte(identifier);
}
代码示例来源:origin: net.openhft/chronicle-queue
private void doRollback(boolean interrupted) {
if (interrupted)
LOG.warn("Thread is interrupted. Can't guarantee complete message, so not committing");
// zero out all contents...
for (long i = position; i <= wire.bytes().writePosition(); i++)
wire.bytes().writeByte(i, (byte) 0);
position = lastPosition;
wire.bytes().writePosition(position);
((AbstractWire) wire).forceNotInsideHeader();
}
代码示例来源:origin: net.openhft/chronicle-map
void updateReplicationState(byte identifier, long timestamp) {
initDelayedUpdateChecksum(true);
Bytes segmentBytes = this.segmentBytesForWriteGuarded();
segmentBytes.writePosition(replicationBytesOffset());
segmentBytes.writeLong(timestamp);
segmentBytes.writeByte(identifier);
}
代码示例来源:origin: net.openhft/chronicle-map
void updateReplicationState(byte identifier, long timestamp) {
initDelayedUpdateChecksum(true);
Bytes segmentBytes = this.segmentBytesForWriteGuarded();
segmentBytes.writePosition(replicationBytesOffset());
segmentBytes.writeLong(timestamp);
segmentBytes.writeByte(identifier);
}
代码示例来源:origin: net.openhft/chronicle-bytes
default void readWithLength(Bytes bytes) {
bytes.clear();
int length = Maths.toUInt31(readStopBit());
int i;
for (i = 0; i < length - 7; i++)
bytes.writeLong(readLong());
for (; i < length; i++)
bytes.writeByte(readByte());
}
代码示例来源:origin: net.openhft/chronicle-bytes
@org.jetbrains.annotations.NotNull
public static Bytes fromHexString(@org.jetbrains.annotations.NotNull String s) {
try {
Bytes in = Bytes.from(s);
Bytes out = Bytes.elasticByteBuffer();
OUTER:
while (in.readRemaining() > 0) {
in.parseHexLong();
for (int i = 0; i < 16; i++) {
if (in.peekUnsignedByte() == ' ') {
in.readSkip(1);
if (in.peekUnsignedByte() == ' ')
break OUTER;
}
long value = in.parseHexLong();
out.writeByte((byte) value);
}
if (in.readByte(in.readPosition() - 1) <= ' ')
in.readSkip(-1);
in.skipTo(StopCharTesters.CONTROL_STOP);
}
return out;
} catch (BufferUnderflowException | BufferOverflowException e) {
throw new AssertionError(e);
}
}
代码示例来源:origin: net.openhft/chronicle-map
destination.writeByte(ENTRY_HUNK);
destination.writeByte(entry.originIdentifier());
内容来源于网络,如有侵权,请联系作者删除!