anchor.diff:                  true ->
                     % TODO: add filePath
                     ReadEvent = [{"type", "read_event"}, {"user_dn", get(user_id)}, {"bytes", Size}],
  -                  gen_server:call(?Dispatcher_Name, {cluster_rengine, 1, {event_arrived, ReadEvent}});
  +                  gen_server:call(?Dispatcher_Name, {cluster_rengine, 1, {event_arrived, ReadEvent}}),
  +                  ReadEventStats = [{"type", "read_for_stats"}, {"user_dn", get(user_id)}, {"bytes", Size}],
  +                  gen_server:call(?Dispatcher_Name, {cluster_rengine, 1, {event_arrived, ReadEventStats}});
                   _ ->
                     ok
                 end;
  
positive.code:           case {is_integer(Res), event_production_enabled("write_event")} of
              {true, true} ->
                WriteEvent = [{"type", "write_event"}, {"user_dn", get(user_id)}, {"bytes", binary:referenced_byte_size(Buf)}],
                gen_server:call(?Dispatcher_Name, {cluster_rengine, 1, {event_arrived, WriteEvent}});
              _ ->
                ok
            end,
  
negative.code:           case {is_integer(Res), event_production_enabled("write_event")} of
              {true, true} ->
                WriteEvent = [{"type", "write_event"}, {"user_dn", get(user_id)}, {"count", binary:referenced_byte_size(Buf)}],
                gen_server:call(?Dispatcher_Name, {cluster_rengine, 1, {event_arrived, WriteEvent}}),
                WriteEventStats = [{"type", "write_for_stats"}, {"user_dn", get(user_id)}, {"bytes", binary:referenced_byte_size(Buf)}],
                gen_server:call(?Dispatcher_Name, {cluster_rengine, 1, {event_arrived, WriteEventStats}});
              _ ->
                ok
            end,
  