You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
120 lines
3.1 KiB
120 lines
3.1 KiB
package stratum |
|
|
|
import ( |
|
"log" |
|
"regexp" |
|
"strings" |
|
|
|
"../util" |
|
) |
|
|
|
var noncePattern *regexp.Regexp |
|
|
|
func init() { |
|
noncePattern, _ = regexp.Compile("^[0-9a-f]{8}$") |
|
} |
|
|
|
func (s *StratumServer) handleLoginRPC(cs *Session, params *LoginParams) (reply *JobReply, errorReply *ErrorReply) { |
|
if !s.config.BypassAddressValidation && !util.ValidateAddress(params.Login, s.config.Address) { |
|
errorReply = &ErrorReply{Code: -1, Message: "Invalid address used for login", Close: true} |
|
return |
|
} |
|
|
|
miner := NewMiner(params.Login, params.Pass, s.port.Difficulty, cs.ip) |
|
miner.Session = cs |
|
s.registerMiner(miner) |
|
miner.heartbeat() |
|
|
|
log.Printf("Miner connected %s@%s", params.Login, miner.IP) |
|
|
|
reply = &JobReply{} |
|
reply.Id = miner.Id |
|
reply.Job = miner.getJob(s) |
|
reply.Status = "OK" |
|
return |
|
} |
|
|
|
func (s *StratumServer) handleGetJobRPC(cs *Session, params *GetJobParams) (reply *JobReplyData, errorReply *ErrorReply) { |
|
miner, ok := s.miners.Get(params.Id) |
|
if !ok { |
|
errorReply = &ErrorReply{Code: -1, Message: "Unauthenticated", Close: true} |
|
return |
|
} |
|
miner.heartbeat() |
|
reply = miner.getJob(s) |
|
return |
|
} |
|
|
|
func (s *StratumServer) handleSubmitRPC(cs *Session, params *SubmitParams) (reply *SubmitReply, errorReply *ErrorReply) { |
|
miner, ok := s.miners.Get(params.Id) |
|
if !ok { |
|
errorReply = &ErrorReply{Code: -1, Message: "Unauthenticated", Close: true} |
|
return |
|
} |
|
miner.heartbeat() |
|
|
|
job := miner.findJob(params.JobId) |
|
if job == nil { |
|
errorReply = &ErrorReply{Code: -1, Message: "Invalid job id", Close: true} |
|
return |
|
} |
|
|
|
if !noncePattern.MatchString(params.Nonce) { |
|
errorReply = &ErrorReply{Code: -1, Message: "Malformed nonce", Close: true} |
|
return |
|
} |
|
nonce := strings.ToLower(params.Nonce) |
|
exist := job.submit(nonce) |
|
if exist { |
|
errorReply = &ErrorReply{Code: -1, Message: "Duplicate share", Close: true} |
|
return |
|
} |
|
|
|
t := s.currentBlockTemplate() |
|
if job.Height != t.Height { |
|
log.Printf("Block expired for height %v %s@%s", job.Height, miner.Login, miner.IP) |
|
errorReply = &ErrorReply{Code: -1, Message: "Block expired", Close: false} |
|
return |
|
} |
|
|
|
validShare := miner.processShare(s, job, t, nonce, params.Result) |
|
if !validShare { |
|
errorReply = &ErrorReply{Code: -1, Message: "Low difficulty share", Close: !ok} |
|
return |
|
} |
|
|
|
reply = &SubmitReply{Status: "OK"} |
|
return |
|
} |
|
|
|
func (s *StratumServer) handleUnknownRPC(cs *Session, req *JSONRpcReq) *ErrorReply { |
|
log.Printf("Unknown RPC method: %v", req) |
|
return &ErrorReply{Code: -1, Message: "Invalid method", Close: true} |
|
} |
|
|
|
func (s *StratumServer) broadcastNewJobs() { |
|
log.Printf("Broadcasting new jobs to %v miners", s.miners.Count()) |
|
bcast := make(chan int, 1024*16) |
|
n := 0 |
|
|
|
for m := range s.miners.IterBuffered() { |
|
n++ |
|
bcast <- n |
|
go func(miner *Miner) { |
|
reply := miner.getJob(s) |
|
err := miner.Session.pushMessage("job", &reply) |
|
<-bcast |
|
if err != nil { |
|
log.Printf("Job transmit error to %v@%v: %v", miner.Login, miner.IP, err) |
|
s.removeMiner(miner.Id) |
|
} |
|
}(m.Val) |
|
} |
|
} |
|
|
|
func (s *StratumServer) refreshBlockTemplate(bcast bool) { |
|
newBlock := s.fetchBlockTemplate() |
|
if newBlock && bcast { |
|
s.broadcastNewJobs() |
|
} |
|
}
|
|
|