diff --git a/src/webui/service/load_gen/forms.py b/src/webui/service/load_gen/forms.py new file mode 100644 index 0000000000000000000000000000000000000000..3144fbe5dd2324dad904f1054e30735e27aacbd4 --- /dev/null +++ b/src/webui/service/load_gen/forms.py @@ -0,0 +1,45 @@ +# Copyright 2022-2023 ETSI TeraFlowSDN - TFS OSG (https://tfs.etsi.org/) +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +from flask_wtf import FlaskForm +from wtforms import BooleanField, FloatField, IntegerField, StringField, SubmitField +from wtforms.validators import DataRequired, NumberRange + +class LoadGenStartForm(FlaskForm): + num_requests = IntegerField('Num Requests', default=100, validators=[DataRequired(), NumberRange(min=0)]) + num_generated = IntegerField('Num Generated', render_kw={'readonly': True}) + + request_type_service_l2nm = BooleanField('Service L2NM', default=False) + request_type_service_l3nm = BooleanField('Service L3NM', default=False) + request_type_service_mw = BooleanField('Service MW', default=False) + request_type_service_tapi = BooleanField('Service TAPI', default=False) + request_type_slice_l2nm = BooleanField('Slice L2NM', default=True) + request_type_slice_l3nm = BooleanField('Slice L3NM', default=False) + + offered_load = FloatField('Offered Load [Erlang]', default=50, validators=[NumberRange(min=1.e-12)]) + holding_time = FloatField('Holding Time [seconds]', default=10, validators=[NumberRange(min=1.e-12)]) + inter_arrival_time = FloatField('Inter Arrival Time[seconds]', default=0, validators=[NumberRange(min=1.e-12)]) + + do_teardown = BooleanField('Do Teardown', default=True) + + record_to_dlt = BooleanField('Record to DLT', default=False) + dlt_domain_id = StringField('DLT Domain Id', default='') + + infinite_loop = BooleanField('Infinite Loop', render_kw={'readonly': True}) + running = BooleanField('Running', render_kw={'readonly': True}) + + submit = SubmitField('Start') + +class LoadGenStopForm(FlaskForm): + submit = SubmitField('Stop') diff --git a/src/webui/service/load_gen/routes.py b/src/webui/service/load_gen/routes.py index 3118b6de0e061adac65be178163623cd2d1d8fff..89390090819e65fb69277f2a5654f15232100ebc 100644 --- a/src/webui/service/load_gen/routes.py +++ b/src/webui/service/load_gen/routes.py @@ -14,32 +14,93 @@ from flask import render_template, Blueprint, flash from common.proto.context_pb2 import Empty +from common.proto.load_generator_pb2 import Parameters, RequestTypeEnum from load_generator.client.LoadGeneratorClient import LoadGeneratorClient +from .forms import LoadGenStartForm, LoadGenStopForm load_gen = Blueprint('load_gen', __name__, url_prefix='/load_gen') -@load_gen.route('start', methods=['GET']) -def start(): +@load_gen.route('home', methods=['GET', 'POST']) +def home(): load_gen_client = LoadGeneratorClient() - try: - load_gen_client.connect() - load_gen_client.Start(Empty()) - load_gen_client.close() - flash('Load Generator Started.', 'success') - except Exception as e: # pylint: disable=broad-except - flash('Problem starting Load Generator. {:s}'.format(str(e)), 'danger') - - return render_template('main/debug.html') - -@load_gen.route('stop', methods=['GET']) -def stop(): - load_gen_client = LoadGeneratorClient() - try: - load_gen_client.connect() - load_gen_client.Stop(Empty()) - load_gen_client.close() - flash('Load Generator Stoped.', 'success') - except Exception as e: # pylint: disable=broad-except - flash('Problem stopping Load Generator. {:s}'.format(str(e)), 'danger') - - return render_template('main/debug.html') + + form_start = LoadGenStartForm() + form_stop = LoadGenStopForm() + + if form_start.validate_on_submit(): + load_gen_params = Parameters() + load_gen_params.num_requests = form_start.num_requests.data + load_gen_params.offered_load = form_start.offered_load.data + load_gen_params.holding_time = form_start.holding_time.data + load_gen_params.inter_arrival_time = form_start.inter_arrival_time.data + load_gen_params.do_teardown = form_start.do_teardown.data + load_gen_params.dry_mode = False + load_gen_params.record_to_dlt = form_start.record_to_dlt.data + load_gen_params.dlt_domain_id = form_start.dlt_domain_id.data + + del load_gen_params.request_types[:] # pylint: disable=no-member + request_types = list() + if form_start.request_type_service_l2nm.data: request_types.append(RequestTypeEnum.REQUESTTYPE_SERVICE_L2NM) + if form_start.request_type_service_l3nm.data: request_types.append(RequestTypeEnum.REQUESTTYPE_SERVICE_L3NM) + if form_start.request_type_service_mw .data: request_types.append(RequestTypeEnum.REQUESTTYPE_SERVICE_MW ) + if form_start.request_type_service_tapi.data: request_types.append(RequestTypeEnum.REQUESTTYPE_SERVICE_TAPI) + if form_start.request_type_slice_l2nm .data: request_types.append(RequestTypeEnum.REQUESTTYPE_SLICE_L2NM ) + if form_start.request_type_slice_l3nm .data: request_types.append(RequestTypeEnum.REQUESTTYPE_SLICE_L3NM ) + load_gen_params.request_types.extend(request_types) # pylint: disable=no-member + + try: + load_gen_client.connect() + load_gen_client.Start(load_gen_params) + load_gen_client.close() + flash('Load Generator Started.', 'success') + except Exception as e: # pylint: disable=broad-except + flash('Problem starting Load Generator. {:s}'.format(str(e)), 'danger') + + if form_stop.validate_on_submit(): + try: + load_gen_client.connect() + load_gen_client.Stop(Empty()) + load_gen_client.close() + flash('Load Generator Stoped.', 'success') + except Exception as e: # pylint: disable=broad-except + flash('Problem stopping Load Generator. {:s}'.format(str(e)), 'danger') + + load_gen_client.connect() + status = load_gen_client.GetStatus(Empty()) + load_gen_client.close() + + form_start.num_requests .default = status.parameters.num_requests + form_start.offered_load .default = status.parameters.offered_load + form_start.holding_time .default = status.parameters.holding_time + form_start.inter_arrival_time.default = status.parameters.inter_arrival_time + form_start.do_teardown .default = status.parameters.do_teardown + form_start.record_to_dlt .default = status.parameters.record_to_dlt + form_start.dlt_domain_id .default = status.parameters.dlt_domain_id + form_start.num_generated .default = status.num_generated + form_start.infinite_loop .default = status.infinite_loop + form_start.running .default = status.running + + request_types = status.parameters.request_types + form_start.request_type_service_l2nm.default = RequestTypeEnum.REQUESTTYPE_SERVICE_L2NM in request_types + form_start.request_type_service_l3nm.default = RequestTypeEnum.REQUESTTYPE_SERVICE_L3NM in request_types + form_start.request_type_service_mw .default = RequestTypeEnum.REQUESTTYPE_SERVICE_MW in request_types + form_start.request_type_service_tapi.default = RequestTypeEnum.REQUESTTYPE_SERVICE_TAPI in request_types + form_start.request_type_slice_l2nm .default = RequestTypeEnum.REQUESTTYPE_SLICE_L2NM in request_types + form_start.request_type_slice_l3nm .default = RequestTypeEnum.REQUESTTYPE_SLICE_L3NM in request_types + + form_start.num_requests .render_kw['readonly'] = status.running + form_start.offered_load .render_kw['readonly'] = status.running + form_start.holding_time .render_kw['readonly'] = status.running + form_start.inter_arrival_time.render_kw['readonly'] = status.running + form_start.do_teardown .render_kw['readonly'] = status.running + form_start.record_to_dlt .render_kw['readonly'] = status.running + form_start.dlt_domain_id .render_kw['readonly'] = status.running + + form_start.request_type_service_l2nm.render_kw['readonly'] = status.running + form_start.request_type_service_l3nm.render_kw['readonly'] = status.running + form_start.request_type_service_mw .render_kw['readonly'] = status.running + form_start.request_type_service_tapi.render_kw['readonly'] = status.running + form_start.request_type_slice_l2nm .render_kw['readonly'] = status.running + form_start.request_type_slice_l3nm .render_kw['readonly'] = status.running + + return render_template('load_gen/home.html', form_start=form_start, form_stop=form_stop) diff --git a/src/webui/service/templates/base.html b/src/webui/service/templates/base.html index 35999ebe1785a033097dd30bfd672ce3b9a91a87..1dfa3687198d8a33db346ba2bbcd2989f6f109bb 100644 --- a/src/webui/service/templates/base.html +++ b/src/webui/service/templates/base.html @@ -86,10 +86,16 @@
  • Grafana
    • -
  • Debug
    • +
  • + {% if '/load-gen/' in request.path %} + Load Generator + {% else %} + Load Generator + {% endif %} +
    • + +{% extends 'base.html' %} + +{% block content %} +

    Load Generator

    +
    + +
    + {{ form_start.hidden_tag() }} +
    +
    + {{ form_start.num_requests.label(class="col-sm-2 col-form-label") }} +
    + {% if form_start.num_requests.errors %} + {{ form_start.num_requests(class="form-control is-invalid") }} +
    + {% for error in form_start.num_requests.errors %}{{ error }}{% endfor %} +
    + {% else %} + {{ form_start.num_requests(class="form-control") }} + {% endif %} +
    +
    +
    + +
    + {{ form_start.num_generated.label(class="col-sm-2 col-form-label") }} +
    + {% if form_start.num_generated.errors %} + {{ form_start.num_generated(class="form-control is-invalid") }} +
    + {% for error in form_start.num_generated.errors %}{{ error }}{% endfor %} +
    + {% else %} + {{ form_start.num_generated(class="form-control") }} + {% endif %} +
    +
    +
    + +
    +
    Service Types:
    +
    + {{ form_start.request_type_service_l2nm }} {{ form_start.request_type_service_l2nm.label(class="col-sm-3 col-form-label") }} + {{ form_start.request_type_service_l3nm }} {{ form_start.request_type_service_l3nm.label(class="col-sm-3 col-form-label") }} + {{ form_start.request_type_service_mw }} {{ form_start.request_type_service_mw .label(class="col-sm-3 col-form-label") }} + {{ form_start.request_type_service_tapi }} {{ form_start.request_type_service_tapi.label(class="col-sm-3 col-form-label") }} + {{ form_start.request_type_slice_l2nm }} {{ form_start.request_type_slice_l2nm .label(class="col-sm-3 col-form-label") }} + {{ form_start.request_type_slice_l3nm }} {{ form_start.request_type_slice_l3nm .label(class="col-sm-3 col-form-label") }} +
    +
    +
    + +
    + {{ form_start.offered_load.label(class="col-sm-2 col-form-label") }} +
    + {% if form_start.offered_load.errors %} + {{ form_start.offered_load(class="form-control is-invalid") }} +
    + {% for error in form_start.offered_load.errors %}{{ error }}{% endfor %} +
    + {% else %} + {{ form_start.offered_load(class="form-control") }} + {% endif %} +
    +
    +
    + +
    + {{ form_start.holding_time.label(class="col-sm-2 col-form-label") }} +
    + {% if form_start.holding_time.errors %} + {{ form_start.holding_time(class="form-control is-invalid") }} +
    + {% for error in form_start.holding_time.errors %}{{ error }}{% endfor %} +
    + {% else %} + {{ form_start.holding_time(class="form-control") }} + {% endif %} +
    +
    +
    + +
    + {{ form_start.inter_arrival_time.label(class="col-sm-2 col-form-label") }} +
    + {% if form_start.inter_arrival_time.errors %} + {{ form_start.inter_arrival_time(class="form-control is-invalid") }} +
    + {% for error in form_start.inter_arrival_time.errors %}{{ error }}{% endfor %} +
    + {% else %} + {{ form_start.inter_arrival_time(class="form-control") }} + {% endif %} +
    +
    +
    + +
    + {{ form_start.do_teardown(class="form-control") }} {{ form_start.do_teardown.label(class="col-sm-2 col-form-label") }} +
    +
    + +
    + {{ form_start.record_to_dlt(class="form-control") }} {{ form_start.record_to_dlt.label(class="col-sm-2 col-form-label") }} +
    +
    + +
    + {{ form_start.dlt_domain_id.label(class="col-sm-2 col-form-label") }} +
    + {% if form_start.dlt_domain_id.errors %} + {{ form_start.dlt_domain_id(class="form-control is-invalid") }} +
    + {% for error in form_start.dlt_domain_id.errors %}{{ error }}{% endfor %} +
    + {% else %} + {{ form_start.dlt_domain_id(class="form-control") }} + {% endif %} +
    +
    +
    + +
    + {{ form_start.infinite_loop(class="form-control") }} {{ form_start.infinite_loop.label(class="col-sm-2 col-form-label") }} +
    +
    + +
    + {{ form_start.running(class="form-control") }} {{ form_start.running.label(class="col-sm-2 col-form-label") }} +
    +
    + +
    + {{ form_start.submit(class="btn btn-primary") }} +
    +
    +
    + +
    + {{ form_stop.hidden_tag() }} +
    +
    + {{ form_stop.submit(class="btn btn-primary") }} +
    +
    +
    + +{% endblock %} diff --git a/src/webui/service/templates/main/debug.html b/src/webui/service/templates/main/debug.html index 11a868fdff9f5ee1bcbf22936ae0283d4ccc5715..eef42ae9a9f4cf386d26da0449681bab75f33b41 100644 --- a/src/webui/service/templates/main/debug.html +++ b/src/webui/service/templates/main/debug.html @@ -17,26 +17,12 @@ {% extends 'base.html' %} {% block content %} -

    Debug

    +

    Debug API

    - - -

    Load Generator:

    - Start - Stop + {% endblock %}