rusefi
/
jSerialComm
mirror of https://github.com/rusefi/jSerialComm.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Block/loop until all bytes are written SerialOutputStream 

Ensures that the write methods of SerialOutputStream fulfill their
contract by acknowledging the possibility that not all bytes could be
written in the first call to native writeBytes() and looping until all
bytes have been written.
This commit is contained in:
Kevin Herron 2017-04-30 06:48:46 -07:00
parent 6edf6f9396
commit df4a8b7cb8
1 changed files with 36 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
src/main/java/com/fazecast/jSerialComm/SerialPort.java
View File

@ -1107,23 +1107,50 @@ public final class SerialPort
@Override
public final void write(int b) throws IOException
{
if (!isOpened)
throw new IOException("This port appears to have been shutdown or disconnected.");
int bytesWritten = 0;
singleByteBuffer[0] = (byte) (b & 0xFF);
do {
if (!isOpened)
throw new IOException("This port appears to have been shutdown or disconnected.");
if (writeBytes(portHandle, singleByteBuffer, 1L) < 0)
throw new IOException("This port appears to have been shutdown or disconnected.");
singleByteBuffer[0] = (byte) (b & 0xFF);
bytesWritten += writeBytes(portHandle, singleByteBuffer, 1L);
if (bytesWritten < 0)
throw new IOException("This port appears to have been shutdown or disconnected.");
if (bytesWritten == 0) sleep1();
} while (bytesWritten < 1);
}
@Override
public final void write(byte[] b) throws IOException
{
if (!isOpened)
throw new IOException("This port appears to have been shutdown or disconnected.");
int bytesWritten = 0;
byte[] buffer = b;
if (writeBytes(portHandle, b, b.length) < 0)
throw new IOException("This port appears to have been shutdown or disconnected.");
do {
if (!isOpened)
throw new IOException("This port appears to have been shutdown or disconnected.");
int written = writeBytes(portHandle, buffer, 1L);
if (written < 0)
throw new IOException("This port appears to have been shutdown or disconnected.");
bytesWritten += written;
if (written == 0)
{
sleep1();
}
else
{
buffer = new byte[b.length - bytesWritten];
System.arraycopy(b, bytesWritten, buffer, 0, buffer.length);
}
} while (bytesWritten < b.length);
}
@Override