anchor.diff:                  {Node, FromPid} ->
                       case fully_connected(Node, Connections) of
                           true ->
  +                            lager:info("Node ~p is fully connected.", [Node]),
                               gen_server:reply(FromPid, ok),
                               lists:keydelete(FromPid, 2, SyncJoins0);
                           _ ->
  
positive.code: 
  %% @private
  fully_connected(Node, Connections) ->
      Parallelism = maps:get(parallelism, Node, ?PARALLELISM),
  
      Channels = case maps:get(channels, Node, [?DEFAULT_CHANNEL]) of
  
negative.code: 
      case partisan_peer_service_connections:find(Node, Connections) of
          {ok, Conns} ->
              Open = length(Conns),
              Required = length(Channels) * Parallelism,
              lager:info("Node ~p has ~p open connections, ~p required.", [Node, Open, Required]),
              Open =:= Required;
          _ ->
              false
      end.