Disconnect the miner immediately when the connection to the mining po…

…ol is not ready

This helps to solve the problem that the miner still thinks the connection is active when the BTCAgent's connection to the mining pool fails.

DownSessionBTC.go

@@ -488,6 +488,11 @@ func (down *DownSessionBTC) exit() {
 	down.close()
 }
 
+func (down *DownSessionBTC) poolNotReady() {
+	glog.Warning(down.id, "pool connection not ready")
+	down.exit()
+}
+
 func (down *DownSessionBTC) handleEvent() {
 	down.eventLoopRunning = true
 	for down.eventLoopRunning {
@@ -506,6 +511,8 @@ func (down *DownSessionBTC) handleEvent() {
 			down.close()
 		case EventExit:
 			down.exit()
+		case EventPoolNotReady:
+			down.poolNotReady()
 		default:
 			glog.Error(down.id, "unknown event: ", e)
 		}

DownSessionETH.go

@@ -550,6 +550,11 @@ func (down *DownSessionETH) exit() {
 	down.close()
 }
 
+func (down *DownSessionETH) poolNotReady() {
+	glog.Warning(down.id, "pool connection not ready")
+	down.exit()
+}
+
 func (down *DownSessionETH) handleEvent() {
 	down.eventLoopRunning = true
 	for down.eventLoopRunning {
@@ -574,6 +579,8 @@ func (down *DownSessionETH) handleEvent() {
 			down.close()
 		case EventExit:
 			down.exit()
+		case EventPoolNotReady:
+			down.poolNotReady()
 		default:
 			glog.Error(down.id, "unknown event: ", e)
 		}

Event.go

@@ -9,6 +9,8 @@ type EventType uint8
 
 type EventExit struct{}
 
+type EventPoolNotReady struct{}
+
 type EventInitFinished struct{}
 
 type EventUpSessionReady struct {

UpSessionManager.go

@@ -101,9 +101,15 @@ func (manager *UpSessionManager) addDownSession(e EventAddDownSession) {
 		return
 	}
 
-	// 服务器均未就绪，把矿机托管给 FakeUpSession
-	manager.fakeUpSession.minerNum++
-	e.Session.SendEvent(EventSetUpSession{manager.fakeUpSession.upSession})
+	// 服务器均未就绪，若已启用 AlwaysKeepDownconn，就把矿机托管给 FakeUpSession
+	if manager.config.AlwaysKeepDownconn {
+		manager.fakeUpSession.minerNum++
+		e.Session.SendEvent(EventSetUpSession{manager.fakeUpSession.upSession})
+		return
+	}
+
+	// 未启用 AlwaysKeepDownconn，直接断开连接，防止矿机认为 BTCAgent 连接活跃
+	e.Session.SendEvent(EventPoolNotReady{})
 }
 
 func (manager *UpSessionManager) upSessionReady(e EventUpSessionReady) {