lthreads = _globals.pop('threads', [])
for i, host in enumerate(host_list):
url = url_templ.substitute({'HOST': host})
- timeout = int(subst_dict['DURATION']) + 3*125+10
+ timeout = int(subst_dict['DURATION']) + 3 * 125 + 10
prefix_id = subst_dict['ID_PREFIX'] + str(index_list[i])
subst_dict['ID'] = prefix_id
data = data_templ.substitute(subst_dict)
<transactions-per-second>$RATE</transactions-per-second>
<chained-transactions>$CHAINED_FLAG</chained-transactions>
</input>''')
- subst_dict = {'ID_PREFIX': id_prefix, 'DURATION': duration, 'RATE': rate, 'CHAINED_FLAG': chained_flag}
+ subst_dict = {'ID_PREFIX': id_prefix, 'DURATION': duration,
+ 'RATE': rate, 'CHAINED_FLAG': 'true' if chained_flag else 'false'}
urlt = string.Template('''http://$HOST:8181/restconf/operations/odl-mdsal-lowlevel-control:write-transactions''')
_initiate_rpcs(host_list, index_list, urlt, datat, subst_dict)
_globals.clear()
msg = "host_list:{}, index_list:{} ,id_prefix:{}, duration:{}, rate:{}, isolated_transactions:{}".format(
- host_list, index_list, id_prefix, duration, rate, isolated_transactions_flag)
+ host_list, index_list, id_prefix, duration, rate, isolated_transactions_flag)
msg = "Input parameters: " + msg
logger.info(msg)
datat = string.Template('''<input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control">
<isolated-transactions>$ISOLATED_TRANSACTIONS</isolated-transactions>
</input>''')
subst_dict = {'ID_PREFIX': id_prefix, 'DURATION': duration, 'RATE': rate,
- 'ISOLATED_TRANSACTIONS': isolated_transactions_flag}
+ 'ISOLATED_TRANSACTIONS': 'true' if isolated_transactions_flag else 'false'}
urlt = string.Template('''http://$HOST:8181/restconf/operations/odl-mdsal-lowlevel-control:produce-transactions''')
_initiate_rpcs(host_list, index_list, urlt, datat, subst_dict)