diff --git a/zetta.js b/zetta.js
index <HASH>..<HASH> 100644
--- a/zetta.js
+++ b/zetta.js
@@ -277,6 +277,7 @@ Zetta.prototype._cleanupPeers = function(callback) {
   this.peerRegistry.find({ match: function() { return true; } }, function(err, results) {
     if(err) {
       callback(err);  
+      return;
     }
 
     async.forEach(results, function(peer, next) {
@@ -294,6 +295,7 @@ Zetta.prototype._initPeers = function(callback) {
   this.peerRegistry.find({ match: function(peer) { return true; } }, function(err, results) {
     if(err) {
       callback(err);  
+      return;
     }
 
     results.forEach(function(peer) {
Added a return statement to halt execution per adam.