anchor.diff:                  orddict:new(), AllSubs),
               orddict:to_list(Merged)
           end,
  -    mnesia:activity(transaction,Fun).
  +    mnesia:activity(transaction,Fun,[],mnesia_frag).
       %%mnesia:async_dirty(Fun).
   
   
  
positive.code:                     append_sub(R,ClientId,QoS)
              end
          end,
      ok = mnesia:activity(transaction,Fun).
  
  append_sub(R =  #mqtt_sub{subs = Subs}, ClientId,QoS) ->
      mnesia:write(R#mqtt_sub{subs = orddict:store(ClientId,QoS,Subs)}).
  
negative.code:                     end
              end
          end,
      ok = mnesia:activity(transaction,Fun,[],mnesia_frag).
  
  
  %% @doc
  