MapDBLog: add sanity check

Change-Id: If364a073b2d80c301eed236f80c6884f34bee6be

@@ -99,7 +99,8 @@ public class MapDBLog implements Log {
                 long nextIndex = log.isEmpty() ? 1 : log.lastKey() + 1;
                 long nextIndex = log.isEmpty() ? 1 : log.lastKey() + 1;
                 long addedBytes = 0;
                 long addedBytes = 0;
                 for (Entry entry : entries) {
                 for (Entry entry : entries) {
-                    byte[] entryBytes = serializer.encode(entry);
+                    byte[] entryBytes = verifyNotNull(serializer.encode(entry),
+                                                      "Writing LogEntry %s failed", nextIndex);
                     log.put(nextIndex, entryBytes);
                     log.put(nextIndex, entryBytes);
                     addedBytes += entryBytes.length;
                     addedBytes += entryBytes.length;
                     indices.add(nextIndex);
                     indices.add(nextIndex);
@@ -144,7 +145,7 @@ public class MapDBLog implements Log {
         DB db = txMaker.makeTx();
         DB db = txMaker.makeTx();
         try {
         try {
             BTreeMap<Long, byte[]> log = getLogMap(db);
             BTreeMap<Long, byte[]> log = getLogMap(db);
-            return log.isEmpty() ? null : serializer.decode(log.firstEntry().getValue());
+            return log.isEmpty() ? null : verifyNotNull(serializer.decode(log.firstEntry().getValue()));
         } finally {
         } finally {
             db.close();
             db.close();
         }
         }
@@ -177,7 +178,7 @@ public class MapDBLog implements Log {
             }
             }
             List<T> entries = new ArrayList<>((int) (to - from + 1));
             List<T> entries = new ArrayList<>((int) (to - from + 1));
             for (long i = from; i <= to; i++) {
             for (long i = from; i <= to; i++) {
-                T entry = serializer.decode(log.get(i));
+                T entry = verifyNotNull(serializer.decode(log.get(i)), "LogEntry %s was null", i);
                 entries.add(entry);
                 entries.add(entry);
             }
             }
             return entries;
             return entries;
@@ -193,7 +194,8 @@ public class MapDBLog implements Log {
         try {
         try {
             BTreeMap<Long, byte[]> log = getLogMap(db);
             BTreeMap<Long, byte[]> log = getLogMap(db);
             byte[] entryBytes = log.get(index);
             byte[] entryBytes = log.get(index);
-            return entryBytes == null ? null : serializer.decode(entryBytes);
+            return entryBytes == null ? null : verifyNotNull(serializer.decode(entryBytes),
+                                                             "LogEntry %s was null", index);
         } finally {
         } finally {
             db.close();
             db.close();
         }
         }
@@ -217,7 +219,7 @@ public class MapDBLog implements Log {
         DB db = txMaker.makeTx();
         DB db = txMaker.makeTx();
         try {
         try {
             BTreeMap<Long, byte[]> log = getLogMap(db);
             BTreeMap<Long, byte[]> log = getLogMap(db);
-            return log.isEmpty() ? null : serializer.decode(log.lastEntry().getValue());
+            return log.isEmpty() ? null : verifyNotNull(serializer.decode(log.lastEntry().getValue()));
         } finally {
         } finally {
             db.close();
             db.close();
         }
         }