anchor.diff:                                  {_, _, MpMOwner} = MpM?MULTIPART_MANIFEST.owner,
                                   case CallerKeyId == MpMOwner of
                                       true ->
  -                                        do_part_common2(Op, RiakcPid, M,
  +                                        do_part_common2(Op, ?PID(RiakcPid), M,
                                                           Obj, MpM, Props);
                                       false ->
                                           {error, access_denied}
  
positive.code:         {upload_part_ready, PartUUID, PutPid}
      catch error:{badmatch, {m_umwc, _}} ->
              riak_cs_put_fsm:force_stop(PutPid),
              {error, todo_try_again_later}
      end;
  do_part_common2(upload_part_finished, RiakcPid, M, _Obj, MpM, Props) ->
      {PartUUID, MD5} = proplists:get_value(upload_part_finished, Props),
  
negative.code: %%% Internal functions
  %%%===================================================================
  
  do_part_common(Op, Bucket, Key, UploadId, {_,_,CallerKeyId} = _Caller, Props, RiakcPidUnW) ->
      case wrap_riak_connection(RiakcPidUnW) of
          {ok, RiakcPid} ->
              try
                  case riak_cs_utils:get_manifests(?PID(RiakcPid), Bucket, Key) of
                      {ok, Obj, Manifests} ->
                          case find_manifest_with_uploadid(UploadId, Manifests) of
                              false ->
  