mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

ignore status
All checks were successful
Build and Publish / BuildAndDeployAmd64 (push) Successful in 26s
Details
Build and Publish / BuildAndDeploy (push) Successful in 2m24s
Details

Browse Source
This commit is contained in:
matst80
2024-11-13 22:23:48 +01:00
parent 83fcc10f1b
commit 4d3e49b53d
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
synced-pool.go
View File

@@ -61,12 +61,8 @@ var (
}) })
) )
var (
PongResponse = MakeFrameWithPayload(Pong, 200, []byte{})
)
func (p *SyncedPool) PongHandler(data *FrameWithPayload, resultChan chan<- FrameWithPayload) error { func (p *SyncedPool) PongHandler(data *FrameWithPayload, resultChan chan<- FrameWithPayload) error {
resultChan <- PongResponse resultChan <- MakeFrameWithPayload(Pong, 200, []byte{})
return nil return nil
} }
@@ -371,9 +367,9 @@ func (p *SyncedPool) AddRemote(host string) error {
return nil return nil
} }
client := NewConnection(fmt.Sprintf("%s:1338", host)) client := NewConnection(fmt.Sprintf("%s:1338", host))
response, err := client.Call(Ping, nil) _, err := client.Call(Ping, nil)
if err != nil || response.StatusCode != 200 || response.Type != Pong { if err != nil {
log.Printf("Error connecting to remote %s: %v\n", host, response) log.Printf("Error connecting to remote %s: %s\n", host, err)
return err return err
} }