File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -31,8 +31,6 @@ pub async fn register_validator<S: BuilderApiState>(
3131 . insert ( HEADER_START_TIME_UNIX_MS , HeaderValue :: from_str ( & utcnow_ms ( ) . to_string ( ) ) ?) ;
3232 send_headers. insert ( USER_AGENT , get_user_agent_with_version ( & req_headers) ?) ;
3333
34- let relays = state. all_relays ( ) . to_vec ( ) ;
35-
3634 // prepare the body in advance, ugly dyn
3735 let bodies: Box < dyn Iterator < Item = ( usize , Bytes ) > > =
3836 if let Some ( batch_size) = state. config . pbs_config . validator_registration_batch_size {
@@ -47,15 +45,15 @@ pub async fn register_validator<S: BuilderApiState>(
4745 } ;
4846 send_headers. insert ( CONTENT_TYPE , HeaderValue :: from_static ( "application/json" ) ) ;
4947
50- let mut handles = Vec :: with_capacity ( relays . len ( ) ) ;
48+ let mut handles = Vec :: with_capacity ( state . all_relays ( ) . len ( ) ) ;
5149
5250 for ( n_regs, body) in bodies {
53- for relay in relays . clone ( ) {
51+ for relay in state . all_relays ( ) . iter ( ) . cloned ( ) {
5452 handles. push ( tokio:: spawn (
5553 send_register_validator_with_timeout (
5654 n_regs,
5755 body. clone ( ) ,
58- relay. clone ( ) ,
56+ relay,
5957 send_headers. clone ( ) ,
6058 state. pbs_config ( ) . timeout_register_validator_ms ,
6159 state. pbs_config ( ) . register_validator_retry_limit ,
You can’t perform that action at this time.
0 commit comments