@@ -84,6 +84,8 @@ impl UserService {
84
84
) ;
85
85
}
86
86
87
+ let socket_addr = socket. peer_addr ( ) . unwrap ( ) ;
88
+
87
89
UserService {
88
90
logger,
89
91
socket,
@@ -93,7 +95,7 @@ impl UserService {
93
95
database,
94
96
ban_manager,
95
97
username : None ,
96
- socket_addr : None ,
98
+ socket_addr : Some ( socket_addr ) ,
97
99
time_of_last_received_packet : Local :: now ( ) ,
98
100
}
99
101
}
@@ -119,6 +121,8 @@ impl UserService {
119
121
) ;
120
122
}
121
123
124
+ let socket_addr = socket. peer_addr ( ) . unwrap ( ) ;
125
+
122
126
UserService {
123
127
logger,
124
128
socket,
@@ -127,7 +131,7 @@ impl UserService {
127
131
secret_key : [ 0 ; SECRET_KEY_SIZE ] ,
128
132
database,
129
133
ban_manager : None ,
130
- socket_addr : None ,
134
+ socket_addr : Some ( socket_addr ) ,
131
135
username : None ,
132
136
time_of_last_received_packet : Local :: now ( ) ,
133
137
}
@@ -168,8 +172,6 @@ impl UserService {
168
172
}
169
173
let packet = packet. unwrap ( ) ;
170
174
171
- self . socket_addr = Some ( self . socket . peer_addr ( ) . unwrap ( ) ) ;
172
-
173
175
let result = self . handle_reporter_packet ( packet) ;
174
176
if let Err ( app_error) = result {
175
177
self . exit_error = Some ( Err ( app_error. add_entry ( file ! ( ) , line ! ( ) ) ) ) ;
@@ -233,9 +235,6 @@ impl UserService {
233
235
return ;
234
236
}
235
237
236
- // Save address.
237
- self . socket_addr = Some ( self . socket . peer_addr ( ) . unwrap ( ) ) ;
238
-
239
238
// Connected.
240
239
let result = self . wait_for_client_requests ( ) ;
241
240
if let Err ( app_error) = result {
0 commit comments