Showing
1 changed file
with
8 additions
and
8 deletions
... | @@ -163,15 +163,15 @@ public class FooComponent { | ... | @@ -163,15 +163,15 @@ public class FooComponent { |
163 | if (vv == null) { | 163 | if (vv == null) { |
164 | ByteBuffer zero = ByteBuffer.allocate(Long.BYTES).putLong(0); | 164 | ByteBuffer zero = ByteBuffer.allocate(Long.BYTES).putLong(0); |
165 | if (dbService.putIfAbsent(someTable, someKey, zero.array())) { | 165 | if (dbService.putIfAbsent(someTable, someKey, zero.array())) { |
166 | - log.info("Wrote initial value"); | 166 | + log.info("Wrote initial value"); |
167 | - vv = dbService.get(someTable, someKey); | 167 | + vv = dbService.get(someTable, someKey); |
168 | } else { | 168 | } else { |
169 | - log.info("Concurrent write detected."); | 169 | + log.info("Concurrent write detected."); |
170 | - // concurrent write detected, read and fall through | 170 | + // concurrent write detected, read and fall through |
171 | - vv = dbService.get(someTable, someKey); | 171 | + vv = dbService.get(someTable, someKey); |
172 | - if (vv == null) { | 172 | + if (vv == null) { |
173 | - log.error("Shouldn't reach here"); | 173 | + log.error("Shouldn't reach here"); |
174 | - } | 174 | + } |
175 | } | 175 | } |
176 | } | 176 | } |
177 | int retry = 5; | 177 | int retry = 5; | ... | ... |
-
Please register or login to post a comment