anchor.diff:  %%
   %% -spec handle_command({append, log_id(), #log_operation{}, boolean()}, pid(), #state{}) ->
   %%                      {reply, {ok, #op_number{}} #state{}} | {reply, error(), #state{}}.
  -handle_command({append, LogId, LogOperation, Sync}, _Sender,
  -               #state{logs_map=Map,
  -                      op_id_table=OpIdTable,
  -                      partition=Partition,
  -              enable_log_to_disk=EnableLog}=State) ->
  +handle_command({append, LogId, LogOperation, Sync}, _Sender, #state{
  +    logs_map = Map,
  +    partition = Partition,
  +    op_id_table = OpIdTable,
  +    enable_log_to_disk = EnableLog,
  +    pvc_commit_cache = PVCCommitCache
  +} = State) ->
  +
       case get_log_from_map(Map, Partition, LogId) of
           {ok, Log} ->
               MyDCID = dc_meta_data_utilities:get_my_dc_id(),
  
positive.code:                     NewBOpId = BOpId#op_number{local = BLocal + 1, global = BGlobal + 1},
                      true = update_ets_op_id({LogId, Bucket, MyDCID}, NewBOpId, OpIdTable),
                      NewBOpId;
                  _ ->
                      NewOpId
              end,
              LogRecord = #log_record{
                  version = log_utilities:log_record_version(),
                  op_number = NewOpId,
                  bucket_op_number = NewBucketOpId,
                  log_operation = LogOperation
              },
              case insert_log_record(Log, LogId, LogRecord, EnableLog) of
                  {ok, NewOpId} ->
                      inter_dc_log_sender_vnode:send(Partition, LogRecord),
  
negative.code:             #op_number{local = Local, global = Global} = OpId,
              NewOpId = OpId#op_number{local =  Local + 1, global = Global + 1},
              true = update_ets_op_id({LogId, MyDCID}, NewOpId, OpIdTable),
  
              %% Set up an in-memory CLog for PVC when log is disabled
              OperationType = LogOperation#log_operation.op_type,
              ok = case {OperationType, EnableLog} of
                   {commit, false} ->
                      CommitPayload = LogOperation#log_operation.log_payload,
                      true = ets:insert(PVCCommitCache, {Log, CommitPayload}),
                      ok;
                  _ ->
                      ok
              end,
  
              %% non commit operations update the bucket id number to keep track
              %% of the number of updates per bucket
              NewBucketOpId = case OperationType of
                  update ->
                      Bucket = (LogOperation#log_operation.log_payload)#update_log_payload.bucket,
                      BOpId = get_op_id(OpIdTable, {LogId, Bucket, MyDCID}),
  