fix: 🐛 fixed some bugs

import-yuefeng · Aug 19, 2019 · df13e9f · df13e9f
1 parent 531e3cc
commit df13e9f
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 3 deletions.
diff --git a/core/outbound/clients/remote_bundle.go b/core/outbound/clients/remote_bundle.go
@@ -71,7 +71,6 @@ func (cb *RemoteClientBundle) Exchange(isLog bool) *CacheMessage {
 			// use dns that first response
 		}
 	}
-	// defer close(ch)
 	if ec != nil && ec.responseMessage != nil {
 		cacheMessage.ResponseMessage = ec.responseMessage
 		cacheMessage.QuestionMessage = ec.questionMessage

diff --git a/core/outbound/dispatcher.go b/core/outbound/dispatcher.go
@@ -97,7 +97,6 @@ func (d *Dispatcher) Exchange(query *dns.Msg, inboundIP string) *dns.Msg {
 			bundleLenght--
 			if x.isHit {
 				ActiveClientBundle = x.hitRemoteClientBundle
-				close(ch)
 				break
 			}
 		}
@@ -183,7 +182,6 @@ func (d *Dispatcher) selectByIPNetwork(bundle *Bundle) *BundleMsg {
 			i++
 		}
 		if i >= int(float64(len(bundle.ClientBundle))*0.75) {
-			close(ch)
 			break
 		}
 	}