Return an error if the storage engine can't be created

influxdata · Sep 22, 2014 · 78f8c39 · 78f8c39
1 parent 20deef8
commit 78f8c39
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/datastore/shard_datastore.go b/datastore/shard_datastore.go
@@ -182,6 +182,10 @@ func (self *ShardDatastore) GetOrCreateShard(id uint32) (cluster.LocalShardDb, e
 	}
 
 	se, err := init.Initialize(dbDir, c)
+	if err != nil {
+		return nil, err
+	}
+
 	db, err = NewShard(se, self.pointBatchSize, self.writeBatchSize, self.metaStore)
 	if err != nil {
 		log.Error("Error creating shard: ", err)