----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/56506/ -----------------------------------------------------------
Review request for geode, anilkumar gingade and Darrel Schneider. 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 ----- geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java 0b98364b743c39e69773d586f9c793eb7de71b8d 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