ContainerRestClient
class ContainerRestClient
using Azure.Core;
using Azure.Core.Pipeline;
using Azure.Storage.Blobs.Models;
using Azure.Storage.Common;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;
using System.Xml.Linq;
namespace Azure.Storage.Blobs
{
internal class ContainerRestClient
{
private readonly HttpPipeline _pipeline;
private readonly string _url;
private readonly string _version;
private static ResponseClassifier _responseClassifier201;
internal ClientDiagnostics ClientDiagnostics { get; }
private unsafe static ResponseClassifier ResponseClassifier201 {
get {
ResponseClassifier val = _responseClassifier201;
if (val == null) {
byte* intPtr = stackalloc byte[2];
*(short*)intPtr = 201;
StatusCodeClassifier val2 = new StatusCodeClassifier((ReadOnlySpan<ushort>)new Span<ushort>(intPtr, 1));
_responseClassifier201 = val2;
val = val2;
}
return val;
}
}
public ContainerRestClient(ClientDiagnostics clientDiagnostics, HttpPipeline pipeline, string url, string version)
{
if (clientDiagnostics == null)
throw new ArgumentNullException("clientDiagnostics");
ClientDiagnostics = clientDiagnostics;
if (pipeline == null)
throw new ArgumentNullException("pipeline");
_pipeline = pipeline;
if (url == null)
throw new ArgumentNullException("url");
_url = url;
if (version == null)
throw new ArgumentNullException("version");
_version = version;
}
internal HttpMessage CreateCreateRequest(int? timeout, IDictionary<string, string> metadata, PublicAccessType? access, string defaultEncryptionScope, bool? preventEncryptionScopeOverride)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
if (metadata != null)
val2.get_Headers().Add("x-ms-meta-", metadata);
RequestHeaders headers;
if (access.HasValue) {
headers = val2.get_Headers();
headers.Add("x-ms-blob-public-access", access.Value.ToSerialString());
}
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
if (defaultEncryptionScope != null) {
headers = val2.get_Headers();
headers.Add("x-ms-default-encryption-scope", defaultEncryptionScope);
}
if (preventEncryptionScopeOverride.HasValue)
val2.get_Headers().Add("x-ms-deny-encryption-scope-override", preventEncryptionScopeOverride.Value);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<CreateAsync>d__8))]
public Task<ResponseWithHeaders<ContainerCreateHeaders>> CreateAsync(int? timeout = default(int?), IDictionary<string, string> metadata = null, PublicAccessType? access = default(PublicAccessType?), string defaultEncryptionScope = null, bool? preventEncryptionScopeOverride = default(bool?), CancellationToken cancellationToken = default(CancellationToken))
{
<CreateAsync>d__8 stateMachine = default(<CreateAsync>d__8);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerCreateHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.metadata = metadata;
stateMachine.access = access;
stateMachine.defaultEncryptionScope = defaultEncryptionScope;
stateMachine.preventEncryptionScopeOverride = preventEncryptionScopeOverride;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerCreateHeaders> Create(int? timeout = default(int?), IDictionary<string, string> metadata = null, PublicAccessType? access = default(PublicAccessType?), string defaultEncryptionScope = null, bool? preventEncryptionScopeOverride = default(bool?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateCreateRequest(timeout, metadata, access, defaultEncryptionScope, preventEncryptionScopeOverride);
try {
_pipeline.Send(val, cancellationToken);
ContainerCreateHeaders headers = new ContainerCreateHeaders(val.get_Response());
if (val.get_Response().get_Status() != 201)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateGetPropertiesRequest(int? timeout, string leaseId)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers;
if (leaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
}
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<GetPropertiesAsync>d__11))]
public Task<ResponseWithHeaders<ContainerGetPropertiesHeaders>> GetPropertiesAsync(int? timeout = default(int?), string leaseId = null, CancellationToken cancellationToken = default(CancellationToken))
{
<GetPropertiesAsync>d__11 stateMachine = default(<GetPropertiesAsync>d__11);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerGetPropertiesHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.leaseId = leaseId;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerGetPropertiesHeaders> GetProperties(int? timeout = default(int?), string leaseId = null, CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateGetPropertiesRequest(timeout, leaseId);
try {
_pipeline.Send(val, cancellationToken);
ContainerGetPropertiesHeaders headers = new ContainerGetPropertiesHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateDeleteRequest(int? timeout, string leaseId, DateTimeOffset? ifModifiedSince, DateTimeOffset? ifUnmodifiedSince)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Delete());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers;
if (leaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
}
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
if (ifUnmodifiedSince.HasValue)
val2.get_Headers().Add("If-Unmodified-Since", ifUnmodifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<DeleteAsync>d__14))]
public Task<ResponseWithHeaders<ContainerDeleteHeaders>> DeleteAsync(int? timeout = default(int?), string leaseId = null, DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
<DeleteAsync>d__14 stateMachine = default(<DeleteAsync>d__14);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerDeleteHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.leaseId = leaseId;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.ifUnmodifiedSince = ifUnmodifiedSince;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerDeleteHeaders> Delete(int? timeout = default(int?), string leaseId = null, DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateDeleteRequest(timeout, leaseId, ifModifiedSince, ifUnmodifiedSince);
try {
_pipeline.Send(val, cancellationToken);
ContainerDeleteHeaders headers = new ContainerDeleteHeaders(val.get_Response());
if (val.get_Response().get_Status() != 202)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateSetMetadataRequest(int? timeout, string leaseId, IDictionary<string, string> metadata, DateTimeOffset? ifModifiedSince)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "metadata", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers;
if (leaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
}
if (metadata != null)
val2.get_Headers().Add("x-ms-meta-", metadata);
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<SetMetadataAsync>d__17))]
public Task<ResponseWithHeaders<ContainerSetMetadataHeaders>> SetMetadataAsync(int? timeout = default(int?), string leaseId = null, IDictionary<string, string> metadata = null, DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
<SetMetadataAsync>d__17 stateMachine = default(<SetMetadataAsync>d__17);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerSetMetadataHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.leaseId = leaseId;
stateMachine.metadata = metadata;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerSetMetadataHeaders> SetMetadata(int? timeout = default(int?), string leaseId = null, IDictionary<string, string> metadata = null, DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateSetMetadataRequest(timeout, leaseId, metadata, ifModifiedSince);
try {
_pipeline.Send(val, cancellationToken);
ContainerSetMetadataHeaders headers = new ContainerSetMetadataHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateGetAccessPolicyRequest(int? timeout, string leaseId)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "acl", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers;
if (leaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
}
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<GetAccessPolicyAsync>d__20))]
public Task<ResponseWithHeaders<IReadOnlyList<BlobSignedIdentifier>, ContainerGetAccessPolicyHeaders>> GetAccessPolicyAsync(int? timeout = default(int?), string leaseId = null, CancellationToken cancellationToken = default(CancellationToken))
{
<GetAccessPolicyAsync>d__20 stateMachine = default(<GetAccessPolicyAsync>d__20);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<IReadOnlyList<BlobSignedIdentifier>, ContainerGetAccessPolicyHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.leaseId = leaseId;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<IReadOnlyList<BlobSignedIdentifier>, ContainerGetAccessPolicyHeaders> GetAccessPolicy(int? timeout = default(int?), string leaseId = null, CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateGetAccessPolicyRequest(timeout, leaseId);
try {
_pipeline.Send(val, cancellationToken);
ContainerGetAccessPolicyHeaders headers = new ContainerGetAccessPolicyHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
IReadOnlyList<BlobSignedIdentifier> value = null;
XElement xElement = XDocument.Load(val.get_Response().get_ContentStream(), LoadOptions.PreserveWhitespace).Element("SignedIdentifiers");
if (xElement != null) {
List<BlobSignedIdentifier> list = new List<BlobSignedIdentifier>();
foreach (XElement item in xElement.Elements("SignedIdentifier")) {
list.Add(BlobSignedIdentifier.DeserializeBlobSignedIdentifier(item));
}
value = list;
}
return ResponseWithHeaders.FromValue(value, headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateSetAccessPolicyRequest(int? timeout, string leaseId, PublicAccessType? access, DateTimeOffset? ifModifiedSince, DateTimeOffset? ifUnmodifiedSince, IEnumerable<BlobSignedIdentifier> containerAcl)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "acl", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers;
if (leaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
}
if (access.HasValue) {
headers = val2.get_Headers();
headers.Add("x-ms-blob-public-access", access.Value.ToSerialString());
}
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
if (ifUnmodifiedSince.HasValue)
val2.get_Headers().Add("If-Unmodified-Since", ifUnmodifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
if (containerAcl != null) {
headers = val2.get_Headers();
headers.Add("Content-Type", "application/xml");
XmlWriterContent xmlWriterContent = new XmlWriterContent();
xmlWriterContent.XmlWriter.WriteStartElement("SignedIdentifiers");
foreach (BlobSignedIdentifier item in containerAcl) {
xmlWriterContent.XmlWriter.WriteObjectValue(item, "SignedIdentifier");
}
xmlWriterContent.XmlWriter.WriteEndElement();
val2.set_Content(xmlWriterContent);
}
return val;
}
[AsyncStateMachine(typeof(<SetAccessPolicyAsync>d__23))]
public Task<ResponseWithHeaders<ContainerSetAccessPolicyHeaders>> SetAccessPolicyAsync(int? timeout = default(int?), string leaseId = null, PublicAccessType? access = default(PublicAccessType?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), IEnumerable<BlobSignedIdentifier> containerAcl = null, CancellationToken cancellationToken = default(CancellationToken))
{
<SetAccessPolicyAsync>d__23 stateMachine = default(<SetAccessPolicyAsync>d__23);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerSetAccessPolicyHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.leaseId = leaseId;
stateMachine.access = access;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.ifUnmodifiedSince = ifUnmodifiedSince;
stateMachine.containerAcl = containerAcl;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerSetAccessPolicyHeaders> SetAccessPolicy(int? timeout = default(int?), string leaseId = null, PublicAccessType? access = default(PublicAccessType?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), IEnumerable<BlobSignedIdentifier> containerAcl = null, CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateSetAccessPolicyRequest(timeout, leaseId, access, ifModifiedSince, ifUnmodifiedSince, containerAcl);
try {
_pipeline.Send(val, cancellationToken);
ContainerSetAccessPolicyHeaders headers = new ContainerSetAccessPolicyHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateRestoreRequest(int? timeout, string deletedContainerName, string deletedContainerVersion)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "undelete", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
if (deletedContainerName != null) {
headers = val2.get_Headers();
headers.Add("x-ms-deleted-container-name", deletedContainerName);
}
if (deletedContainerVersion != null) {
headers = val2.get_Headers();
headers.Add("x-ms-deleted-container-version", deletedContainerVersion);
}
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<RestoreAsync>d__26))]
public Task<ResponseWithHeaders<ContainerRestoreHeaders>> RestoreAsync(int? timeout = default(int?), string deletedContainerName = null, string deletedContainerVersion = null, CancellationToken cancellationToken = default(CancellationToken))
{
<RestoreAsync>d__26 stateMachine = default(<RestoreAsync>d__26);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerRestoreHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.deletedContainerName = deletedContainerName;
stateMachine.deletedContainerVersion = deletedContainerVersion;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerRestoreHeaders> Restore(int? timeout = default(int?), string deletedContainerName = null, string deletedContainerVersion = null, CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateRestoreRequest(timeout, deletedContainerName, deletedContainerVersion);
try {
_pipeline.Send(val, cancellationToken);
ContainerRestoreHeaders headers = new ContainerRestoreHeaders(val.get_Response());
if (val.get_Response().get_Status() != 201)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateRenameRequest(string sourceContainerName, int? timeout, string sourceLeaseId)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "rename", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("x-ms-source-container-name", sourceContainerName);
if (sourceLeaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-source-lease-id", sourceLeaseId);
}
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<RenameAsync>d__29))]
public Task<ResponseWithHeaders<ContainerRenameHeaders>> RenameAsync(string sourceContainerName, int? timeout = default(int?), string sourceLeaseId = null, CancellationToken cancellationToken = default(CancellationToken))
{
<RenameAsync>d__29 stateMachine = default(<RenameAsync>d__29);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerRenameHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.sourceContainerName = sourceContainerName;
stateMachine.timeout = timeout;
stateMachine.sourceLeaseId = sourceLeaseId;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerRenameHeaders> Rename(string sourceContainerName, int? timeout = default(int?), string sourceLeaseId = null, CancellationToken cancellationToken = default(CancellationToken))
{
if (sourceContainerName != null) {
HttpMessage val = CreateRenameRequest(sourceContainerName, timeout, sourceLeaseId);
try {
_pipeline.Send(val, cancellationToken);
ContainerRenameHeaders headers = new ContainerRenameHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
throw new ArgumentNullException("sourceContainerName");
}
internal HttpMessage CreateSubmitBatchRequest(long contentLength, string multipartContentType, Stream body, int? timeout)
{
HttpMessage val = _pipeline.CreateMessage();
Request request = val.get_Request();
request.set_Method(RequestMethod.get_Post());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "batch", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
request.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = request.get_Headers();
headers.Add("x-ms-version", _version);
headers = request.get_Headers();
headers.Add("Accept", "application/xml");
request.get_Headers().Add("Content-Length", contentLength);
headers = request.get_Headers();
headers.Add("Content-Type", multipartContentType);
request.set_Content(RequestContent.Create(body));
return val;
}
[AsyncStateMachine(typeof(<SubmitBatchAsync>d__32))]
public Task<ResponseWithHeaders<Stream, ContainerSubmitBatchHeaders>> SubmitBatchAsync(long contentLength, string multipartContentType, Stream body, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
<SubmitBatchAsync>d__32 stateMachine = default(<SubmitBatchAsync>d__32);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<Stream, ContainerSubmitBatchHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.contentLength = contentLength;
stateMachine.multipartContentType = multipartContentType;
stateMachine.body = body;
stateMachine.timeout = timeout;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<Stream, ContainerSubmitBatchHeaders> SubmitBatch(long contentLength, string multipartContentType, Stream body, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
if (multipartContentType == null)
throw new ArgumentNullException("multipartContentType");
if (body != null) {
HttpMessage val = CreateSubmitBatchRequest(contentLength, multipartContentType, body, timeout);
try {
_pipeline.Send(val, cancellationToken);
ContainerSubmitBatchHeaders headers = new ContainerSubmitBatchHeaders(val.get_Response());
if (val.get_Response().get_Status() != 202)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(val.ExtractResponseContent(), headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
throw new ArgumentNullException("body");
}
internal HttpMessage CreateFilterBlobsRequest(int? timeout, string where, string marker, int? maxresults, IEnumerable<FilterBlobsIncludeItem> include)
{
HttpMessage val = _pipeline.CreateMessage();
Request request = val.get_Request();
request.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "blobs", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
if (where != null)
rawRequestUriBuilder.AppendQuery("where", where, true);
if (marker != null)
rawRequestUriBuilder.AppendQuery("marker", marker, true);
if (maxresults.HasValue)
rawRequestUriBuilder.AppendQuery("maxresults", maxresults.Value, true);
if (include != null) {
ChangeTrackingList<FilterBlobsIncludeItem> changeTrackingList = include as ChangeTrackingList<FilterBlobsIncludeItem>;
if (changeTrackingList == null || !changeTrackingList.IsUndefined)
RequestUriBuilderExtensions.AppendQueryDelimited(rawRequestUriBuilder, "include", include, ",", true);
}
request.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = request.get_Headers();
headers.Add("x-ms-version", _version);
headers = request.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<FilterBlobsAsync>d__35))]
public Task<ResponseWithHeaders<FilterBlobSegment, ContainerFilterBlobsHeaders>> FilterBlobsAsync(int? timeout = default(int?), string where = null, string marker = null, int? maxresults = default(int?), IEnumerable<FilterBlobsIncludeItem> include = null, CancellationToken cancellationToken = default(CancellationToken))
{
<FilterBlobsAsync>d__35 stateMachine = default(<FilterBlobsAsync>d__35);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<FilterBlobSegment, ContainerFilterBlobsHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.where = where;
stateMachine.marker = marker;
stateMachine.maxresults = maxresults;
stateMachine.include = include;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<FilterBlobSegment, ContainerFilterBlobsHeaders> FilterBlobs(int? timeout = default(int?), string where = null, string marker = null, int? maxresults = default(int?), IEnumerable<FilterBlobsIncludeItem> include = null, CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateFilterBlobsRequest(timeout, where, marker, maxresults, include);
try {
_pipeline.Send(val, cancellationToken);
ContainerFilterBlobsHeaders headers = new ContainerFilterBlobsHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
FilterBlobSegment value = null;
XElement xElement = XDocument.Load(val.get_Response().get_ContentStream(), LoadOptions.PreserveWhitespace).Element("EnumerationResults");
if (xElement != null)
value = FilterBlobSegment.DeserializeFilterBlobSegment(xElement);
return ResponseWithHeaders.FromValue(value, headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateAcquireLeaseRequest(int? timeout, long? duration, string proposedLeaseId, DateTimeOffset? ifModifiedSince, DateTimeOffset? ifUnmodifiedSince)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("comp", "lease", true);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-lease-action", "acquire");
if (duration.HasValue)
val2.get_Headers().Add("x-ms-lease-duration", duration.Value);
if (proposedLeaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-proposed-lease-id", proposedLeaseId);
}
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
if (ifUnmodifiedSince.HasValue)
val2.get_Headers().Add("If-Unmodified-Since", ifUnmodifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<AcquireLeaseAsync>d__38))]
public Task<ResponseWithHeaders<ContainerAcquireLeaseHeaders>> AcquireLeaseAsync(int? timeout = default(int?), long? duration = default(long?), string proposedLeaseId = null, DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
<AcquireLeaseAsync>d__38 stateMachine = default(<AcquireLeaseAsync>d__38);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerAcquireLeaseHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.duration = duration;
stateMachine.proposedLeaseId = proposedLeaseId;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.ifUnmodifiedSince = ifUnmodifiedSince;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerAcquireLeaseHeaders> AcquireLease(int? timeout = default(int?), long? duration = default(long?), string proposedLeaseId = null, DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateAcquireLeaseRequest(timeout, duration, proposedLeaseId, ifModifiedSince, ifUnmodifiedSince);
try {
_pipeline.Send(val, cancellationToken);
ContainerAcquireLeaseHeaders headers = new ContainerAcquireLeaseHeaders(val.get_Response());
if (val.get_Response().get_Status() != 201)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateAcquireLeaseRequest(int? timeout, long? duration, string proposedLeaseId, RequestConditions requestConditions, RequestContext context)
{
HttpMessage val = _pipeline.CreateMessage(context, ResponseClassifier201);
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("comp", "lease", true);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-lease-action", "acquire");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
if (duration.HasValue)
val2.get_Headers().Add("x-ms-lease-duration", duration.Value);
if (proposedLeaseId != null) {
headers = val2.get_Headers();
headers.Add("x-ms-proposed-lease-id", proposedLeaseId);
}
if (requestConditions != null)
val2.get_Headers().Add(requestConditions, "R");
return val;
}
[AsyncStateMachine(typeof(<AcquireLeaseAsync>d__41))]
public virtual Task<Response> AcquireLeaseAsync(int? timeout = default(int?), long? duration = default(long?), string proposedLeaseId = null, RequestConditions requestConditions = null, RequestContext context = null)
{
<AcquireLeaseAsync>d__41 stateMachine = default(<AcquireLeaseAsync>d__41);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<Response>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.duration = duration;
stateMachine.proposedLeaseId = proposedLeaseId;
stateMachine.requestConditions = requestConditions;
stateMachine.context = context;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public virtual Response AcquireLease(int? timeout = default(int?), long? duration = default(long?), string proposedLeaseId = null, RequestConditions requestConditions = null, RequestContext context = null)
{
if (((requestConditions != null) ? requestConditions.get_IfMatch() : null).HasValue)
throw new ArgumentNullException("requestConditions", "Service does not support the If-Match header for this operation.");
if (((requestConditions != null) ? requestConditions.get_IfNoneMatch() : null).HasValue)
throw new ArgumentNullException("requestConditions", "Service does not support the If-None-Match header for this operation.");
using (DiagnosticScope diagnosticScope = ClientDiagnostics.CreateScope("Container.AcquireLease", ActivityKind.Internal)) {
diagnosticScope.Start();
try {
HttpMessage val = CreateAcquireLeaseRequest(timeout, duration, proposedLeaseId, requestConditions, context);
try {
return _pipeline.ProcessMessage(val, context, default(CancellationToken));
} finally {
((IDisposable)val)?.Dispose();
}
} catch (Exception exception) {
diagnosticScope.Failed(exception);
throw;
}
}
}
internal HttpMessage CreateReleaseLeaseRequest(string leaseId, int? timeout, DateTimeOffset? ifModifiedSince, DateTimeOffset? ifUnmodifiedSince)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("comp", "lease", true);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-lease-action", "release");
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
if (ifUnmodifiedSince.HasValue)
val2.get_Headers().Add("If-Unmodified-Since", ifUnmodifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<ReleaseLeaseAsync>d__44))]
public Task<ResponseWithHeaders<ContainerReleaseLeaseHeaders>> ReleaseLeaseAsync(string leaseId, int? timeout = default(int?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
<ReleaseLeaseAsync>d__44 stateMachine = default(<ReleaseLeaseAsync>d__44);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerReleaseLeaseHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.leaseId = leaseId;
stateMachine.timeout = timeout;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.ifUnmodifiedSince = ifUnmodifiedSince;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerReleaseLeaseHeaders> ReleaseLease(string leaseId, int? timeout = default(int?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
if (leaseId != null) {
HttpMessage val = CreateReleaseLeaseRequest(leaseId, timeout, ifModifiedSince, ifUnmodifiedSince);
try {
_pipeline.Send(val, cancellationToken);
ContainerReleaseLeaseHeaders headers = new ContainerReleaseLeaseHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
throw new ArgumentNullException("leaseId");
}
internal HttpMessage CreateRenewLeaseRequest(string leaseId, int? timeout, DateTimeOffset? ifModifiedSince, DateTimeOffset? ifUnmodifiedSince)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("comp", "lease", true);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-lease-action", "renew");
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
if (ifUnmodifiedSince.HasValue)
val2.get_Headers().Add("If-Unmodified-Since", ifUnmodifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<RenewLeaseAsync>d__47))]
public Task<ResponseWithHeaders<ContainerRenewLeaseHeaders>> RenewLeaseAsync(string leaseId, int? timeout = default(int?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
<RenewLeaseAsync>d__47 stateMachine = default(<RenewLeaseAsync>d__47);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerRenewLeaseHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.leaseId = leaseId;
stateMachine.timeout = timeout;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.ifUnmodifiedSince = ifUnmodifiedSince;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerRenewLeaseHeaders> RenewLease(string leaseId, int? timeout = default(int?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
if (leaseId != null) {
HttpMessage val = CreateRenewLeaseRequest(leaseId, timeout, ifModifiedSince, ifUnmodifiedSince);
try {
_pipeline.Send(val, cancellationToken);
ContainerRenewLeaseHeaders headers = new ContainerRenewLeaseHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
throw new ArgumentNullException("leaseId");
}
internal HttpMessage CreateBreakLeaseRequest(int? timeout, long? breakPeriod, DateTimeOffset? ifModifiedSince, DateTimeOffset? ifUnmodifiedSince)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("comp", "lease", true);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-lease-action", "break");
if (breakPeriod.HasValue)
val2.get_Headers().Add("x-ms-lease-break-period", breakPeriod.Value);
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
if (ifUnmodifiedSince.HasValue)
val2.get_Headers().Add("If-Unmodified-Since", ifUnmodifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<BreakLeaseAsync>d__50))]
public Task<ResponseWithHeaders<ContainerBreakLeaseHeaders>> BreakLeaseAsync(int? timeout = default(int?), long? breakPeriod = default(long?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
<BreakLeaseAsync>d__50 stateMachine = default(<BreakLeaseAsync>d__50);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerBreakLeaseHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.breakPeriod = breakPeriod;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.ifUnmodifiedSince = ifUnmodifiedSince;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerBreakLeaseHeaders> BreakLease(int? timeout = default(int?), long? breakPeriod = default(long?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateBreakLeaseRequest(timeout, breakPeriod, ifModifiedSince, ifUnmodifiedSince);
try {
_pipeline.Send(val, cancellationToken);
ContainerBreakLeaseHeaders headers = new ContainerBreakLeaseHeaders(val.get_Response());
if (val.get_Response().get_Status() != 202)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateChangeLeaseRequest(string leaseId, string proposedLeaseId, int? timeout, DateTimeOffset? ifModifiedSince, DateTimeOffset? ifUnmodifiedSince)
{
HttpMessage val = _pipeline.CreateMessage();
Request val2 = val.get_Request();
val2.set_Method(RequestMethod.get_Put());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("comp", "lease", true);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
val2.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = val2.get_Headers();
headers.Add("x-ms-lease-action", "change");
headers = val2.get_Headers();
headers.Add("x-ms-lease-id", leaseId);
headers = val2.get_Headers();
headers.Add("x-ms-proposed-lease-id", proposedLeaseId);
if (ifModifiedSince.HasValue)
val2.get_Headers().Add("If-Modified-Since", ifModifiedSince.Value, "R");
if (ifUnmodifiedSince.HasValue)
val2.get_Headers().Add("If-Unmodified-Since", ifUnmodifiedSince.Value, "R");
headers = val2.get_Headers();
headers.Add("x-ms-version", _version);
headers = val2.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<ChangeLeaseAsync>d__53))]
public Task<ResponseWithHeaders<ContainerChangeLeaseHeaders>> ChangeLeaseAsync(string leaseId, string proposedLeaseId, int? timeout = default(int?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
<ChangeLeaseAsync>d__53 stateMachine = default(<ChangeLeaseAsync>d__53);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerChangeLeaseHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.leaseId = leaseId;
stateMachine.proposedLeaseId = proposedLeaseId;
stateMachine.timeout = timeout;
stateMachine.ifModifiedSince = ifModifiedSince;
stateMachine.ifUnmodifiedSince = ifUnmodifiedSince;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerChangeLeaseHeaders> ChangeLease(string leaseId, string proposedLeaseId, int? timeout = default(int?), DateTimeOffset? ifModifiedSince = default(DateTimeOffset?), DateTimeOffset? ifUnmodifiedSince = default(DateTimeOffset?), CancellationToken cancellationToken = default(CancellationToken))
{
if (leaseId == null)
throw new ArgumentNullException("leaseId");
if (proposedLeaseId != null) {
HttpMessage val = CreateChangeLeaseRequest(leaseId, proposedLeaseId, timeout, ifModifiedSince, ifUnmodifiedSince);
try {
_pipeline.Send(val, cancellationToken);
ContainerChangeLeaseHeaders headers = new ContainerChangeLeaseHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
throw new ArgumentNullException("proposedLeaseId");
}
internal HttpMessage CreateListBlobFlatSegmentRequest(string prefix, string marker, int? maxresults, IEnumerable<ListBlobsIncludeItem> include, int? timeout)
{
HttpMessage val = _pipeline.CreateMessage();
Request request = val.get_Request();
request.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "list", true);
if (prefix != null)
rawRequestUriBuilder.AppendQuery("prefix", prefix, true);
if (marker != null)
rawRequestUriBuilder.AppendQuery("marker", marker, true);
if (maxresults.HasValue)
rawRequestUriBuilder.AppendQuery("maxresults", maxresults.Value, true);
if (include != null) {
ChangeTrackingList<ListBlobsIncludeItem> changeTrackingList = include as ChangeTrackingList<ListBlobsIncludeItem>;
if (changeTrackingList == null || !changeTrackingList.IsUndefined)
RequestUriBuilderExtensions.AppendQueryDelimited(rawRequestUriBuilder, "include", include, ",", true);
}
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
request.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = request.get_Headers();
headers.Add("x-ms-version", _version);
headers = request.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<ListBlobFlatSegmentAsync>d__56))]
public Task<ResponseWithHeaders<ListBlobsFlatSegmentResponse, ContainerListBlobFlatSegmentHeaders>> ListBlobFlatSegmentAsync(string prefix = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
<ListBlobFlatSegmentAsync>d__56 stateMachine = default(<ListBlobFlatSegmentAsync>d__56);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ListBlobsFlatSegmentResponse, ContainerListBlobFlatSegmentHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.prefix = prefix;
stateMachine.marker = marker;
stateMachine.maxresults = maxresults;
stateMachine.include = include;
stateMachine.timeout = timeout;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ListBlobsFlatSegmentResponse, ContainerListBlobFlatSegmentHeaders> ListBlobFlatSegment(string prefix = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateListBlobFlatSegmentRequest(prefix, marker, maxresults, include, timeout);
try {
_pipeline.Send(val, cancellationToken);
ContainerListBlobFlatSegmentHeaders headers = new ContainerListBlobFlatSegmentHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
ListBlobsFlatSegmentResponse value = null;
XElement xElement = XDocument.Load(val.get_Response().get_ContentStream(), LoadOptions.PreserveWhitespace).Element("EnumerationResults");
if (xElement != null)
value = ListBlobsFlatSegmentResponse.DeserializeListBlobsFlatSegmentResponse(xElement);
return ResponseWithHeaders.FromValue(value, headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateListBlobHierarchySegmentRequest(string prefix, string delimiter, string marker, int? maxresults, IEnumerable<ListBlobsIncludeItem> include, int? timeout)
{
HttpMessage val = _pipeline.CreateMessage();
Request request = val.get_Request();
request.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "container", true);
rawRequestUriBuilder.AppendQuery("comp", "list", true);
if (prefix != null)
rawRequestUriBuilder.AppendQuery("prefix", prefix, true);
if (delimiter != null)
rawRequestUriBuilder.AppendQuery("delimiter", delimiter, true);
if (marker != null)
rawRequestUriBuilder.AppendQuery("marker", marker, true);
if (maxresults.HasValue)
rawRequestUriBuilder.AppendQuery("maxresults", maxresults.Value, true);
if (include != null) {
ChangeTrackingList<ListBlobsIncludeItem> changeTrackingList = include as ChangeTrackingList<ListBlobsIncludeItem>;
if (changeTrackingList == null || !changeTrackingList.IsUndefined)
RequestUriBuilderExtensions.AppendQueryDelimited(rawRequestUriBuilder, "include", include, ",", true);
}
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
request.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = request.get_Headers();
headers.Add("x-ms-version", _version);
headers = request.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<ListBlobHierarchySegmentAsync>d__59))]
public Task<ResponseWithHeaders<ListBlobsHierarchySegmentResponse, ContainerListBlobHierarchySegmentHeaders>> ListBlobHierarchySegmentAsync(string prefix = null, string delimiter = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
<ListBlobHierarchySegmentAsync>d__59 stateMachine = default(<ListBlobHierarchySegmentAsync>d__59);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ListBlobsHierarchySegmentResponse, ContainerListBlobHierarchySegmentHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.prefix = prefix;
stateMachine.delimiter = delimiter;
stateMachine.marker = marker;
stateMachine.maxresults = maxresults;
stateMachine.include = include;
stateMachine.timeout = timeout;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ListBlobsHierarchySegmentResponse, ContainerListBlobHierarchySegmentHeaders> ListBlobHierarchySegment(string prefix = null, string delimiter = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateListBlobHierarchySegmentRequest(prefix, delimiter, marker, maxresults, include, timeout);
try {
_pipeline.Send(val, cancellationToken);
ContainerListBlobHierarchySegmentHeaders headers = new ContainerListBlobHierarchySegmentHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
ListBlobsHierarchySegmentResponse value = null;
XElement xElement = XDocument.Load(val.get_Response().get_ContentStream(), LoadOptions.PreserveWhitespace).Element("EnumerationResults");
if (xElement != null)
value = ListBlobsHierarchySegmentResponse.DeserializeListBlobsHierarchySegmentResponse(xElement);
return ResponseWithHeaders.FromValue(value, headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateGetAccountInfoRequest(int? timeout)
{
HttpMessage val = _pipeline.CreateMessage();
Request request = val.get_Request();
request.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendQuery("restype", "account", true);
rawRequestUriBuilder.AppendQuery("comp", "properties", true);
if (timeout.HasValue)
rawRequestUriBuilder.AppendQuery("timeout", timeout.Value, true);
request.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = request.get_Headers();
headers.Add("x-ms-version", _version);
headers = request.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<GetAccountInfoAsync>d__62))]
public Task<ResponseWithHeaders<ContainerGetAccountInfoHeaders>> GetAccountInfoAsync(int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
<GetAccountInfoAsync>d__62 stateMachine = default(<GetAccountInfoAsync>d__62);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ContainerGetAccountInfoHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.timeout = timeout;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ContainerGetAccountInfoHeaders> GetAccountInfo(int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
HttpMessage val = CreateGetAccountInfoRequest(timeout);
try {
_pipeline.Send(val, cancellationToken);
ContainerGetAccountInfoHeaders headers = new ContainerGetAccountInfoHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
return ResponseWithHeaders.FromValue(headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
internal HttpMessage CreateListBlobFlatSegmentNextPageRequest(string nextLink, string prefix, string marker, int? maxresults, IEnumerable<ListBlobsIncludeItem> include, int? timeout)
{
HttpMessage val = _pipeline.CreateMessage();
Request request = val.get_Request();
request.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendRawNextLink(nextLink, false);
request.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = request.get_Headers();
headers.Add("x-ms-version", _version);
headers = request.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<ListBlobFlatSegmentNextPageAsync>d__65))]
public Task<ResponseWithHeaders<ListBlobsFlatSegmentResponse, ContainerListBlobFlatSegmentHeaders>> ListBlobFlatSegmentNextPageAsync(string nextLink, string prefix = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
<ListBlobFlatSegmentNextPageAsync>d__65 stateMachine = default(<ListBlobFlatSegmentNextPageAsync>d__65);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ListBlobsFlatSegmentResponse, ContainerListBlobFlatSegmentHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.nextLink = nextLink;
stateMachine.prefix = prefix;
stateMachine.marker = marker;
stateMachine.maxresults = maxresults;
stateMachine.include = include;
stateMachine.timeout = timeout;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ListBlobsFlatSegmentResponse, ContainerListBlobFlatSegmentHeaders> ListBlobFlatSegmentNextPage(string nextLink, string prefix = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
if (nextLink != null) {
HttpMessage val = CreateListBlobFlatSegmentNextPageRequest(nextLink, prefix, marker, maxresults, include, timeout);
try {
_pipeline.Send(val, cancellationToken);
ContainerListBlobFlatSegmentHeaders headers = new ContainerListBlobFlatSegmentHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
ListBlobsFlatSegmentResponse value = null;
XElement xElement = XDocument.Load(val.get_Response().get_ContentStream(), LoadOptions.PreserveWhitespace).Element("EnumerationResults");
if (xElement != null)
value = ListBlobsFlatSegmentResponse.DeserializeListBlobsFlatSegmentResponse(xElement);
return ResponseWithHeaders.FromValue(value, headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
throw new ArgumentNullException("nextLink");
}
internal HttpMessage CreateListBlobHierarchySegmentNextPageRequest(string nextLink, string prefix, string delimiter, string marker, int? maxresults, IEnumerable<ListBlobsIncludeItem> include, int? timeout)
{
HttpMessage val = _pipeline.CreateMessage();
Request request = val.get_Request();
request.set_Method(RequestMethod.get_Get());
RawRequestUriBuilder rawRequestUriBuilder = new RawRequestUriBuilder();
rawRequestUriBuilder.AppendRaw(_url, false);
rawRequestUriBuilder.AppendRawNextLink(nextLink, false);
request.set_Uri(rawRequestUriBuilder);
RequestHeaders headers = request.get_Headers();
headers.Add("x-ms-version", _version);
headers = request.get_Headers();
headers.Add("Accept", "application/xml");
return val;
}
[AsyncStateMachine(typeof(<ListBlobHierarchySegmentNextPageAsync>d__68))]
public Task<ResponseWithHeaders<ListBlobsHierarchySegmentResponse, ContainerListBlobHierarchySegmentHeaders>> ListBlobHierarchySegmentNextPageAsync(string nextLink, string prefix = null, string delimiter = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
<ListBlobHierarchySegmentNextPageAsync>d__68 stateMachine = default(<ListBlobHierarchySegmentNextPageAsync>d__68);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<ResponseWithHeaders<ListBlobsHierarchySegmentResponse, ContainerListBlobHierarchySegmentHeaders>>.Create();
stateMachine.<>4__this = this;
stateMachine.nextLink = nextLink;
stateMachine.prefix = prefix;
stateMachine.delimiter = delimiter;
stateMachine.marker = marker;
stateMachine.maxresults = maxresults;
stateMachine.include = include;
stateMachine.timeout = timeout;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public ResponseWithHeaders<ListBlobsHierarchySegmentResponse, ContainerListBlobHierarchySegmentHeaders> ListBlobHierarchySegmentNextPage(string nextLink, string prefix = null, string delimiter = null, string marker = null, int? maxresults = default(int?), IEnumerable<ListBlobsIncludeItem> include = null, int? timeout = default(int?), CancellationToken cancellationToken = default(CancellationToken))
{
if (nextLink != null) {
HttpMessage val = CreateListBlobHierarchySegmentNextPageRequest(nextLink, prefix, delimiter, marker, maxresults, include, timeout);
try {
_pipeline.Send(val, cancellationToken);
ContainerListBlobHierarchySegmentHeaders headers = new ContainerListBlobHierarchySegmentHeaders(val.get_Response());
if (val.get_Response().get_Status() != 200)
throw new RequestFailedException(val.get_Response());
ListBlobsHierarchySegmentResponse value = null;
XElement xElement = XDocument.Load(val.get_Response().get_ContentStream(), LoadOptions.PreserveWhitespace).Element("EnumerationResults");
if (xElement != null)
value = ListBlobsHierarchySegmentResponse.DeserializeListBlobsHierarchySegmentResponse(xElement);
return ResponseWithHeaders.FromValue(value, headers, val.get_Response());
} finally {
((IDisposable)val)?.Dispose();
}
}
throw new ArgumentNullException("nextLink");
}
}
}