()
| 127 | // DB wants to do recovery, we're sure now -- it didn't. So truncate |
| 128 | // the log. |
| 129 | void preAppend() throws IOException { |
| 130 | totalRecords++; |
| 131 | if(recoveryUndecided){ |
| 132 | recoveryUndecided = false; |
| 133 | raf.seek(0); |
| 134 | raf.setLength(0); |
| 135 | raf.writeLong(NO_CHECKPOINT_ID); |
| 136 | raf.seek(raf.length()); |
| 137 | currentOffset = raf.getFilePointer(); |
| 138 | } |
| 139 | } |
| 140 | |
| 141 | public synchronized int getTotalRecords() { |
| 142 | return totalRecords; |
no outgoing calls
no test coverage detected