anchor.diff:                               bucket=Bucket,
                                riakc_pid=RiakPid}) ->
       dt_entry(<<"accept_body">>, [], [extract_name(User), Bucket]),
  +    dt_entry_bucket(<<"create">>, [], [extract_name(User), Bucket]),
       %% Check for `x-amz-acl' header to support
       %% non-default ACL at bucket creation time.
       ACL = riak_moss_acl_utils:canned_acl(
  
positive.code:                                        RiakPid) of
          ok ->
              dt_return(<<"accept_body">>, [200], [extract_name(User), Bucket]),
              {{halt, 200}, RD, Ctx};
          {error, Reason} ->
              Code = riak_moss_s3_response:status_code(Reason),
              dt_return(<<"accept_body">>, [Code], [extract_name(User)]),
              riak_moss_s3_response:api_error(Reason, RD, Ctx)
      end.
  
  
negative.code:                                  bucket=Bucket,
                                   riakc_pid=RiakPid}) ->
      dt_entry(<<"delete_resource">>, [], [extract_name(User), Bucket]),
      dt_entry_bucket(<<"delete">>, [], [extract_name(User), Bucket]),
      case riak_moss_utils:delete_bucket(User,
                                         VClock,
                                         Bucket,
                                         RiakPid) of
          ok ->
              dt_return(<<"delete_resource">>, [200], [extract_name(User), Bucket]),
              dt_return_bucket(<<"delete">>, [200], [extract_name(User), Bucket]),
              {true, RD, Ctx};
          {error, Reason} ->
              Code = riak_moss_s3_response:status_code(Reason),
              dt_return(<<"delete_resource">>, [Code], [extract_name(User), Bucket]),
              dt_return_bucket(<<"delete">>, [Code], [extract_name(User), Bucket]),
              riak_moss_s3_response:api_error(Reason, RD, Ctx)
      end.
  
  