File tree Expand file tree Collapse file tree 1 file changed +9
-6
lines changed
Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -295,12 +295,8 @@ fn cancel_timer(timer: Option(process.Timer)) -> Nil {
295295}
296296
297297fn refresh_nodes ( barnacle : Barnacle ( error) ) -> RefreshResult ( error) {
298- use available_nodes <- result . try (
298+ use available_nodes_list <- result . try (
299299 barnacle . strategy . discover_nodes ( )
300- |> result . map ( fn ( nodes ) {
301- set . from_list ( nodes )
302- |> set . delete ( node . self ( ) |> node . to_atom )
303- } )
304300 |> result . map_error ( StrategyError ) ,
305301 )
306302
@@ -309,10 +305,17 @@ fn refresh_nodes(barnacle: Barnacle(error)) -> RefreshResult(error) {
309305 |> result . map_error ( StrategyError ) ,
310306 )
311307
308+ let self = node . self ( ) |> node . to_atom
309+
310+ let available_nodes =
311+ available_nodes_list
312+ |> set . from_list
313+ |> set . delete ( self )
314+
312315 let current_nodes =
313316 current_nodes_list
314317 |> set . from_list
315- |> set . delete ( node . self ( ) |> node . to_atom )
318+ |> set . delete ( self )
316319
317320 let nodes_to_add = set . difference ( available_nodes , current_nodes )
318321 let nodes_to_remove = set . difference ( current_nodes , available_nodes )
You can’t perform that action at this time.
0 commit comments