File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -576,7 +576,7 @@ impl PoolRefiller {
576576 req = use_keyspace_request_receiver. recv( ) => {
577577 if let Some ( req) = req {
578578 debug!( "[{}] Requested keyspace change: {}" , self . endpoint_description( ) , req. keyspace_name. as_str( ) ) ;
579- self . use_keyspace( & req. keyspace_name, req. response_sender) ;
579+ self . use_keyspace( req. keyspace_name, req. response_sender) ;
580580 } else {
581581 // The keyspace request channel is dropped.
582582 // This means that the corresponding pool is dropped.
@@ -1077,13 +1077,12 @@ impl PoolRefiller {
10771077 // have their keyspace set.
10781078 fn use_keyspace (
10791079 & mut self ,
1080- keyspace_name : & VerifiedKeyspaceName ,
1080+ keyspace_name : VerifiedKeyspaceName ,
10811081 response_sender : tokio:: sync:: oneshot:: Sender < Result < ( ) , QueryError > > ,
10821082 ) {
10831083 self . current_keyspace = Some ( keyspace_name. clone ( ) ) ;
10841084
10851085 let mut conns = self . conns . clone ( ) ;
1086- let keyspace_name = keyspace_name. clone ( ) ;
10871086 let address = self . endpoint . read ( ) . unwrap ( ) . address ( ) ;
10881087 let connect_timeout = self . pool_config . connection_config . connect_timeout ;
10891088
You can’t perform that action at this time.
0 commit comments