Fix management of corrupted OpLog
@@ -260,11 +260,11 @@ public class OPersistentOperationalLogV1 implements OOperationLog {
stream.readLong();//length, again
long magic = stream.readLong();
if (magic != MAGIC) {
-// throw //TODO
+ throw new ODistributedException("Invalid OpLog magic number for entry " + logId);
}
return new OOperationLogEntry(new OLogId(logId), request);
} catch (Exception e) {
- return null;//TODO manage broken log
+ return null;
}
}
