chg: [isNet] silly bug
parent
11999504da
commit
20667c1674
9
main.go
9
main.go
|
@ -123,11 +123,14 @@ func main() {
|
||||||
rd4.redisDB, _ = strconv.Atoi(ss[1])
|
rd4.redisDB, _ = strconv.Atoi(ss[1])
|
||||||
var ret bool
|
var ret bool
|
||||||
ret, ss[0] = config.IsNet(ss[0])
|
ret, ss[0] = config.IsNet(ss[0])
|
||||||
if !ret {
|
if ret {
|
||||||
sss := strings.Split(string(ss[0]), ":")
|
sss := strings.Split(string(ss[0]), ":")
|
||||||
rd4.redisHost = sss[0]
|
rd4.redisHost = sss[0]
|
||||||
rd4.redisPort = sss[1]
|
rd4.redisPort = sss[1]
|
||||||
|
} else {
|
||||||
|
log.Fatal("Redis config error.")
|
||||||
}
|
}
|
||||||
|
|
||||||
rd4.redisQueue = string(config.ReadConfigFile(*confdir, "redis_queue"))
|
rd4.redisQueue = string(config.ReadConfigFile(*confdir, "redis_queue"))
|
||||||
// Connect to D4 Redis
|
// Connect to D4 Redis
|
||||||
// TODO use DialOptions to Dial with a timeout
|
// TODO use DialOptions to Dial with a timeout
|
||||||
|
@ -147,10 +150,12 @@ func main() {
|
||||||
rp.redisDBCount, _ = strconv.Atoi(ss[1])
|
rp.redisDBCount, _ = strconv.Atoi(ss[1])
|
||||||
var ret bool
|
var ret bool
|
||||||
ret, ss[0] = config.IsNet(ss[0])
|
ret, ss[0] = config.IsNet(ss[0])
|
||||||
if !ret {
|
if ret {
|
||||||
sss := strings.Split(string(ss[0]), ":")
|
sss := strings.Split(string(ss[0]), ":")
|
||||||
rp.redisHost = sss[0]
|
rp.redisHost = sss[0]
|
||||||
rp.redisPort = sss[1]
|
rp.redisPort = sss[1]
|
||||||
|
} else {
|
||||||
|
log.Fatal("Redis config error.")
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create a connection Pool
|
// Create a connection Pool
|
||||||
|
|
Loading…
Reference in New Issue