apps/urtrator
Archived
2
0
Fork 0
Code Issues 22 Pull Requests Packages Projects Releases 8 Wiki Activity

Stop updating servers if we're failed to connect to master server.

Browse Source
This commit is contained in:
Stanislav Nikitin 2016-11-04 19:37:50 +05:00
parent 4e9a6ae970
commit 8a3f2a9a2e
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
requester/requester_object.go
View File

@ -12,6 +12,7 @@ package requester
import ( import (
// stdlib // stdlib
"bytes" "bytes"
"errors"
"fmt" "fmt"
"net" "net"
"strconv" "strconv"
@ -46,11 +47,13 @@ func (r *Requester) Initialize() {
// Gets all available servers from master server. // Gets all available servers from master server.
// This isn't in pooler, because it have no need to be pooled. // This isn't in pooler, because it have no need to be pooled.
func (r *Requester) getServers() { func (r *Requester) getServers() error {
// IP addresses we will compose to return. // IP addresses we will compose to return.
conn, err1 := net.Dial("udp", r.master_server + ":" + r.master_server_port) conn, err1 := net.Dial("udp", r.master_server + ":" + r.master_server_port)
if err1 != nil { if err1 != nil {
fmt.Println("Error dialing to master server!") fmt.Println("Error dialing to master server!")
Eventer.LaunchEvent("setToolbarLabelText", map[string]string{"text": "Failed to connect to master server!"})
return errors.New("Failed to connect to master server!")
} }
defer conn.Close() defer conn.Close()
@ -118,6 +121,8 @@ func (r *Requester) getServers() {
Cache.Servers[addr].Server.Port = port Cache.Servers[addr].Server.Port = port
} }
} }
return nil
} }
// Updates information about all available servers from master server and // Updates information about all available servers from master server and