@@ -121,7 +121,8 @@ func WtfConnect(sc SlaveConfig, pool *redis.Pool, jobPool *redis.Pool, rHub *red
121
121
t1 := time .Now ()
122
122
logger .WithFields (logrus.Fields {
123
123
"socket_id" : s .SocketId (),
124
- "userid" : auth .UserId ,
124
+ "conn_at" : t1 ,
125
+ "user_id" : auth .UserId ,
125
126
}).Info ("connect" )
126
127
s .Listen (func (data []byte ) (b []byte , err error ) {
127
128
h , err := CommanRouter (data , jobPool )
@@ -158,11 +159,12 @@ func WtfConnect(sc SlaveConfig, pool *redis.Pool, jobPool *redis.Pool, rHub *red
158
159
})
159
160
t2 := time .Now ()
160
161
logger .WithFields (logrus.Fields {
161
- "conn_at" : t1 ,
162
- "conn_end" : t2 ,
163
- "socket_id" : s .SocketId (),
164
- "userid" : auth .UserId ,
165
- "conn_duration" : fmt .Sprintf ("%v" , t2 .Sub (t1 )),
162
+ "conn_at" : t1 ,
163
+ "conn_end" : t2 ,
164
+ "socket_id" : s .SocketId (),
165
+ "user_id" : auth .UserId ,
166
+ "conn_duration" : fmt .Sprintf ("%v" , t2 .Sub (t1 )),
167
+ "conn_duration_nano" : fmt .Sprintf ("%d" , t2 .Sub (t1 )),
166
168
}).Info ("disconnect" )
167
169
return
168
170
}
@@ -209,8 +211,9 @@ func WsConnect(sc SlaveConfig, pool *redis.Pool, jobPool *redis.Pool, rHub *redi
209
211
210
212
t1 := time .Now ()
211
213
logger .WithFields (logrus.Fields {
214
+ "conn_at" : t1 ,
212
215
"socket_id" : s .SocketId (),
213
- "userid" : auth .UserId ,
216
+ "user_id" : auth .UserId ,
214
217
}).Info ("connect" )
215
218
s .Listen (func (data []byte ) (b []byte , err error ) {
216
219
h , err := CommanRouter (data , jobPool )
@@ -248,11 +251,12 @@ func WsConnect(sc SlaveConfig, pool *redis.Pool, jobPool *redis.Pool, rHub *redi
248
251
t2 := time .Now ()
249
252
logger .WithFields (
250
253
logrus.Fields {
251
- "conn_at" : t1 ,
252
- "conn_end" : t2 ,
253
- "socket_id" : s .SocketId (),
254
- "userid" : auth .UserId ,
255
- "conn_duration" : fmt .Sprintf ("%v" , t2 .Sub (t1 )),
254
+ "conn_at" : t1 ,
255
+ "conn_end" : t2 ,
256
+ "socket_id" : s .SocketId (),
257
+ "user_id" : auth .UserId ,
258
+ "conn_duration" : fmt .Sprintf ("%v" , t2 .Sub (t1 )),
259
+ "conn_duration_nano" : fmt .Sprintf ("%d" , t2 .Sub (t1 )),
256
260
}).Info ("disconnect" )
257
261
return
258
262
}
0 commit comments