CancellationTokenSource not work

[303248153]

I need to stop the container after it runs longer than the time I give, then I try to use CancellationTokenSource, here is my code:

public static async Task DockerCancell()
{
	var cert = new CertificateCredentials(new X509Certificate2(CertPath, CertPassword));
	var configuration = new DockerClientConfiguration(new Uri("https://docker-1:2376"), cert);
	var client = configuration.CreateClient();
	var createResult = await client.Containers.CreateContainerAsync(new CreateContainerParameters()
	{
		Image = Image,
		Name = Guid.NewGuid().ToString(),
		WorkingDir = "/workdir",
		HostConfig = new HostConfig() { AutoRemove = true },
		Cmd = new[] { "sleep", "3" }
	});
	await client.Containers.StartContainerAsync(createResult.ID, new ContainerStartParameters());
	var token = new CancellationTokenSource();
	token.CancelAfter(1000);
	await client.Containers.WaitContainerAsync(createResult.ID, token.Token);
	Console.WriteLine("shouldn't be here");
}

It always output "shouldn't be here", looks like cancellation token didn't work for this api.
Further more, not only CancelAfter, Cancel is not work too:

public static async Task DockerCancell()
{
	var cert = new CertificateCredentials(new X509Certificate2(CertPath, CertPassword));
	var configuration = new DockerClientConfiguration(new Uri("https://docker-1:2376"), cert);
	var client = configuration.CreateClient();
	var createResult = await client.Containers.CreateContainerAsync(new CreateContainerParameters()
	{
		Image = Image,
		Name = Guid.NewGuid().ToString(),
		WorkingDir = "/workdir",
		HostConfig = new HostConfig() { AutoRemove = true },
		Cmd = new[] { "sleep", "3" }
	});
	await client.Containers.StartContainerAsync(createResult.ID, new ContainerStartParameters());
	var token = new CancellationTokenSource();
	// token.CancelAfter(1000);
	var task = client.Containers.WaitContainerAsync(createResult.ID, token.Token);
	await Task.Delay(1);
	token.Cancel();
	await task;
	Console.WriteLine("shouldn't be here");
}

[jterry75]

I'm not sure what behavior you want here. When you cancel the task is allowed to have a continuation thus printing your Console.WriteLine. Are you expecting the library to throw in this case?

[303248153]

It never return, you can modify "sleep 3" to "sleep 100000000" to confirm it.
The problem is "Cancel" is not work at all, I think the cancellation token is lost somewhere, didn't passed to socket.receive.

[wjrogers]

I just ran into this today -- cancelling WaitContainerAsync doesn't work at all.

[hanslai]

I am having the same problem. my code below.

var tokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(60));
var token = tokenSource.Token;

var containerStarted = await _dockerClient.Containers.StartContainerAsync(_containerId, null, token).ConfigureAwait(false);
tokenSource.Dispose();

if (containerStarted == false) throw new Exception($"Could not start container: {_containerId}");

somehow StartContainerAsync() never return, and CancellationTokenSource does not work.

[dgvives]

It's been a while since several users reported this and found myself in the same boat.
Requests are not getting cancelled when CancellationTokenSource.CancelAfter() is used.

It looks like HttpClient.SendRequest ignores the CancellationToken, I'm having a look at it

class Program
{
    static async Task Main(string[] args)
    {

        var stopWatch = new Stopwatch();
        var configuration = new DockerClientConfiguration();
        var client = configuration.CreateClient();

        try
        {
            stopWatch.Start();

            using var cts = new CancellationTokenSource();

            var createContainerResult = await client.Containers.CreateContainerAsync(new CreateContainerParameters()
            {
                Image = "hello-world",
                Name = Guid.NewGuid().ToString(),
                Cmd = new[] { "ping", "127.0.0.1", "-t" }
            },
            cts.Token);
            Console.WriteLine($"elapsed: {stopWatch.ElapsedMilliseconds}, createContainerResult: {JsonConvert.SerializeObject(createContainerResult)}");

            var startContainerResult = await client.Containers.StartContainerAsync(createContainerResult.ID, new ContainerStartParameters(), cts.Token);
            Console.WriteLine($"elapsed: {stopWatch.ElapsedMilliseconds}, createResult: {JsonConvert.SerializeObject(createContainerResult)}");

            cts.CancelAfter(100);

            var waitContainerResponse = await client.Containers.WaitContainerAsync(createContainerResult.ID, cts.Token).ConfigureAwait(false);

            Console.WriteLine($"waitcontainerResponse: {JsonConvert.SerializeObject(waitContainerResponse)}");
        }
        catch (OperationCanceledException)
        {
            Console.WriteLine($"Operation cancelled after {stopWatch.ElapsedMilliseconds}");
        }


    }
}