Skip to content
This repository has been archived by the owner on Dec 2, 2023. It is now read-only.

Commit

Permalink
(fix): debug docker redis
Browse files Browse the repository at this point in the history
  • Loading branch information
adwpc committed Nov 8, 2021
1 parent 5ed26f4 commit ddefdac
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 2 additions & 0 deletions apps/room/server/room.go
Original file line number Diff line number Diff line change
Expand Up @@ -140,6 +140,7 @@ func (r *RoomServer) StartGRPC(registrar grpc.ServiceRegistrar) error {

r.natsDiscoveryCli = ndc
r.natsConn = nil
log.Infof("NewRoomService r.conf.Redis=%+v r.redis=%+v", r.conf.Redis, r.redis)
r.RoomService = *NewRoomService(r.conf.Redis)
r.RoomSignalService = *NewRoomSignalService(&r.RoomService)

Expand Down Expand Up @@ -171,6 +172,7 @@ func (r *RoomServer) Start() error {
r.natsDiscoveryCli = ndc
r.natsConn = r.NatsConn()
r.RoomService = *NewRoomService(r.conf.Redis)
log.Infof("NewRoomService r.conf.Redis=%+v r.redis=%+v", r.conf.Redis, r.redis)
r.RoomSignalService = *NewRoomSignalService(&r.RoomService)

if err != nil {
Expand Down
2 changes: 1 addition & 1 deletion apps/room/server/room_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -321,7 +321,7 @@ func (s *RoomService) UpdatePeer(ctx context.Context, in *room.UpdatePeerRequest
}

// check peer exist
log.Infof("sid=%v uid=v", sid, uid)
log.Infof("sid=%v uid=%v", sid, uid)
key = util.GetRedisPeerKey(sid, uid)
if s.redis.HGet(key, "uid") == "" {
return &room.UpdatePeerReply{
Expand Down

0 comments on commit ddefdac

Please sign in to comment.