Display number of failed http requests to upstreams

sammy007 · Jan 5, 2016 · 1f86191 · 1f86191
1 parent 47e4f92
commit 1f86191
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/proxy/api.go b/proxy/api.go
@@ -53,6 +53,7 @@ func convertUpstream(u *rpc.RPCClient) map[string]interface{} {
 		"accepts":          atomic.LoadUint64(&u.Accepts),
 		"rejects":          atomic.LoadUint64(&u.Rejects),
 		"lastSubmissionAt": atomic.LoadInt64(&u.LastSubmissionAt),
+		"failsCount":       atomic.LoadUint64(&u.FailsCount),
 	}
 	return upstream
 }

diff --git a/rpc/rpc.go b/rpc/rpc.go
@@ -8,6 +8,7 @@ import (
 	"net/http"
 	"net/url"
 	"sync"
+	"sync/atomic"
 	"time"
 )
 
@@ -23,6 +24,7 @@ type RPCClient struct {
 	Rejects          uint64
 	LastSubmissionAt int64
 	client           *http.Client
+	FailsCount       uint64
 }
 
 type GetBlockReply struct {
@@ -160,6 +162,9 @@ func (r *RPCClient) Sick() bool {
 
 func (r *RPCClient) markSick() {
 	r.Lock()
+	if !r.sick {
+		atomic.AddUint64(&r.FailsCount, 1)
+	}
 	r.sickRate++
 	r.successRate = 0
 	if r.sickRate >= 5 {

diff --git a/www/index.html b/www/index.html
@@ -78,6 +78,7 @@ <h4>Upstream</h4>
             <th>Url</th>
             <th>Accepted</th>
             <th>Rejected</th>
+            <th>Fails</th>
             </tr>
             {{#each upstreams}}
               {{#if sick}}
@@ -93,6 +94,7 @@ <h4>Upstream</h4>
             <td>{{url}}</td>
             <td>{{formatNumber accepts}}</td>
             <td><strong>{{formatNumber rejects}}</strong></td>
+            <td>{{failsCount}}</td>
             </tr>
             {{/each}}
           </table>