only:refactoring automatic logging prefix

This commit is contained in:
rusefillc 2023-07-08 20:10:46 -04:00
parent 2ec9b656f8
commit c2b2905b1a
6 changed files with 7 additions and 7 deletions

View File

@ -33,7 +33,7 @@ public class Elm327IoStream extends AbstractIoStream {
public Elm327IoStream(Elm327Connector con) {
this.con = con;
dataBuffer = createDataBuffer("elm327Stream");
dataBuffer = createDataBuffer();
// ByteBuffer inBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE);
outBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE);

View File

@ -13,8 +13,8 @@ public abstract class AbstractIoStream implements IoStream {
private final AtomicInteger bytesOut = new AtomicInteger();
private long latestActivity;
public IncomingDataBuffer createDataBuffer(String loggingPrefix) {
IncomingDataBuffer incomingData = new IncomingDataBuffer(loggingPrefix, getStreamStats());
public IncomingDataBuffer createDataBuffer() {
IncomingDataBuffer incomingData = new IncomingDataBuffer(getClass().getSimpleName(), getStreamStats());
setInputListener(incomingData::addData);
return incomingData;
}

View File

@ -23,7 +23,7 @@ public class BufferedSerialIoStream extends SerialIoStream {
*/
private BufferedSerialIoStream(SerialPort sp, String port) {
super(sp, port);
dataBuffer = createDataBuffer("[serial] ");
dataBuffer = createDataBuffer();
}
@Override

View File

@ -91,7 +91,7 @@ public class PCanIoStream extends AbstractIoStream {
private PCanIoStream(PCANBasic can, StatusConsumer statusListener) {
this.can = can;
this.statusListener = statusListener;
dataBuffer = createDataBuffer("[PCAN] ");
dataBuffer = createDataBuffer();
}
@Override

View File

@ -77,7 +77,7 @@ public class SocketCANIoStream extends AbstractIoStream {
throw new IllegalStateException("Error looking up", e);
}
// buffer could only be created once socket variable is not null due to callback
dataBuffer = createDataBuffer("[SocketCAN] ");
dataBuffer = createDataBuffer();
}
@Nullable

View File

@ -35,7 +35,7 @@ public class TcpIoStream extends AbstractIoStream {
this.socket = socket;
input = new BufferedInputStream(socket.getInputStream());
output = new BufferedOutputStream(socket.getOutputStream());
dataBuffer = createDataBuffer(loggingPrefix);
dataBuffer = createDataBuffer();
}
@NotNull