Function TestCreateServiceMemorySwap

integration/service/create_test.go:469–566

(t *testing.T)

}

func TestCreateServiceMemorySwap(t *testing.T) {
	ctx := setupTest(t)
	d := swarm.NewSwarm(ctx, t, testEnv)
	defer d.Stop(t)
	apiClient := d.NewClientT(t)

	toPtr := func(v int64) *int64 { return &v }
	tests := []struct {
		testName string

		swapSpec  *int64
		limitSpec int64

		// as reported by Docker
		expectedDockerSwap int64
	}{
		{
			testName: "default",
		},
		{
			testName:           "memory-limit and memory-swap",
			swapSpec:           toPtr(1 * units.MiB),
			limitSpec:          20 * units.MiB,
			expectedDockerSwap: 21 * units.MiB,
		},
		{
			testName:           "memory-limit alone - should default to twice as much swap",
			limitSpec:          20 * units.MiB,
			expectedDockerSwap: 40 * units.MiB,
		},
		{
			testName:           "memory-limit and zero memory-swap",
			swapSpec:           toPtr(0),
			limitSpec:          20 * units.MiB,
			expectedDockerSwap: 20 * units.MiB,
		},
		{
			testName:           "memory-limit and unlimited memory-swap",
			swapSpec:           toPtr(-1),
			limitSpec:          20 * units.MiB,
			expectedDockerSwap: -1,
		},
	}

	for _, testCase := range tests {
		t.Run("service create with "+testCase.testName, func(t *testing.T) {
			serviceID := swarm.CreateService(
				ctx, t, d,
				swarm.ServiceWithMemorySwap(testCase.swapSpec, testCase.limitSpec),
			)
			poll.WaitOn(t, swarm.RunningTasksCount(ctx, apiClient, serviceID, 1))

			inspect, err := apiClient.ServiceInspect(ctx, serviceID, client.ServiceInspectOptions{})
			assert.NilError(t, err)

			filter := make(client.Filters)
			filter.Add("service", serviceID)
			tasks, err := apiClient.TaskList(ctx, client.TaskListOptions{