in proxy/protocol/dubbo/server/server.go [117:143]
func (d *DubboServer) Start() error {
err := d.Init()
if err != nil {
return err
}
dubboproxy.DubboListenAddr = d.opts.Address
host, _, err := net.SplitHostPort(d.opts.Address)
if err != nil {
return err
}
ip := net.ParseIP(host)
if ip == nil {
return &util.BaseError{"invalid host"}
}
tcpAddr, err := net.ResolveTCPAddr("tcp", d.opts.Address)
if err != nil {
openlog.Error("ResolveTCPAddr err: " + err.Error())
return err
}
l, err := net.ListenTCP("tcp", tcpAddr)
if err != nil {
openlog.Error("listening failed, reason: " + err.Error())
return err
}
d.routineMgr.Spawn(d, l, "Acceptloop")
return nil
}