Resolve numerous high/medium Coverity findings. Resolve some NPE Fort…

…ify findings.

Signed-off-by: sjudeng <sjudeng@users.noreply.github.com>

janusgraph-cassandra/src/main/java/org/janusgraph/diskstorage/cassandra/astyanax/AstyanaxStoreManager.java

@@ -433,7 +433,12 @@ public void clearStorage() throws BackendException {
             if (ks == null)
                 return;
 
-            for (ColumnFamilyDefinition cf : cluster.describeKeyspace(keySpaceName).getColumnFamilyList()) {
+            final KeyspaceDefinition keyspaceDefinition = cluster.describeKeyspace(keySpaceName);
+            if (keyspaceDefinition == null) {
+                return;
+            }
+
+            for (ColumnFamilyDefinition cf : keyspaceDefinition.getColumnFamilyList()) {
                 ks.truncateColumnFamily(new ColumnFamily<Object, Object>(cf.getName(), null, null));
             }
         } catch (ConnectionException e) {

janusgraph-core/src/main/java/org/janusgraph/core/JanusGraphFactory.java

@@ -293,10 +293,10 @@ private static final String getAbsolutePath(final File configParent, String file
         File storedir = new File(file);
         if (!storedir.isAbsolute()) {
             String newFile = configParent.getAbsolutePath() + File.separator + file;
-            log.debug("Overwrote relative path: was {}, now {}", file, newFile);
+            log.debug("Overwrote relative path: was {}, now {}", storedir.getAbsolutePath(), newFile);
             return newFile;
         } else {
-            log.debug("Loaded absolute path for key: {}", file);
+            log.debug("Loaded absolute path for key: {}", storedir.getAbsolutePath());
             return file;
         }
     }

janusgraph-core/src/main/java/org/janusgraph/core/util/JanusGraphCleanup.java

@@ -17,6 +17,7 @@
 import com.google.common.base.Preconditions;
 import org.janusgraph.core.JanusGraph;
 
+import org.janusgraph.diskstorage.Backend;
 import org.janusgraph.diskstorage.util.BackendOperation;
 import org.janusgraph.graphdb.configuration.GraphDatabaseConfiguration;
 import org.janusgraph.graphdb.database.StandardJanusGraph;
@@ -48,7 +49,9 @@ public static final void clear(JanusGraph graph) {
         BackendOperation.execute(new Callable<Boolean>(){
             @Override
             public Boolean call() throws Exception {
-                config.getBackend().clearStorage();
+                try (final Backend backend = config.getBackend()) {
+                    backend.clearStorage();
+                }
                 return true;
             }
             @Override

janusgraph-core/src/main/java/org/janusgraph/diskstorage/indexing/IndexFeatures.java

@@ -43,7 +43,7 @@ public IndexFeatures(boolean supportsDocumentTTL, Mapping defaultMap, ImmutableS
                          String wildcardField, ImmutableSet<Cardinality> supportedCardinaities, boolean supportsNanoseconds,
                          boolean supportCustomAnalyzer, boolean supportsGeoContains) {
 
-        Preconditions.checkArgument(defaultMap!=null || defaultMap!=Mapping.DEFAULT);
+        Preconditions.checkArgument(defaultMap!=null && defaultMap!=Mapping.DEFAULT);
         Preconditions.checkArgument(supportedMap!=null && !supportedMap.isEmpty()
                                     && supportedMap.contains(defaultMap));
         this.supportsDocumentTTL = supportsDocumentTTL;

janusgraph-core/src/main/java/org/janusgraph/diskstorage/keycolumnvalue/scan/StandardScanner.java

@@ -73,8 +73,7 @@ private void addJob(Object jobId, StandardScannerExecutor executor) {
                 runningJobs.remove(jobs.getKey(),exe);
             }
         }
-        runningJobs.putIfAbsent(jobId,executor);
-        Preconditions.checkArgument(runningJobs.get(jobId)==executor,"Another job with the same id is already running: %s",jobId);
+        Preconditions.checkArgument(runningJobs.putIfAbsent(jobId, executor) == null,"Another job with the same id is already running: %s",jobId);
     }
 
     public JanusGraphManagement.IndexJobFuture getRunningJob(Object jobId) {

janusgraph-core/src/main/java/org/janusgraph/graphdb/database/EdgeSerializer.java

@@ -232,7 +232,7 @@ public Entry writeRelation(InternalRelation relation, int position, TypeInspecto
     }
 
     public StaticArrayEntry writeRelation(InternalRelation relation, InternalRelationType type, int position, TypeInspector tx) {
-        assert type==relation.getType() || type.getBaseType().equals(relation.getType());
+        assert type==relation.getType() || (type.getBaseType() != null && type.getBaseType().equals(relation.getType()));
         Direction dir = EdgeDirection.fromPosition(position);
         Preconditions.checkArgument(type.isUnidirected(Direction.BOTH) || type.isUnidirected(dir));
         long typeid = type.longId();

janusgraph-core/src/main/java/org/janusgraph/graphdb/database/StandardJanusGraph.java

@@ -669,6 +669,7 @@ public void commit(final Collection<InternalRelation> addedRelations,
             if (logTransaction) {
                 //[FAILURE] Inability to log transaction fails the transaction by escalation since it's likely due to unavailability of primary
                 //storage backend.
+                Preconditions.checkState(txLog != null, "Transaction log is null");
                 txLog.add(txLogHeader.serializeModifications(serializer, LogTxStatus.PRECOMMIT, tx, addedRelations, deletedRelations),txLogHeader.getLogKey());
             }
 

janusgraph-core/src/main/java/org/janusgraph/graphdb/olap/computer/FulgoraGraphComputer.java

@@ -366,6 +366,9 @@ public void run() {
             try {
                 for (Map.Entry<Long, Map<String, Object>> vprop : properties) {
                     Vertex v = tx.getVertex(vprop.getKey());
+                    if (v == null) {
+                        continue;
+                    }
                     for (Map.Entry<String, Object> prop : vprop.getValue().entrySet()) {
                         v.property(VertexProperty.Cardinality.single, prop.getKey(), prop.getValue());
                     }

janusgraph-core/src/main/java/org/janusgraph/graphdb/olap/computer/VertexMemoryHandler.java

@@ -16,6 +16,7 @@
 
 import com.google.common.base.Preconditions;
 import org.janusgraph.core.JanusGraphEdge;
+import org.janusgraph.core.JanusGraphException;
 import org.janusgraph.core.JanusGraphVertex;
 import org.janusgraph.core.JanusGraphVertexProperty;
 import org.janusgraph.graphdb.vertices.PreloadedVertex;
@@ -117,10 +118,15 @@ public Stream<M> receiveMessages(MessageScope messageScope) {
             else return Stream.of(message);
         } else {
             final MessageScope.Local<M> localMessageScope = (MessageScope.Local) messageScope;
-            final Traversal<Vertex, Edge> reverseIncident = FulgoraUtil.getReverseElementTraversal(localMessageScope,vertex,vertex.tx());
             final BiFunction<M,Edge,M> edgeFct = localMessageScope.getEdgeFunction();
+            final List<Edge> edges;
+            try (final Traversal<Vertex, Edge> reverseIncident = FulgoraUtil.getReverseElementTraversal(localMessageScope,vertex,vertex.tx())) {
+                edges = IteratorUtils.list(reverseIncident);
+            } catch (Exception e) {
+                throw new JanusGraphException("Unable to close traversal", e);
+            }
 
-            return IteratorUtils.stream(reverseIncident)
+            return edges.stream()
                     .map(e -> {
                         M msg = vertexMemory.getMessage(vertexMemory.getCanonicalId(((JanusGraphEdge) e).otherVertex(vertex).longId()), localMessageScope);
                         return msg == null ? null : edgeFct.apply(msg, e);

janusgraph-core/src/main/java/org/janusgraph/graphdb/query/MetricsQueryExecutor.java

@@ -87,15 +87,12 @@ private <T> T runWithMetrics(String opName, Function<Void,T> impl) {
 
         final MetricManager mgr = MetricManager.INSTANCE;
         mgr.getCounter(metricsPrefix, opName, M_CALLS).inc();
-        final Timer.Context tc = mgr.getTimer(metricsPrefix, opName, M_TIME).time();
 
-        try {
+        try (final Timer.Context tc = mgr.getTimer(metricsPrefix, opName, M_TIME).time()) {
             return impl.apply(null);
         } catch (RuntimeException e) {
             mgr.getCounter(metricsPrefix, opName, M_EXCEPTIONS).inc();
             throw e;
-        } finally {
-            tc.stop();
         }
     }
 }

janusgraph-core/src/main/java/org/janusgraph/graphdb/query/QueryUtil.java

@@ -269,7 +269,7 @@ public static <R> List<R> processIntersectingRetrievals(List<IndexCall<R>> retri
                 }
             }
             sublimit = (int) Math.min(Integer.MAX_VALUE - 1, Math.max(Math.pow(sublimit, 1.5),(sublimit+1)*2));
-        } while (results.size() < limit && !exhaustedResults);
+        } while (results != null && results.size() < limit && !exhaustedResults);
         return results;
     }
 

janusgraph-core/src/main/java/org/janusgraph/graphdb/query/vertex/BasicVertexCentricQueryBuilder.java

@@ -344,7 +344,7 @@ public VertexList executeVertexIds(InternalVertex vertex, BaseVertexCentricQuery
                     if (merge==null) merge = (VertexListInternal)vlist;
                     else merge.addAll(vlist);
                 }
-                if (merge.size()>baseQuery.getLimit()) merge = (VertexListInternal)merge.subList(0,baseQuery.getLimit());
+                if (merge != null && merge.size()>baseQuery.getLimit()) merge = (VertexListInternal)merge.subList(0,baseQuery.getLimit());
                 return merge;
             } else vertex = tx.getCanonicalVertex(vertex);
         }

janusgraph-core/src/main/java/org/janusgraph/graphdb/relations/CacheEdge.java

@@ -15,6 +15,7 @@
 package org.janusgraph.graphdb.relations;
 
 import com.carrotsearch.hppc.cursors.LongObjectCursor;
+import com.google.common.base.Preconditions;
 import com.google.common.base.Predicate;
 import com.google.common.collect.Iterables;
 import org.janusgraph.core.PropertyKey;
@@ -46,7 +47,9 @@ public CacheEdge(long id, EdgeLabel label, InternalVertex start, InternalVertex
     }
 
     public Direction getVertexCentricDirection() {
-        return data.getCache().direction;
+        final RelationCache cache = data.getCache();
+        Preconditions.checkState(cache != null, "Cache is null");
+        return cache.direction;
     }
 
     //############## Similar code as CacheProperty but be careful when copying #############################

janusgraph-core/src/main/java/org/janusgraph/util/datastructures/RangeInterval.java

@@ -163,8 +163,7 @@ public boolean equals(Object other) {
         else if (other==null) return false;
         else if (!getClass().isInstance(other)) return false;
         RangeInterval oth = (RangeInterval)other;
-        if ((start==null ^ oth.start==null) || (end==null ^ oth.end==null)) return false;
-        return start.equals(oth.start) && end.equals(oth.end) && endInclusive==oth.endInclusive && startInclusive==oth.startInclusive;
+        return Objects.equals(start, oth.start) && Objects.equals(end, oth.end) && end.equals(oth.end) && endInclusive==oth.endInclusive && startInclusive==oth.startInclusive;
     }
 
     @Override

janusgraph-core/src/main/java/org/janusgraph/util/system/ConfigurationLint.java

@@ -24,6 +24,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.File;
 import java.io.FileInputStream;
 import java.io.IOException;
 import java.util.*;
@@ -40,7 +41,7 @@ public static void main(String args[]) throws IOException {
             System.exit(1);
         }
 
-        log.info("Checking " + args[0]);
+        log.info("Checking " + new File(args[0]).getAbsolutePath());
         Status s = validate(args[0]);
         if (0 == s.errors) {
             log.info(s.toString());

janusgraph-cql/src/main/java/org/janusgraph/diskstorage/cql/CQLResultSetKeyIterator.java

@@ -67,7 +67,7 @@ protected StaticBuffer computeNext() {
 
         while (this.iterator.hasNext()) {
             this.iterator.next();
-            if (!this.currentKey.equals(this.lastKey)) {
+            if (this.currentKey != null && !this.currentKey.equals(this.lastKey)) {
                 this.lastKey = this.currentKey;
                 return this.lastKey;
             }

janusgraph-es/src/main/java/org/janusgraph/diskstorage/es/rest/RestElasticSearchClient.java

@@ -194,7 +194,7 @@ public Map getIndexSettings(String indexName) throws IOException {
         Response response = performRequest(REQUEST_TYPE_GET, REQUEST_SEPARATOR + indexName + "/_settings", null);
         try (final InputStream inputStream = response.getEntity().getContent()) {
             Map<String,RestIndexSettings> settings = mapper.readValue(inputStream, new TypeReference<Map<String, RestIndexSettings>>() {});
-            return settings.get(indexName).getSettings().getMap();
+            return settings == null ? null : settings.get(indexName).getSettings().getMap();
         }
     }
 
@@ -208,7 +208,7 @@ public Map getMapping(String indexName, String typeName) throws IOException{
         Response response = performRequest(REQUEST_TYPE_GET, REQUEST_SEPARATOR + indexName + "/_mapping/" + typeName, null);
         try (final InputStream inputStream = response.getEntity().getContent()) {
             Map<String, RestIndexMappings> settings = mapper.readValue(inputStream, new TypeReference<Map<String, RestIndexMappings>>() {});
-            return settings.get(indexName).getMappings().get(typeName).getProperties();
+            return settings == null ? null : settings.get(indexName).getMappings().get(typeName).getProperties();
         }
     }
 

janusgraph-hadoop-parent/janusgraph-hadoop-core/src/main/java/org/janusgraph/hadoop/MapReduceIndexManagement.java

@@ -17,7 +17,9 @@
 import com.google.common.base.Joiner;
 import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableSet;
+import org.apache.commons.lang3.StringUtils;
 import org.janusgraph.core.JanusGraph;
+import org.janusgraph.core.RelationType;
 import org.janusgraph.core.schema.RelationTypeIndex;
 import org.janusgraph.core.schema.SchemaAction;
 import org.janusgraph.core.schema.JanusGraphIndex;
@@ -163,10 +165,9 @@ public JanusGraphManagement.IndexJobFuture updateIndex(Index index, SchemaAction
 
         // The index name and relation type name (if the latter is applicable)
         final String indexName = index.name();
-        final String relationTypeName =
-                RelationTypeIndex.class.isAssignableFrom(index.getClass()) ?
-                ((RelationTypeIndex)index).getType().name() :
-                "";
+        final RelationType relationType =
+            RelationTypeIndex.class.isAssignableFrom(index.getClass()) ? ((RelationTypeIndex) index).getType() : null;
+        final String relationTypeName = relationType == null ? StringUtils.EMPTY : relationType.name();
         Preconditions.checkNotNull(indexName);
 
         // Set the class of the IndexUpdateJob

janusgraph-hadoop-parent/janusgraph-hadoop-core/src/main/java/org/janusgraph/hadoop/config/job/AbstractDistCacheConfigurer.java

@@ -99,7 +99,7 @@ protected Path uploadFileIfNecessary(FileSystem localFS, Path localPath, FileSys
                     localPath, destPath, destFS);
         }
 
-        if (!fileStats.isRemoteCopyCurrent()) {
+        if (fileStats != null && !fileStats.isRemoteCopyCurrent()) {
             log.debug("Copying {} to {}", localPath, destPath);
             destFS.copyFromLocalFile(localPath, destPath);
             if (null != fileStats.local) {
@@ -146,8 +146,9 @@ private static Conf configureByClasspath(String mapredJarFilename) {
         for (String cpentry : classpath.split(File.pathSeparator)) {
             if (cpentry.toLowerCase().endsWith(".jar") || cpentry.toLowerCase().endsWith(".properties")) {
                 paths.add(new Path(cpentry));
-                if (cpentry.toLowerCase().endsWith(mrj));
+                if (cpentry.toLowerCase().endsWith(mrj)) {
                     mapredJarPath = cpentry;
+                }
             }
         }
         return new Conf(paths, mapredJarPath);

janusgraph-hadoop-parent/janusgraph-hadoop-core/src/main/java/org/janusgraph/hadoop/scan/HadoopScanRunner.java

@@ -103,9 +103,11 @@ public static ScanMetrics runJob(Configuration conf, String confRootField,
                     JanusGraphHadoopConfiguration.SCAN_JOB_CONFIG_KEYS, scanConf);
 
             // Copy scanjob settings from the JanusGraph Configuration instance to the Hadoop Configuration instance
-            Map<String, Object> jobConfMap = conf.getSubset(confRoot);
-            for (Map.Entry<String, Object> jobConfEntry : jobConfMap.entrySet()) {
-                hadoopJobConf.set((ConfigOption) ConfigElement.parse(confRoot, jobConfEntry.getKey()).element, jobConfEntry.getValue());
+            if (conf != null) {
+                Map<String, Object> jobConfMap = conf.getSubset(confRoot);
+                for (Map.Entry<String, Object> jobConfEntry : jobConfMap.entrySet()) {
+                    hadoopJobConf.set((ConfigOption) ConfigElement.parse(confRoot, jobConfEntry.getKey()).element, jobConfEntry.getValue());
+                }
             }
         }
 

janusgraph-lucene/src/main/java/org/janusgraph/diskstorage/lucene/LuceneIndex.java

@@ -403,7 +403,7 @@ private void addToDocument(String store,
             for (IndexableField f : spatialStrategy.createIndexableFields(geo.getValue())) {
                 doc.add(f);
                 if (spatialStrategy instanceof PointVectorStrategy) {
-                    doc.add(new DoubleDocValuesField(f.name(), f.numericValue().doubleValue()));
+                    doc.add(new DoubleDocValuesField(f.name(), f.numericValue() == null ? null : f.numericValue().doubleValue()));
                 }
             }
         }
@@ -449,7 +449,8 @@ public List<String> query(IndexQuery query, KeyInformation.IndexRetriever inform
             log.debug("Executed query [{}] in {} ms", q, System.currentTimeMillis() - time);
             List<String> result = new ArrayList<String>(docs.scoreDocs.length);
             for (int i = 0; i < docs.scoreDocs.length; i++) {
-                result.add(searcher.doc(docs.scoreDocs[i].doc).getField(DOCID).stringValue());
+                final IndexableField field = searcher.doc(docs.scoreDocs[i].doc).getField(DOCID);
+                result.add(field == null ? null : field.stringValue());
             }
             return result;
         } catch (IOException e) {
@@ -638,7 +639,8 @@ public Iterable<RawQuery.Result<String>> query(RawQuery query, KeyInformation.In
             log.debug("Executed query [{}] in {} ms",q, System.currentTimeMillis() - time);
             List<RawQuery.Result<String>> result = new ArrayList<RawQuery.Result<String>>(docs.scoreDocs.length);
             for (int i = offset; i < docs.scoreDocs.length; i++) {
-                result.add(new RawQuery.Result<String>(searcher.doc(docs.scoreDocs[i].doc).getField(DOCID).stringValue(),docs.scoreDocs[i].score));
+                final IndexableField field = searcher.doc(docs.scoreDocs[i].doc).getField(DOCID);
+                result.add(new RawQuery.Result<String>(field == null ? null : field.stringValue(),docs.scoreDocs[i].score));
             }
             return result;
         } catch (IOException e) {

janusgraph-solr/src/main/java/org/janusgraph/diskstorage/solr/SolrIndex.java

@@ -481,7 +481,7 @@ private void commitDocumentChanges(String collectionName, Collection<SolrInputDo
             for (SolrInputDocument d : documents) {
                 Collection<String> fieldNames = d.getFieldNames();
                 for (String name : fieldNames) {
-                    logger.error(name + ":" + d.getFieldValue(name).toString());
+                    logger.error(name + ":" + d.getFieldValue(name));
                 }
             }
 
@@ -1041,7 +1041,7 @@ private static void waitForRecoveriesToFinish(CloudSolrClient server, String col
                 zkStateReader.updateClusterState();
                 ClusterState clusterState = zkStateReader.getClusterState();
                 Map<String, Slice> slices = clusterState.getSlicesMap(collection);
-                Preconditions.checkNotNull("Could not find collection:" + collection, slices);
+                Preconditions.checkNotNull(slices, "Could not find collection:" + collection);
 
                // change paths for Replica.State per Solr refactoring
                // remove SYNC state per: http://tinyurl.com/pag6rwt