Fix exceed rate limit

Axentro · Feb 19, 2021 · ecf43ca · ecf43ca
1 parent 3a294b7
commit ecf43ca
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/miner/client.go b/miner/client.go
@@ -355,13 +355,21 @@ func (c *Client) recv() {
 					})
 				}(i)
 			}
-		case types.TypeMinerHandshakeRejected, types.TypeMinerExceedRate:
+		case types.TypeMinerHandshakeRejected:
 			reason := types.PeerRejectedResponse{}
 			err = json.Unmarshal([]byte(result.Content), &reason)
 			if err != nil {
 				log.Error("Can't convert rejected message")
 			}
-			log.Fatal("Query rejected: ", reason.Reason)
+			log.Fatal("Handshake rejected: ", reason.Reason)
+		case types.TypeMinerExceedRate:
+			reason := types.PeerRejectedResponse{}
+			err = json.Unmarshal([]byte(result.Content), &reason)
+			if err != nil {
+				log.Error("Can't convert rejected message")
+			}
+			log.Warn("Too many queries: ", reason.Reason)
+			time.Sleep(30 * time.Second)
 		default:
 			log.Warnf("Unknonw response type %d: %v", result.Type, result)
 		}