[RATIS-1150] Return DataStreamException to client.

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Component/s: Streaming
• Assignee: runzhiwang
• Reporter: runzhiwang
• Created: 12/Nov/20 09:32
• Updated: 15/Nov/20 11:06
• Resolved: 15/Nov/20 11:06

Description

When primary or peer WritableByteChannel#write throw exception, we should return it to client.

static long writeTo(ByteBuf buf, DataStream stream) {
    final WritableByteChannel channel = stream.getWritableByteChannel();
    long byteWritten = 0;
    for (ByteBuffer buffer : buf.nioBuffers()) {
      try {
        byteWritten += channel.write(buffer);
      } catch (Throwable t) {
        throw new CompletionException(t);
      }
    }
    return byteWritten;
  }

Issue Links

• links to: GitHub Pull Request #277