'``/VolumeDriver.Mount`` sets the primary of the dataset with matching
name to the current node and then waits for the dataset to
actually arrive. If it does not arrive within 120 seconds, then it
returns an error up to docker.'

def test_mount_timeout(self):

    name = u'myvol'
    dataset_id = uuid4()
    mount_id = ''.join((random.choice('0123456789abcdef') for n in xrange(64)))
    d = self.flocker_client.create_dataset(self.NODE_B, int(DEFAULT_SIZE.to_Byte()), metadata={NAME_FIELD: name}, dataset_id=dataset_id)
    self._flush_volume_plugin_reactor_on_endpoint_render()
    self.volume_plugin_reactor.callLater(500.0, self.flocker_client.synchronize_state)
    d.addCallback((lambda _: self.assertResult('POST', '/VolumeDriver.Mount', {u'Name': name, u'ID': unicode(mount_id)}, OK, {u'Err': u'Timed    out    waiting    for    dataset    to    mount.', u'Mountpoint': u''})))
    return d
