in AdlsDotNetSDK/Core.cs [49:92]
public static async Task<bool> MkdirsAsync(string path, string octalPermission, AdlsClient client, RequestOptions req, OperationResponse resp, CancellationToken cancelToken = default(CancellationToken))
{
QueryParams qp = new QueryParams();
if (!string.IsNullOrEmpty(octalPermission))
{
if (!IsValidOctal(octalPermission))
{
resp.IsSuccessful = false;
resp.Error = "Octal Permission not valid";
return false;
}
qp.Add("permission", Convert.ToString(octalPermission));
}
var responseTuple = await WebTransport.MakeCallAsync("MKDIRS", path, default(ByteBuffer), default(ByteBuffer), qp, client, req, resp, cancelToken).ConfigureAwait(false);
if (!resp.IsSuccessful) return false;
bool readerValue = false;
if (responseTuple != null)
{
try
{
using (MemoryStream stream = new MemoryStream(responseTuple.Item1))
{
using (StreamReader stReader = new StreamReader(stream))
{
using (var jsonReader = new JsonTextReader(stReader))
{
jsonReader.Read(); //Start Object
jsonReader.Read(); //"boolean"
jsonReader.Read(); //Value
readerValue = (bool)jsonReader.Value;
}
}
}
}
catch (Exception ex)
{
resp.IsSuccessful = false;
resp.Error = $"Unexpected problem with parsing JSON output. \r\nExceptionType: {ex.GetType()} \r\nExceptionMessage: {ex.Message}";
return false;
}
}
return readerValue;
}