|
|
@ -82,7 +82,7 @@ func NewPoint(pConfig *Config) (*Point, error) {
|
|
|
|
r, err := router.CreateRouter(routerConfig.Strategy, routerConfig.Settings, vpoint.space)
|
|
|
|
r, err := router.CreateRouter(routerConfig.Strategy, routerConfig.Settings, vpoint.space)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
log.Error("Failed to create router: ", err)
|
|
|
|
log.Error("Failed to create router: ", err)
|
|
|
|
return nil, ErrorBadConfiguration
|
|
|
|
return nil, ErrBadConfiguration
|
|
|
|
}
|
|
|
|
}
|
|
|
|
vpoint.space.BindApp(router.APP_ID, r)
|
|
|
|
vpoint.space.BindApp(router.APP_ID, r)
|
|
|
|
vpoint.router = r
|
|
|
|
vpoint.router = r
|
|
|
@ -129,19 +129,19 @@ func NewPoint(pConfig *Config) (*Point, error) {
|
|
|
|
dh, err := NewInboundDetourHandlerAlways(vpoint.space, detourConfig)
|
|
|
|
dh, err := NewInboundDetourHandlerAlways(vpoint.space, detourConfig)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
log.Error("Point: Failed to create detour handler: ", err)
|
|
|
|
log.Error("Point: Failed to create detour handler: ", err)
|
|
|
|
return nil, ErrorBadConfiguration
|
|
|
|
return nil, ErrBadConfiguration
|
|
|
|
}
|
|
|
|
}
|
|
|
|
detourHandler = dh
|
|
|
|
detourHandler = dh
|
|
|
|
case AllocationStrategyRandom:
|
|
|
|
case AllocationStrategyRandom:
|
|
|
|
dh, err := NewInboundDetourHandlerDynamic(vpoint.space, detourConfig)
|
|
|
|
dh, err := NewInboundDetourHandlerDynamic(vpoint.space, detourConfig)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
log.Error("Point: Failed to create detour handler: ", err)
|
|
|
|
log.Error("Point: Failed to create detour handler: ", err)
|
|
|
|
return nil, ErrorBadConfiguration
|
|
|
|
return nil, ErrBadConfiguration
|
|
|
|
}
|
|
|
|
}
|
|
|
|
detourHandler = dh
|
|
|
|
detourHandler = dh
|
|
|
|
default:
|
|
|
|
default:
|
|
|
|
log.Error("Point: Unknown allocation strategy: ", allocConfig.Strategy)
|
|
|
|
log.Error("Point: Unknown allocation strategy: ", allocConfig.Strategy)
|
|
|
|
return nil, ErrorBadConfiguration
|
|
|
|
return nil, ErrBadConfiguration
|
|
|
|
}
|
|
|
|
}
|
|
|
|
vpoint.idh[idx] = detourHandler
|
|
|
|
vpoint.idh[idx] = detourHandler
|
|
|
|
if len(detourConfig.Tag) > 0 {
|
|
|
|
if len(detourConfig.Tag) > 0 {
|
|
|
@ -188,7 +188,7 @@ func (this *Point) Close() {
|
|
|
|
func (this *Point) Start() error {
|
|
|
|
func (this *Point) Start() error {
|
|
|
|
if this.port <= 0 {
|
|
|
|
if this.port <= 0 {
|
|
|
|
log.Error("Point: Invalid port ", this.port)
|
|
|
|
log.Error("Point: Invalid port ", this.port)
|
|
|
|
return ErrorBadConfiguration
|
|
|
|
return ErrBadConfiguration
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
err := retry.Timed(100 /* times */, 100 /* ms */).On(func() error {
|
|
|
|
err := retry.Timed(100 /* times */, 100 /* ms */).On(func() error {
|
|
|
|