----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/56506/ -----------------------------------------------------------
(Updated Feb. 11, 2017, midnight) Review request for geode, anilkumar gingade and Darrel Schneider. Changes ------- Updated as noted and restarted precheckin Repository: geode Description ------- Implemented limited retries in two forms of Oplog.flush() when channel.write() is called. If write() returns bytes witten less than the change in the ByteBuffer positions, then reset buffer positions and re-try writing for a limited number of times. Throws IOException if the write doesn't succeeded after a few retries (max number of retries is defined by a static). Added new unit tests. Diffs (updated) ----- geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java 0b98364 geode-core/src/test/java/org/apache/geode/internal/cache/OplogFlushTest.java PRE-CREATION Diff: https://reviews.apache.org/r/56506/diff/ Testing ------- Started precheckin Thanks, Ken Howe