anchor.diff:      ?assertEqual(OpsNum, OkNum + ErrorNum),
       TmpTN = trunc(ThreadsNum/ConflictedThreads),
       WLength = length(Workers),
  -    NewTN= case {Level, Fun} of
  -               {local_only, _} ->
  -                   TmpTN * WLength;
  -               {locally_cached, create} ->
  -                   TmpTN * WLength;
  -               _ ->
  -                   TmpTN
  -           end,
  +    Multip = min(WLength, min(ThreadsNum, ConflictedThreads)),
  +    NewTN = case {Level, Fun} of
  +                {local_only, _} ->
  +                    TmpTN * Multip;
  +                {locally_cached, create} ->
  +                    TmpTN * Multip;
  +                _ ->
  +                    TmpTN
  +            end,
       ModelConfig = TestRecord:model_init(),
       case ModelConfig#model_config.transactional_global_cache of
           true ->
  
positive.code:                       AnsExt2 ++ [#parameter{name = doc_in_db, value = DocsInDB, unit = "us",
                            description = "Docs in datastore after test"},
                            #parameter{name = links_in_db, value = DocsInDB, unit = "us",
                            description = "Links in datastore after test"}
                        ]
                end,
  
  
negative.code: 
      TmpTN = trunc(ThreadsNum/ConflictedThreads),
      WLength = length(Workers),
      Multip = min(WLength, min(ThreadsNum, ConflictedThreads)),
      {NewTN, NewCT} = case Level of
                           local_only ->
                               {TmpTN * Multip, Multip};
                           locally_cached ->
                               {TmpTN * Multip, Multip};
                           _ ->
                               {TmpTN, 1}
                       end,
  