diff --git a/lego/sys/rpcx/selector.go b/lego/sys/rpcx/selector.go index 7023ba4e5..85cc15ceb 100644 --- a/lego/sys/rpcx/selector.go +++ b/lego/sys/rpcx/selector.go @@ -40,7 +40,7 @@ type Selector struct { updateServerEvent func(map[string]*ServiceNode) servers map[string]*ServiceNode serversType map[string][]*ServiceNode - lock sync.Mutex + lock sync.RWMutex i map[string]int } @@ -51,7 +51,9 @@ func (this *Selector) Select(ctx context.Context, servicePath, serviceMethod str leng := len(service) if leng == 1 { if nodes, ok := this.serversType[service[0]]; ok { + this.lock.RLock() i, ok := this.i[service[0]] + this.lock.RUnlock() if !ok { i = 0 } diff --git a/modules/practice/api_accept.go b/modules/practice/api_accept.go index 4c9c38dc1..e694157ca 100644 --- a/modules/practice/api_accept.go +++ b/modules/practice/api_accept.go @@ -132,6 +132,6 @@ func (this *apiComp) Accept(session comm.IUserSession, req *pb.PracticeAcceptReq this.module.SendMsgToUser(string(this.module.GetType()), "qiecuonotify", &pb.PracticeQiecuonotifyPush{Uid: session.GetUserId(), NotifyType: 2}, req.Uid) _session, _ := this.module.GetUserSession(req.Uid) - go this.module.ModuleBuried.TriggerBuried(_session, comm.GetBuriedParam(comm.Rtype183, 1)) + go this.module.ModuleBuried.TriggerBuried(_session.Clone(), comm.GetBuriedParam(comm.Rtype183, 1)) return } diff --git a/modules/shop/api_buy.go b/modules/shop/api_buy.go index 0b784771e..c0aedfedb 100644 --- a/modules/shop/api_buy.go +++ b/modules/shop/api_buy.go @@ -86,7 +86,7 @@ func (this *apiComp) Buy(session comm.IUserSession, req *pb.ShopBuyReq) (errdata errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), - Message: err.Error(), + Message: "no found shop !", } return } diff --git a/modules/smithy/api_atlasactivate.go b/modules/smithy/api_atlasactivate.go index e91539926..db5349b53 100644 --- a/modules/smithy/api_atlasactivate.go +++ b/modules/smithy/api_atlasactivate.go @@ -117,7 +117,7 @@ func (this *apiComp) AtlasActivate(session comm.IUserSession, req *pb.SmithyAtla szTask = append(szTask, comm.GetBuriedParam(comm.Rtype165, 1)) szTask = append(szTask, comm.GetBuriedParam(comm.Rtype166, int32(len(atlas.Collect)))) szTask = append(szTask, comm.GetBuriedParam(comm.Rtype167, atlas.Score)) - this.module.ModuleBuried.TriggerBuried(session.Clone(), szTask...) + go this.module.ModuleBuried.TriggerBuried(session.Clone(), szTask...) session.SendMsg(string(this.module.GetType()), "atlasactivate", &pb.SmithyAtlasActivateResp{Data: atlas}) return } diff --git a/modules/smithy/api_forgeequip.go b/modules/smithy/api_forgeequip.go index bbf242547..5c897b565 100644 --- a/modules/smithy/api_forgeequip.go +++ b/modules/smithy/api_forgeequip.go @@ -295,7 +295,7 @@ func (this *apiComp) ForgeEquip(session comm.IUserSession, req *pb.SmithyForgeEq szTask = append(szTask, comm.GetBuriedParam(comm.Rtype177, 1)) szTask = append(szTask, comm.GetBuriedParam(comm.Rtype179, 1, nextProficiency.Value1)) - this.module.ModuleBuried.TriggerBuried(session.Clone(), szTask...) + go this.module.ModuleBuried.TriggerBuried(session.Clone(), szTask...) } // 是否解锁新套装 if nextProficiency.Type == comm.SmithyReelType4 { @@ -348,7 +348,7 @@ func (this *apiComp) ForgeEquip(session comm.IUserSession, req *pb.SmithyForgeEq tasks = append(tasks, comm.GetBuriedParam(comm.Rtype189, req.Count)) // 进行N次定制打造 } tasks = append(tasks, comm.GetBuriedParam(comm.Rtype148, req.Count)) - this.module.ModuleBuried.TriggerBuried(session.Clone(), tasks...) + go this.module.ModuleBuried.TriggerBuried(session.Clone(), tasks...) return } diff --git a/modules/smithy/api_rise.go b/modules/smithy/api_rise.go index ca37088b8..ce48edad9 100644 --- a/modules/smithy/api_rise.go +++ b/modules/smithy/api_rise.go @@ -87,7 +87,7 @@ func (this *apiComp) Rise(session comm.IUserSession, req *pb.SmithyRiseReq) (err } tasks := make([]*pb.BuriedParam, 0) tasks = append(tasks, comm.GetBuriedParam(comm.Rtype175, stove.Temperature)) - this.module.ModuleBuried.TriggerBuried(session.Clone(), tasks...) + go this.module.ModuleBuried.TriggerBuried(session.Clone(), tasks...) } return