From 271fb20ecb48944692bdb4e7f91be9b90506981b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?P=C3=A9ter=20Szil=C3=A1gyi?= <peterke@gmail.com>
Date: Wed, 10 Jun 2015 18:01:05 +0300
Subject: [PATCH] cmd/geth, eth/downloader: rough guess at the import eta

---
 cmd/geth/admin.go            |  9 +++++++--
 eth/downloader/downloader.go | 15 +++++++++++++--
 2 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/cmd/geth/admin.go b/cmd/geth/admin.go
index ea8a709230..7bf23829a6 100644
--- a/cmd/geth/admin.go
+++ b/cmd/geth/admin.go
@@ -325,8 +325,13 @@ func (js *jsre) setHead(call otto.FunctionCall) otto.Value {
 }
 
 func (js *jsre) syncProgress(call otto.FunctionCall) otto.Value {
-	pending, cached, importing := js.ethereum.Downloader().Stats()
-	v, _ := call.Otto.ToValue(map[string]interface{}{"pending": pending, "cached": cached, "importing": importing})
+	pending, cached, importing, eta := js.ethereum.Downloader().Stats()
+	v, _ := call.Otto.ToValue(map[string]interface{}{
+		"pending":   pending,
+		"cached":    cached,
+		"importing": importing,
+		"estimate":  eta.String(),
+	})
 	return v
 }
 
diff --git a/eth/downloader/downloader.go b/eth/downloader/downloader.go
index efb94e5e3a..c3234ecb10 100644
--- a/eth/downloader/downloader.go
+++ b/eth/downloader/downloader.go
@@ -79,7 +79,9 @@ type Downloader struct {
 	banned *set.Set                    // Set of hashes we've received and banned
 
 	// Statistics
+	importStart time.Time     // Instance when the last blocks were taken from the cache
 	importQueue []common.Hash // Hashes of the previously taken blocks to check import progress
+	importDone  int           // Number of taken blocks already imported from the last batch
 	importLock  sync.Mutex
 
 	// Callbacks
@@ -126,19 +128,25 @@ func New(mux *event.TypeMux, hasBlock hashCheckFn, getBlock getBlockFn) *Downloa
 }
 
 // Stats retrieves the current status of the downloader.
-func (d *Downloader) Stats() (pending int, cached int, importing int) {
+func (d *Downloader) Stats() (pending int, cached int, importing int, estimate time.Duration) {
 	// Fetch the download status
 	pending, cached = d.queue.Size()
 
-	// Generate the import status
+	// Figure out the import progress
 	d.importLock.Lock()
 	defer d.importLock.Unlock()
 
 	for len(d.importQueue) > 0 && d.hasBlock(d.importQueue[0]) {
 		d.importQueue = d.importQueue[1:]
+		d.importDone++
 	}
 	importing = len(d.importQueue)
 
+	// Make an estimate on the total sync
+	estimate = 0
+	if d.importDone > 0 {
+		estimate = time.Since(d.importStart) / time.Duration(d.importDone) * time.Duration(pending+cached+importing)
+	}
 	return
 }
 
@@ -226,7 +234,9 @@ func (d *Downloader) TakeBlocks() []*Block {
 			hashes[i] = block.RawBlock.Hash()
 		}
 		d.importLock.Lock()
+		d.importStart = time.Now()
 		d.importQueue = hashes
+		d.importDone = 0
 		d.importLock.Unlock()
 	}
 	return blocks
@@ -287,6 +297,7 @@ func (d *Downloader) Cancel() bool {
 
 	d.importLock.Lock()
 	d.importQueue = nil
+	d.importDone = 0
 	d.importLock.Unlock()
 
 	return true