anchor.diff:  mock_node_up(CallNode, ExecuteNode, BrokenNode) ->
       ?assertEqual(ok, rpc:call(CallNode, consistent_hashing, set_fixed_node, [BrokenNode])),
       set_ha(ExecuteNode, master_up, []).
  +
  +check_update(Node, Value) ->
  +    Rec = receive
  +        {update, _, _} = Message -> Message
  +    after
  +        5000 -> timeout
  +    end,
  +    ?assertEqual({update, Value, Node}, Rec).
   
   %%%===================================================================
   %%% HA stress tests
  
positive.code:         ?assertEqual(ok, rpc:call(Worker, consistent_hashing, set_fixed_node, [FixedWorker]))
      end, Workers),
      set_ha(Config, master_up, []),
      set_ha(Config, change_config, [1, cast]);
  end_per_testcase(Case, Config) ->
      case lists:suffix("ha_test", atom_to_list(Case)) of
          true ->
  
negative.code:             )
      end.
  
  assert_value_in_memory(Worker, Model, Key, Value) ->
      case ?MEM_DRV(Model) of
          undefined ->
              ok;
          Driver ->
              Ctx = datastore_multiplier:extend_name(?UNIQUE_KEY(Model, Key),
                  ?MEM_CTX(Model)),
              ?assertMatch({ok, #document{deleted = false, value = {_, Value, _, _}}},
                  rpc:call(Worker, Driver, get, [
                      Ctx, ?UNIQUE_KEY(Model, Key)
                  ]), 5
              )
      end.
  
  assert_not_in_memory(Worker, Model, Key) ->
      case ?MEM_DRV(Model) of
          undefined ->
  