aboutsummaryrefslogtreecommitdiffstats
path: root/tools/vsperf_install.yml
blob: 3c78e0ca8cc6a83259246263c72ceba3f45d8eca (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
##############################################################################
# Copyright (c) 2017 Nokia
#
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
heat_template_version: 2015-04-30

description: >
  Used to run VMs with Vsperf

parameters:
  image:
    type: string
    description: Name of the image
    default: yardstick-vsperf

  flavor:
    type: string
    default: vsperf-flavor

  timeout:
    type: number
    description: Timeout in seconds for WaitCondition, depends on your image and environment
    default: 6000

  external_net_name:
    type: string
    description: Name of the external network which management network will connect to
    default: ext-net1

resources:
  network:
    type: OS::Neutron::Net
    properties:
      name: vsperf_net

  subnet:
    type: OS::Neutron::Subnet
    properties:
      name: vsperf_subnet
      ip_version: 4
      cidr: 192.168.0.0/24
      network: { get_resource: network }

  management_router:
    type: OS::Neutron::Router
    properties:
      name: management_router
      external_gateway_info:
        network: { get_param: external_net_name }

  management_router_interface:
    type: OS::Neutron::RouterInterface
    properties:
      router: { get_resource: management_router }
      subnet: { get_resource: subnet }

  floating_ip:
    type: OS::Neutron::FloatingIP
    properties:
      floating_network: { get_param: external_net_name }

  floating_ip_association:
    type: OS::Nova::FloatingIPAssociation
    properties:
      floating_ip: { get_resource: floating_ip }
      server_id: {get_resource: vsperf_vm}

  keypair:
    type: OS::Nova::KeyPair
    properties:
      name: yardstick-key
      public_key: ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQD0RkXfW6pksd1cZmXuvXZF/Mlqqq3ahIGcGoULOC97XMpu0vdxMpcUwdjwGqMwEXTVyfHidu0l99bLqOCpSUKCmbWx3ONJ+1kqFx4HwsKEWLiyDYqsuMrDeZT1eFjC5avCoTcrIw2wq5NaBb00lDGagNZOeopaL5YIa4+PizEY23+cir24D67NU21Fg3JE92AIeGlNa4j66L3a+lL0hZq74Dilmp42wm4GsbplRO6KJfyaraowHb1X+TmhCjBgHk6M/OJ9yPAroZyJNcwjMAuuxhAYWRuT3SdbnoUR0RG2VhfDh0qNid7vOqLbhKPeaLLFmzkN+9w3WdCp6LbSYt87 yardstick@yardstick.opnfv.org

  wait_handle:
    type: OS::Heat::WaitConditionHandle

  wait_condition:
    type: OS::Heat::WaitCondition
    properties:
      handle: { get_resource: wait_handle }
      count: 1
      timeout: { get_param: timeout }

  vsperf_vm:
    type: OS::Nova::Server
    depends_on: [subnet, keypair]
    properties:
      name: { get_param: "OS::stack_name" }
      image: { get_param: image }
      flavor: { get_param: flavor }
      key_name: {get_resource: keypair}
      networks:
        - network: { get_resource: network }
      config_drive: True
      user_data_format : RAW
      user_data:
        str_replace:
          template: |
            #!/bin/bash
            cat <<'CEOF' > /tmp/vsperf_post_build.sh
            echo "Install vswitchperf"
            mv /root/vswitchperf /home/ubuntu
            chown -R ubuntu:ubuntu /home/ubuntu/vswitchperf
            cd /home/ubuntu/vswitchperf/systems
            sudo -H -u ubuntu ./build_base_machine.sh
            echo "Set password less access to MoonGen server"
            sudo -H -u ubuntu ssh-keygen -b 2048 -t rsa -f /home/ubuntu/.ssh/id_rsa -N ''
            sudo -H -u ubuntu touch /home/ubuntu/.cloud-warnings.skip
            echo "Enable 1GB huge pages"
            update-grub
            $NOTIFY --data-binary '{"status": "SUCCESS"}'
            CEOF
            chmod +x /tmp/vsperf_post_build.sh
            nohup /tmp/vsperf_post_build.sh &
          params:
            $NOTIFY: { get_attr: ['wait_handle', 'curl_cli'] }

outputs:
  vm_uuid:
    description: uuid of the VM
    value: { get_attr: [ vsperf_vm, show,id ] }
/span> bucket->info[i].tsc - task_irq->start_tsc, (bucket->info[i].tsc - task_irq->start_tsc) * 1000 / rte_get_tsc_hz()); } task_irq->stats_use_lt = !task_irq->task_use_lt; bucket->index = 0; } static void irq_stop(struct task_base *tbase) { struct task_irq *task = (struct task_irq *)tbase; uint32_t i; uint32_t lcore_id = rte_lcore_id(); uint64_t lat, max_lat = 0, tot_lat = 0; int bucket_id; int n_lat = 0; if (task->irq_debug) { plog_info("Stopping core %u\n", lcore_id); sleep(2); // Make sure all cores are stopped before starting to write plog_info("Core ID; Interrupt (nanosec); Time (msec)\n"); for (int j = 0; j < 2; j++) { // Start dumping the oldest bucket first if (task->buffer[0].info[0].tsc < task->buffer[1].info[0].tsc) bucket_id = j; else bucket_id = !j; struct irq_bucket *bucket = &task->buffer[bucket_id]; for (i=0; i< bucket->index;i++) { if (bucket->info[i].lat != 0) { lat = bucket->info[i].lat * 1000000000 / rte_get_tsc_hz(); if (max_lat < lat) max_lat = lat; n_lat++; tot_lat += lat; plog_info("%d; %ld; %ld\n", lcore_id, lat, (bucket->info[i].tsc - task->start_tsc) * 1000 / rte_get_tsc_hz()); } } } if (n_lat) tot_lat = tot_lat / n_lat; plog_info("Core %u stopped. max lat is %ld and average is %ld\n", lcore_id, max_lat, tot_lat); } } static inline int handle_irq_bulk(struct task_base *tbase, struct rte_mbuf **mbufs, uint16_t n_pkts) { struct task_irq *task = (struct task_irq *)tbase; uint64_t tsc1; uint64_t index; if (task->stats_use_lt != task->task_use_lt) task->task_use_lt = task->stats_use_lt; struct irq_bucket *bucket = &task->buffer[task->task_use_lt]; tsc1 = rte_rdtsc(); if ((tsc1 > task->first_tsc) && (task->tsc != 0)) { update_irq_stats(task, tsc1 - task->tsc); if (((tsc1 - task->tsc) > task->max_irq) && (bucket->index < MAX_INDEX)) { bucket->info[bucket->index].tsc = tsc1; bucket->info[bucket->index++].lat = tsc1 - task->tsc; } } task->tsc = tsc1; return 0; } static void init_task_irq(struct task_base *tbase, __attribute__((unused)) struct task_args *targ) { struct task_irq *task = (struct task_irq *)tbase; task->start_tsc = rte_rdtsc(); task->first_tsc = task->start_tsc + 2 * rte_get_tsc_hz(); task->lcore_id = targ->lconf->id; task->irq_debug = targ->irq_debug; // max_irq expressed in cycles task->max_irq = rte_get_tsc_hz() / MAX_INTERRUPT_LENGTH; plog_info("\tusing irq mode with max irq set to %ld cycles\n", task->max_irq); for (uint bucket_id = 0; bucket_id < IRQ_BUCKETS_COUNT - 1; bucket_id++) irq_bucket_maxtime_cycles[bucket_id] = rte_get_tsc_hz() * irq_bucket_maxtime_micro[bucket_id] / 1000000; irq_bucket_maxtime_cycles[IRQ_BUCKETS_COUNT - 1] = UINT64_MAX; } static struct task_init task_init_irq = { .mode_str = "irq", .init = init_task_irq, .handle = handle_irq_bulk, .stop = irq_stop, .flag_features = TASK_FEATURE_NO_RX, .size = sizeof(struct task_irq) }; static struct task_init task_init_none; __attribute__((constructor)) static void reg_task_irq(void) { reg_task(&task_init_irq); }