private void addBuffer() {
try {
if (!isClosed && bufferQueue.size() <= BUFFER_QUEUE_SIZE)
bufferQueue.put(new byte[size]);
} catch (InterruptedException e) {
<BUG>LOGGER.log(LogLevel.INFO, "Unable to add buffer to buffer queue", e);
}</BUG>
}
}
public AsyncBufferWriter(OutputStream outputStream, int size, ThreadFactory threadFactory, byte[] newline)  {

private void addBuffer() {
try {
if (!isClosed && bufferQueue.size() <= BUFFER_QUEUE_SIZE)
bufferQueue.put(new byte[size]);
} catch (InterruptedException e) {
LOGGER.log(LogLevel.INFO, Messages.getString("HDFS_ASYNC_UNABLE_ADD_TO_QUEUE"), e);
}
}
}
public AsyncBufferWriter(OutputStream outputStream, int size, ThreadFactory threadFactory, byte[] newline)  {
