anchor.diff:            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}});
  +              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,
  
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:                 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}}),
                    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;
  