-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/6982/
-----------------------------------------------------------
(Updated Sept. 14, 2012, 2 p.m.)
Review request for Flume.
Changes
-------
Thank you Mike for the review.
Summary of my changes
-Changed currentByteUsage to AtomicLong
-Also added synchronized(currentByteUsage) to put.
Description
-------
1. The user will be able to define a byteCapacity and a
byteCapacityBufferPercentage.
2. Events byte size will be estimated from there body contents
3. On put bytes are added to current total
4. On commit any uncommitted takes are removed from the current byte total
5. On rollover any uncommitted puts are removed from the current byte total
This addresses bug FLUME-1535.
https://issues.apache.org/jira/browse/FLUME-1535
Diffs (updated)
-----
flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java
c72e97c
flume-ng-core/src/test/java/org/apache/flume/channel/TestMemoryChannel.java
e070864
Diff: https://reviews.apache.org/r/6982/diff/
Testing
-------
Thanks,
Ted Malaska
