eth/fetcher: fix a closure data race

1 files changed, 3 insertions, 2 deletions

diff --git a/eth/fetcher/fetcher.go b/eth/fetcher/fetcher.go
index 7b5804ab2..90a202235 100644
--- a/eth/fetcher/fetcher.go
+++ b/eth/fetcher/fetcher.go
@@ -281,12 +281,13 @@ func (f *Fetcher) loop() {
 
 					glog.V(logger.Detail).Infof("Peer %s: fetching %s", peer, list)
 				}
-				hashes := hashes // closure!
+				// Create a closure of the fetch and schedule in on a new thread
+				fetcher, hashes := f.fetching[hashes[0]].fetch, hashes
 				go func() {
 					if f.fetchingHook != nil {
 						f.fetchingHook(hashes)
 					}
-					f.fetching[hashes[0]].fetch(hashes)
+					fetcher(hashes)
 				}()
 			}
 			// Schedule the next fetch if blocks are still pending