Commit 71bff772 authored by hujiebin's avatar hujiebin

Update main.go

parent 0f76eaf8
...@@ -190,9 +190,9 @@ func (s *server) Multicast(ctx context.Context, in *userCenter.MulticastMessage) ...@@ -190,9 +190,9 @@ func (s *server) Multicast(ctx context.Context, in *userCenter.MulticastMessage)
failed = append(failed, uid) failed = append(failed, uid)
} }
} }
if len(failed) > 0 { //if len(failed) > 0 {
mylogrus.MyLog.Infof("Multicast failed for %v\n", failed) //mylogrus.MyLog.Infof("Multicast failed for %v\n", failed)
} //}
return &userCenter.MulticastMessageRsp{FailedUids: failed}, nil return &userCenter.MulticastMessageRsp{FailedUids: failed}, nil
} }
...@@ -496,7 +496,7 @@ func transmitMessage(c biz.TransmitterClient, msgType uint32, data string) (uint ...@@ -496,7 +496,7 @@ func transmitMessage(c biz.TransmitterClient, msgType uint32, data string) (uint
} }
func sendKickMessage(c userCenter.RouterClient, msg *userCenter.KickMessage) error { func sendKickMessage(c userCenter.RouterClient, msg *userCenter.KickMessage) error {
mylogrus.MyLog.Infof("sendKickMessage %s", msg.String()) //mylogrus.MyLog.Infof("sendKickMessage %s", msg.String())
ctx, cancel := context.WithTimeout(context.Background(), time.Second*3) ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
defer cancel() defer cancel()
r, err := c.KickUser(ctx, msg) r, err := c.KickUser(ctx, msg)
...@@ -637,8 +637,8 @@ func main() { ...@@ -637,8 +637,8 @@ func main() {
for { for {
select { select {
case a := <-ticker.C: case <-ticker.C:
mylogrus.MyLog.Infof("Tick at %s", a.String()) //mylogrus.MyLog.Infof("Tick at %s", a.String())
terminals := termManager.GetAll() terminals := termManager.GetAll()
if terminals != nil { if terminals != nil {
if len(*terminals) <= 100 { if len(*terminals) <= 100 {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment