reddycharan commented on a change in pull request #1228: Issue #570: Move logic
of unpersistedbytes to bufferedchannel
URL: https://github.com/apache/bookkeeper/pull/1228#discussion_r172287563
##########
File path:
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BufferedChannel.java
##########
@@ -70,28 +96,42 @@ public void close() throws IOException {
* @param src The source ByteBuffer which contains the data to be written.
* @throws IOException if a write operation fails.
*/
- public synchronized void write(ByteBuf src) throws IOException {
+ public void write(ByteBuf src) throws IOException {
int copied = 0;
- int len = src.readableBytes();
- while (copied < len) {
- int bytesToCopy = Math.min(src.readableBytes() - copied,
writeBuffer.writableBytes());
- writeBuffer.writeBytes(src, src.readerIndex() + copied,
bytesToCopy);
- copied += bytesToCopy;
-
- // if we have run out of buffer space, we should flush to the file
- if (!writeBuffer.isWritable()) {
- flushInternal();
+ boolean shouldForceWrite = false;
+ synchronized (this) {
+ int len = src.readableBytes();
+ while (copied < len) {
+ int bytesToCopy = Math.min(src.readableBytes() - copied,
writeBuffer.writableBytes());
+ writeBuffer.writeBytes(src, src.readerIndex() + copied,
bytesToCopy);
+ copied += bytesToCopy;
+
+ // if we have run out of buffer space, we should flush to the
+ // file
+ if (!writeBuffer.isWritable()) {
+ flushInternal();
+ }
+ }
+ position.addAndGet(copied);
+ unpersistedBytes.addAndGet(copied);
Review comment:
I'm exposing this variable's value through getUnpersistedBytes() method for
testing purpose. Also I feel it is more safer to use atomic variables when it
is accessed/modified by multiple threads.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
