sander/exceptional
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

renaming

Browse source
This commit is contained in:
Shautvast 2024-06-30 13:21:37 +02:00
parent 66c3a0f315
commit d5823837e4
1 changed files with 24 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
lib/src/main/java/com/github/shautvast/exceptional/CircularByteBuffer.java
View file

@ -20,13 +20,15 @@ import java.util.stream.IntStream;
* for reader/writer index deal with the offset value, so that the index (as method local variable) does not * for reader/writer index deal with the offset value, so that the index (as method local variable) does not
* include it (ie starting at 0). This simplifies the calculations that include these indices. Same goes for the * include it (ie starting at 0). This simplifies the calculations that include these indices. Same goes for the
* capacity. * capacity.
*
*/ */
//TODO put READ WRITE indices at the end
@SuppressWarnings("StringTemplateMigration") @SuppressWarnings("StringTemplateMigration")
public class CircularByteBuffer { public class CircularByteBuffer {
public static final int READ = 0; public static final int READ_POS = 0;
public static final int WRITE = 4; public static final int WRITE_POS = 4;
public static final int START = 8; public static final int PAYLOADSTART_POS = 8;
final ByteBuffer data; final ByteBuffer data;
/** /**
@ -36,9 +38,9 @@ public class CircularByteBuffer {
* @param capacity the capacity of the CircularByteBuffer * @param capacity the capacity of the CircularByteBuffer
*/ */
public CircularByteBuffer(int capacity) { public CircularByteBuffer(int capacity) {
data = ByteBuffer.allocate(capacity + START); // 8 extra for the read and write index data = ByteBuffer.allocate(capacity + PAYLOADSTART_POS); // 8 extra for the read and write index
data.putInt(READ, START); data.putInt(READ_POS, PAYLOADSTART_POS);
data.putInt(WRITE, START); data.putInt(WRITE_POS, PAYLOADSTART_POS);
} }
/** /**
@ -108,7 +110,7 @@ public class CircularByteBuffer {
} }
private int capacity() { private int capacity() {
return data.capacity() - START; return data.capacity() - PAYLOADSTART_POS;
} }
/** /**
@ -153,60 +155,60 @@ public class CircularByteBuffer {
} }
private void get(int readIndex, byte[] result, int offset, int len) { private void get(int readIndex, byte[] result, int offset, int len) {
data.get(readIndex + START, result, offset, len); data.get(readIndex + PAYLOADSTART_POS, result, offset, len);
} }
private void get(int readIndex, byte[] result) { private void get(int readIndex, byte[] result) {
data.get(readIndex + START, result); data.get(readIndex + PAYLOADSTART_POS, result);
} }
private short getShort(int readIndex) { private short getShort(int readIndex) {
return data.getShort(readIndex + START); return data.getShort(readIndex + PAYLOADSTART_POS);
} }
private byte get(int readIndex) { private byte get(int readIndex) {
return data.get(readIndex + START); return data.get(readIndex + PAYLOADSTART_POS);
} }
int getWriteIndex() { int getWriteIndex() {
return this.data.getInt(WRITE) - START; return this.data.getInt(WRITE_POS) - PAYLOADSTART_POS;
} }
void setWriteIndex(int writeIndex) { void setWriteIndex(int writeIndex) {
this.data.putInt(WRITE, writeIndex + START); this.data.putInt(WRITE_POS, writeIndex + PAYLOADSTART_POS);
} }
int getReadIndex() { int getReadIndex() {
return this.data.getInt(READ) - START; return this.data.getInt(READ_POS) - PAYLOADSTART_POS;
} }
void setReadIndex(int readIndex) { void setReadIndex(int readIndex) {
this.data.putInt(READ, readIndex + START); this.data.putInt(READ_POS, readIndex + PAYLOADSTART_POS);
} }
void putShort(int index, short value) { void putShort(int index, short value) {
this.data.putShort(index + START, value); this.data.putShort(index + PAYLOADSTART_POS, value);
} }
void put(int index, byte value) { void put(int index, byte value) {
this.data.put(index + START, value); this.data.put(index + PAYLOADSTART_POS, value);
} }
void put(int index, byte[] value) { void put(int index, byte[] value) {
this.data.put(index + START, value); this.data.put(index + PAYLOADSTART_POS, value);
} }
private void put(int writeIndex, byte[] bytes, int offset, int len) { private void put(int writeIndex, byte[] bytes, int offset, int len) {
data.put(writeIndex + START, bytes, offset, len - offset); data.put(writeIndex + PAYLOADSTART_POS, bytes, offset, len - offset);
} }
@Override @Override
public String toString() { public String toString() {
return "CircularByteBuffer {r=" + this.data.getInt(READ) + return "CircularByteBuffer {r=" + this.data.getInt(READ_POS) +
", w=" + ", w=" +
this.data.getInt(WRITE) + this.data.getInt(WRITE_POS) +
", data=" + ", data=" +
IntStream.range(READ, this.data.array().length) IntStream.range(READ_POS, this.data.array().length)
.map(x -> this.data.array()[x]) .map(x -> this.data.array()[x])
.mapToObj(Integer::toString) .mapToObj(Integer::toString)
.collect(Collectors.joining(",", "[", "]")) + .collect(Collectors.joining(",", "[", "]")) +