Implement always_keep_downconn

Event.go

@@ -68,7 +68,7 @@ type EventStopUpSessionManager struct {
 }
 
 type EventUpdateFakeJob struct {
-	FakeJob StratumJob
+	FakeJob *StratumJob
 }
 
 type EventTransferDownSessions struct{}

FakeUpSession.go

@@ -87,7 +87,7 @@ func (up *FakeUpSession) downSessionBroken(e EventDownSessionBroken) {
 }
 
 func (up *FakeUpSession) updateFakeJob(e EventUpdateFakeJob) {
-	up.fakeJob = &e.FakeJob
+	up.fakeJob = e.FakeJob
 }
 
 func (up *FakeUpSession) fakeNotifyTicker() {

StratumJob.go

@@ -58,13 +58,16 @@ func IsFakeJobID(id string) bool {
 
 func (job *StratumJob) ToNewFakeJob() {
 	now := uint64(time.Now().Unix())
-	job.ID = fmt.Sprintf("f%04d", now)
+
+	// job id
+	job.Params[0] = fmt.Sprintf("f%d", now%0xffff)
 
 	coinbase1, _ := job.Params[2].(string)
 	pos := len(coinbase1) - 8
 	if pos < 0 {
 		pos = 0
 	}
 
+	// coinbase1
 	job.Params[2] = coinbase1[:pos] + Uint64ToHex(now)
 }

UpSession.go

@@ -155,8 +155,17 @@ func (up *UpSession) close() {
 		up.manager.SendEvent(EventUpSessionBroken{up.slot})
 	}
 
-	for _, down := range up.downSessions {
-		go down.SendEvent(EventExit{})
+	if up.config.AlwaysKeepDownconn {
+		if up.lastJob != nil {
+			up.manager.SendEvent(EventUpdateFakeJob{up.lastJob})
+		}
+		for _, down := range up.downSessions {
+			go up.manager.SendEvent(EventAddDownSession{down})
+		}
+	} else {
+		for _, down := range up.downSessions {
+			go down.SendEvent(EventExit{})
+		}
 	}
 
 	up.eventLoopRunning = false

UpSessionManager.go

@@ -133,6 +133,10 @@ func (manager *UpSessionManager) updateMinerNum(e EventUpdateMinerNum) {
 	glog.Info("miner num update, slot: ", e.Slot, ", miners: ", manager.upSessions[e.Slot].minerNum)
 }
 
+func (manager *UpSessionManager) updateFakeJob(e EventUpdateFakeJob) {
+	manager.fakeUpSession.SendEvent(e)
+}
+
 func (manager *UpSessionManager) exit() {
 	manager.fakeUpSession.SendEvent(EventExit{})
 
@@ -158,6 +162,8 @@ func (manager *UpSessionManager) handleEvent() {
 			manager.upSessionBroken(e)
 		case EventUpdateMinerNum:
 			manager.updateMinerNum(e)
+		case EventUpdateFakeJob:
+			manager.updateFakeJob(e)
 		case EventExit:
 			manager.exit()
 			return