Skip to content

Commit 6bd685b

Browse files
committed
Add deadline timecheck
1 parent a2c6670 commit 6bd685b

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

‎src/main/java/com/timgroup/statsd/UnixStreamClientChannel.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,9 @@ public int writeAll(ByteBuffer bb, boolean canReturnOnTimeout, long deadline)
103103
if (read > 0) {
104104
remaining -= read;
105105
written += read;
106+
if (deadline > 0 && System.nanoTime() >= deadline) {
107+
throw new IOException("Write timed out");
108+
}
106109
continue;
107110
}
108111

0 commit comments

Comments
 (0)