fix bug
This commit is contained in:
@@ -13,7 +13,7 @@ import (
|
|||||||
func (s *Server) Enter(ctx context.Context, req *grpc_pb.EnterReq) (*grpc_pb.EnterResp, error) {
|
func (s *Server) Enter(ctx context.Context, req *grpc_pb.EnterReq) (*grpc_pb.EnterResp, error) {
|
||||||
ins, loaded := instance.Mgr.LoadOrStoreByInstanceID(req.InstanceID, instance.NewScene(s.SID, req.InstanceID))
|
ins, loaded := instance.Mgr.LoadOrStoreByInstanceID(req.InstanceID, instance.NewScene(s.SID, req.InstanceID))
|
||||||
if !loaded {
|
if !loaded {
|
||||||
ins.Start(s.EtcdTTL)
|
ins.Start(s.Cfg.TTL)
|
||||||
}
|
}
|
||||||
ins.EventIn <- req
|
ins.EventIn <- req
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user