send
This commit is contained in:
parent
a2f1bef34a
commit
29c2ab0e4c
@ -55,17 +55,19 @@ func (p *PeerCache) checkPeerStatus(peerID string, caller *tools.HTTPCaller) boo
|
|||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
methods := caller.URLS[utils.PEER.String()]
|
methods := caller.URLS[utils.PEER.String()]
|
||||||
|
fmt.Println("PEER AFT 3", methods)
|
||||||
if methods == nil {
|
if methods == nil {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
meth := methods[tools.POST]
|
meth := methods[tools.POST]
|
||||||
|
fmt.Println("PEER AFT 4", meth)
|
||||||
if meth == "" {
|
if meth == "" {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
url := p.urlFormat(res.(*Peer).Url+meth, utils.PEER)
|
url := p.urlFormat(res.(*Peer).Url+meth, utils.PEER)
|
||||||
state := api.CheckRemotePeer(url)
|
fmt.Println("PEER AFT 5", url)
|
||||||
res.(*Peer).State = state
|
state, services := api.CheckRemotePeer(url)
|
||||||
|
res.(*Peer).Services = services
|
||||||
access.UpdateOne(res, peerID)
|
access.UpdateOne(res, peerID)
|
||||||
fmt.Printf("Peer %v is %v\n", peerID, state)
|
fmt.Printf("Peer %v is %v\n", peerID, state)
|
||||||
return state != tools.DEAD
|
return state != tools.DEAD
|
||||||
@ -92,6 +94,7 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, isMySelf bool, dataID str
|
|||||||
meth = strings.ReplaceAll(meth, ":id", dataID)
|
meth = strings.ReplaceAll(meth, ":id", dataID)
|
||||||
}
|
}
|
||||||
url = p.urlFormat(url+meth, dt)
|
url = p.urlFormat(url+meth, dt)
|
||||||
|
fmt.Println("LaunchPeerExecution AFT 3", url)
|
||||||
if !p.checkPeerStatus(peerID, caller) {
|
if !p.checkPeerStatus(peerID, caller) {
|
||||||
return nil, errors.New("peer is not reachable")
|
return nil, errors.New("peer is not reachable")
|
||||||
}
|
}
|
||||||
@ -118,10 +121,10 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, isMySelf bool, dataID str
|
|||||||
DataID: dataID,
|
DataID: dataID,
|
||||||
}
|
}
|
||||||
singleton.Executions = append(singleton.Executions, pexec)
|
singleton.Executions = append(singleton.Executions, pexec)
|
||||||
if currentRountine == 0 {
|
/*if currentRountine == 0 {
|
||||||
currentRountine++
|
currentRountine++
|
||||||
go p.retryPeerExecution()
|
go p.retryPeerExecution()
|
||||||
}
|
}*/
|
||||||
return pexec, err
|
return pexec, err
|
||||||
}
|
}
|
||||||
fmt.Println("LaunchPeerExecution AFT 3", m, url)
|
fmt.Println("LaunchPeerExecution AFT 3", m, url)
|
||||||
|
Loading…
Reference in New Issue
Block a user