anchor.diff:  
       case partisan_peer_service_connections:find(Node, Connections) of
           {ok, Conns} ->
  -            length(Conns) =:= (length(Channels) * Parallelism);
  +            Open = length(Conns),
  +            Required = length(Channels) * Parallelism,
  +            lager:info("Node ~p has ~p open connections, ~p required.", [Node, Open, Required]),
  +            Open =:= Required;
           _ ->
               false
       end.
positive.code:             {reply, ok, State}
      end;
  
  handle_call({join, #{name := _Name} = Node},
              _From,
              State0) ->
      %% Perform join.
      State = internal_join(Node, State0),
  
      %% Return.
      {reply, ok, State};
  
  handle_call({sync_join, #{name := _Name} = Node},
              From,
              State0) ->
      %% Perform join.
      State = sync_internal_join(Node, From, State0),
  
      %% Return.
      {noreply, State};
  
  handle_call({send_message, Name, Channel, Message}, _From,
              #state{connections=Connections}=State) ->
  
negative.code:                       membership=Membership0,
                        sync_joins=SyncJoins0,
                        connections=Connections}=State) ->
      lager:info("Node ~p connected!", [Node]),
  
      case lists:member(Node, Pending0) of
          true ->
              %% Move out of pending.
  