address comments

Author: sharanyad

agent/engine/docker_task_engine_test.go

@@ -1935,19 +1935,28 @@ func TestSynchronizeContainerStatus(t *testing.T) {
 	labels := map[string]string{
 		"name": "metadata",
 	}
+	volumes := []docker.Mount{
+		{
+			Name:        "volume",
+			Source:      "/src/vol",
+			Destination: "/vol",
+		},
+	}
 	created := time.Now()
 	gomock.InOrder(
 		client.EXPECT().DescribeContainer(gomock.Any(), dockerID).Return(apicontainerstatus.ContainerRunning,
 			dockerapi.DockerContainerMetadata{
 				Labels:    labels,
 				DockerID:  dockerID,
 				CreatedAt: created,
+				Volumes:   volumes,
 			}),
 		imageManager.EXPECT().RecordContainerReference(dockerContainer.Container),
 	)
 	taskEngine.(*DockerTaskEngine).synchronizeContainerStatus(dockerContainer, nil)
 	assert.Equal(t, created, dockerContainer.Container.GetCreatedAt())
 	assert.Equal(t, labels, dockerContainer.Container.GetLabels())
+	assert.Equal(t, volumes, dockerContainer.Container.GetVolumes())
 }
 
 // TestHandleDockerHealthEvent tests the docker health event will only cause the

agent/functional_tests/testdata/taskdefinitions/taskmetadata-validator-awsvpc/task-definition.json

@@ -22,16 +22,17 @@
     },
     "mountPoints": [
         {
-          "sourceVolume": "task-local",
+          "sourceVolume": "shared-local",
           "containerPath": "/ecs/"
         }
     ]
   }],
   "volumes":[
       {
-          "name": "task-local",
+          "name": "shared-local",
           "dockerVolumeConfiguration" :{
-              "scope": "task",
+              "scope": "shared",
+              "autoprovision":true,
               "driver": "local"
           }
       }

agent/functional_tests/tests/functionaltests_unix_test.go

@@ -625,8 +625,6 @@ func TestAgentIntrospectionValidator(t *testing.T) {
 		},
 	})
 	defer agent.Cleanup()
-	// The Agent version was 1.14.2 when we added changes to agent introspection
-	// endpoint feature for the last time.
 	agent.RequireVersion(">1.20.1")
 
 	tdOverrides := make(map[string]string)

agent/handlers/v1/response.go

@@ -156,7 +156,7 @@ func NewPortBindingsResponse(dockerContainer *apicontainer.DockerContainer, eni
 // NewVolumesResponse creates VolumeResponse for a container
 func NewVolumesResponse(dockerContainer *apicontainer.DockerContainer) []VolumeResponse {
 	container := dockerContainer.Container
-	resp := []VolumeResponse{}
+	var resp []VolumeResponse
 
 	volumes := container.GetVolumes()
 

misc/taskmetadata-validator/taskmetadata-validator.go

@@ -256,6 +256,11 @@ func main() {
 		os.Exit(1)
 	}
 
+	if containerMetadata.Volumes[0].DockerName != "shared-local" || containerMetadata.Volumes[0].Destination != "/ecs" {
+		fmt.Fprintf(os.Stderr, "Volume metadata fields incorrect")
+		os.Exit(1)
+	}
+
 	_, err = taskStats(client)
 	if err != nil {
 		fmt.Fprintf(os.Stderr, "Unable to get task stats: %v", err)