update of objective

setup.py

@@ -5,7 +5,7 @@
 import setuptools
 
 pkg_name = "snappi_ixload"
-version = "0.0.3"
+version = "0.0.5"
 
 # read long description from readme.md
 base_dir = os.path.abspath(os.path.dirname(__file__))

snappi_ixload/Test_l47-loop.py

@@ -0,0 +1,286 @@
+import sys
+#sys.path.append("C:\\Users\\waseebai\\Documents\\GitHub\\snappi\\artifacts\\snappi")
+#sys.path.insert(0, "C:\\Users\\waseebai\\Documents\\project\\GitHub\\snappi\\artifacts\\snappi")
+
+import snappi
+
+api = snappi.api(location="http://127.0.0.1:5000", verify=False)
+config = api.config()
+
+port_1 = config.ports.port(name="p1", location="amit.buh.is.keysight.com/1/2")[-1]
+port_2 = config.ports.port(name="p2", location="amit.buh.is.keysight.com/2/2")[-1]
+#port_3 = config.ports.port(name="p3", location="tomini.buh.is.keysight.com/2/2")[-1]
+
+(d1, d2,) = config.devices.device(name="d1").device(name="d2")
+(e1,) = d1.ethernets.ethernet(name="d1.e1")
+
+e1.connection.port_name = "p1"
+e1.mac = "70:9C:91:69:00:00"
+e1.step = "00:00:00:00:00:01" 
+e1.count = 1
+
+(e2,) = d2.ethernets.ethernet(name="d2.e2")
+e2.connection.port_name = "p2"
+e2.mac = "7C:5D:68:26:00:00"
+
+(vlan1,) = e1.vlans.vlan(name = "vlan1")
+vlan1.id = 1
+vlan1.priority = 1
+vlan1.tpid = 'x9100'
+(vlan2,) = e2.vlans.vlan(name = "vlan2")
+vlan2.id = 1
+vlan2.priority = 1
+vlan2.tpid = 'x9100'
+(ip1,) = e1.ipv4_addresses.ipv4(name="e1.ipv4")
+ip1.address = "173.173.173.10"
+ip1.gateway = "0.0.0.0"
+ip1.step = "0.0.0.1"
+ip1.count = 1
+(ip2,) = e2.ipv4_addresses.ipv4(name="e2.ipv4")
+ip2.address = "173.173.173.30"
+ip2.gateway = "0.0.0.0"
+
+#TCP/UDP configs
+(t1,) = d1.tcps.tcp(name="Tcp1")
+t1.ip_interface_name = ip1.name
+t1.adjust_tcp_buffers = False
+t1.keep_alive_time = 7000
+t1.keep_alive_interval = 60
+t1.receive_buffer_size = 1024
+t1.transmit_buffer_size = 1024
+t1.retransmission_minimum_timeout = 180
+t1.retransmission_maximum_timeout = 1000
+t1.minimum_source_port = 80
+t1.maximum_source_port = 1024
+t1.inter_packet_gap = 9
+t1.inter_packet_delay = 1
+t1.ip_fragment_time = 1
+t1.fin_timeout = 60
+t1.syn_retries = 5
+t1.synack_retries = 5
+t1.retansmit_retries1 = 3
+t1.retransmit_retries2 = 3
+t1.packet_reordering = 3
+t1.delayed_acks_segments = 0
+t1.delayed_acks_timeout = 0
+t1.port_randomization = False
+t1.disable_path_mtu = False
+t1.window_scaling = False
+t1.selective_ack = False
+t1.time_wait_reuse = False
+t1.time_wait_recycle = False
+t1.time_wait_rfc1323_strict = False
+t1.packet_timestamps = False
+t1.explicit_congestion_notification  = False
+t1.bic = 0
+t1.vegas_alpha = 2
+t1.rfc1337 = True
+t1.mem_low = 24756
+t1.maximum_wmem = 262144
+t1.westwood = 0
+t1.avoid_vegas_congestion = 0
+t1.maximum_rmem = 262144
+t1.orphan_retries = 0
+t1.maximum_time_wait_buckets = 1800
+t1.low_latency = 0
+t1.minimum_rmem = 4096
+t1.window_scale = 2
+t1.minimum_wmem = 4096
+t1.stdurg = False
+t1.maximum_syn_backlog = 1024
+t1.dsack = True
+t1.abort_on_overflow = True
+t1.fragment_reassembly_timer = 0
+t1.vegas_beta = 6
+t1.maximum_orphans = 8192
+t1.mem_pressure = 32768
+t1.moderate_receive_buffer = 0
+t1.no_metrics_save = True
+t1.retrans_collapse = True
+t1.mem_high = 49152
+t1.vegas_gamma = 2
+t1.fack = True
+t1.bic_low_window = 14
+t1.app_win = 31
+t1.keep_alive_probes = 9
+
+(t2,) = d2.tcps.tcp(name="Tcp2")
+t2.ip_interface_name = ip2.name
+t2.time_wait_recycle = False
+t2.time_wait_rfc1323_strict = True
+t2.keep_alive_time = 600
+(http_1,) = d1.https.http(name="HTTP1")
+http_1.tcp_name = t1.name   #UDP configs can be mapped http.transport = udp_1.name
+http_1.enable_tos = False
+http_1.priority_flow_control_class = "v10"
+http_1.precedence_tos = "v20"
+http_1.delay_tos = "v10"
+http_1.throughput_tos = "v10"
+http_1.url_stats_count = 10
+http_1.disable_priority_flow_control =  0
+http_1.enable_vlan_priority = False
+http_1.vlan_priority = 0
+http_1.esm = 1460
+http_1.enable_esm =  False
+http_1.time_to_live_value = 64
+http_1.tcp_close_option = "v10"
+http_1.enable_integrity_check_support = False
+http_1.type_of_service = 0
+http_1.high_perf_with_simulated_user =  False
+(http_client,) = http_1.clients.client()
+http_client.name = "Http1Client1"
+http_client.cookie_jar_size = 100
+http_client.version = "1"
+http_client.cookie_reject_probability = True
+http_client.enable_cookie_support = False
+http_client.command_timeout = 600
+http_client.command_timeout_ms = 0
+http_client.enable_proxy = False
+http_client.keep_alive = False
+http_client.max_sessions = 3
+http_client.max_streams = 1
+http_client.max_pipeline = 1
+http_client.max_persistent_requests = 0
+http_client.exact_transactions = 1
+http_client.follow_http_redirects = False
+http_client.enable_decompress_support = False
+http_client.enable_per_conn_cookie_support = False
+http_client.ip_preference = "v10"
+http_client.enable_large_header = False
+http_client.max_header_len = 1024
+http_client.per_header_percent_dist =  False
+http_client.enable_auth = False
+http_client.piggy_back_ack = True
+http_client.tcp_fast_open = False
+http_client.content_length_deviation_tolerance = 0
+http_client.disable_dns_resolution_cache = False
+http_client.enable_consecutive_ips_per_session = False
+http_client.enable_achieve_cc_first = False
+http_client.enable_traffic_distribution_for_cc = False
+http_client.browser_emulation_name = "Browser1"
+
+# http_client1.name = "Http1Client2"
+# http_client1.cookie_jar_size = 100
+# http_client1.version = "1"
+# http_client1.cookie_reject_probability = True
+
+(http_2,) = d2.https.http(name="HTTP2")
+http_2.tcp_name = t2.name		#UDP configs can be mapped http.transport = udp_2.name
+http_2.enable_tos = False
+http_2.priority_flow_control_class = "v10"
+http_2.precedence_tos = "v20"
+http_2.delay_tos = "v10"
+http_2.throughput_tos = "v10"
+http_2.url_stats_count = 10
+http_2.disable_priority_flow_control = 0
+http_2.enable_vlan_priority = False
+http_2.vlan_priority = 0
+http_2.esm = 1460
+http_2.enable_esm = False 
+http_2.time_to_live_value = 64
+http_2.tcp_close_option = "v10"
+http_2.enable_integrity_check_support = False
+http_2.type_of_service = 0 
+http_2.high_perf_with_simulated_user = False		#UDP configs can be mapped http.transport = udp_2.name
+
+(http_server,) = http_2.servers.server()
+#http_server.name = "Http1Server1"
+http_server.rst_timeout = 100
+http_server.enable_http2 = False
+http_server.port = 80
+http_server.request_timeout = 300
+http_server.maximum_response_delay = 0
+http_server.minimum_response_delay = 0
+http_server.dont_expect_upgrade = False
+http_server.enable_per_server_per_url_stat = False
+http_server.url_page_size = 1024
+http_server.enable_chunk_encoding = False
+http_server.enable_md5_checksum = False
+
+(get_a,delete_a) = http_client.methods.method().method()
+(get1,) = get_a.get.get()
+get1.destination = "Traffic2_Http1Server1:80" 
+get1.page = "./1b.html"
+get1.name_value_args =""
+(delete1,) = delete_a.delete.delete()
+delete1.destination = "Traffic2_Http1Server1:80"
+delete1.page = "./1b.html"
+
+# (get_b,delete_b,post1_b) = http_client1.methods.method().method().method()
+# (get2,) = get_b.get.get()
+# get2.destination = "Traffic2_Http1Server1:80" 
+# get2.page = "./1b.html" 
+# (post2,) = post1_b.post.post()
+# post2.destination = "Traffic2_Http1Server1:80" 
+# post2.page = "./1b.html"
+# post2.name_value_args = "sample"
+# (delete2,) = delete_b.delete.delete()
+# delete2.destination = "Traffic2_Http1Server1:80" 
+# delete2.page = "./1b.html"
+import pdb;pdb.set_trace()
+
+
+tp = config.trafficprofile.trafficprofile()
+#For Http1Client1 
+tp[0].app = [http_client.name]
+tp[0].objective_type = ["connection_per_sec", "simulated_user"]
+tp[0].objective_value = [60, 80]
+tp[0].timeline = ['Timeline1']
+obj_type = tp[0].objectives.objective()
+obj_type[0].connection_per_sec.enable_controlled_user_adjustment = True
+obj_type[0].connection_per_sec.sustain_time=14
+obj_type[0].connection_per_sec.ramp_down_time=12
+obj_type[0].connection_per_sec.time_to_first_iter = 3
+obj_type[0].connection_per_sec.iteration = 4
+# #For simulated_user
+# obj_type[0].simulated_user.ramp_up_value = 5
+# obj_type[0].simulated_user.sustain_time = 7
+# obj_type[0].simulated_user.ramp_down_time =12
+# obj_type[0].simulated_user.enable_controlled_user_adjustment = True
+# obj_type[0].simulated_user.time_to_first_iter = 6
+# obj_type[0].simulated_user.iteration = 5
+# obj_type[0].simulated_user.iteration_time = 81
+# obj_type[0].simulated_user.ramp_up_interval = 2
+# obj_type[0].simulated_user.ramp_up_type= "users_intervals"
+# obj_type[0].simulated_user.ramp_down_value= 13
+
+
+
+# # #For Http1Client2 
+# tp[1].app = [http_client1.name]
+# tp[1].objective_type = ["simulated_user", "connection_per_sec", "transactions_per_sec"]
+# tp[1].objective_value = [50, 90, 85]
+# tp[1].timeline = ['Timeline3']
+# obj_type1 = tp[1].objectives.objective()
+# obj_type1[0].simulated_user.ramp_up_value = 10
+# obj_type1[0].simulated_user.sustain_time = 7
+# obj_type1[0].simulated_user.ramp_down_time =12
+# obj_type1[0].simulated_user.enable_controlled_user_adjustment = True
+# obj_type1[0].simulated_user.time_to_first_iter = 6
+# obj_type1[0].simulated_user.iteration = 5
+# obj_type1[0].simulated_user.iteration_time = 81
+# obj_type1[0].simulated_user.ramp_up_type= "max_pending_user"
+# obj_type1[0].simulated_user.ramp_down_value= 13
+
+
+
+tm1=tp[0].trafficmap.trafficmap()
+#tm1[0].port_map_policy_name  = "port_pairs"
+
+#tm2=tp[0].trafficmap.trafficmap()
+tm1[0].port_map_policy_name  = "custom"
+cust1 = tm1[0].custom.custom()
+cust1[0].name = "samplemap"
+mt1 = cust1[0].mapping_type
+mt1.vlan_range_pairs.enable =True
+mt1.vlan_range_pairs.destination_id = 1
+
+response = api.set_config(config)
+print(response)
+
+cs = api.control_state()
+cs.app.state = 'start'  # cs.app.state.START
+response1 = api.set_control_state(cs)
+print(response1)
+cs.app.state = 'stop'  # cs.app.state.START
+api.set_control_state(cs)

snappi_ixload/Test_l47.py

@@ -242,7 +242,7 @@
 
 tp = config.trafficprofile.trafficprofile()
 #tp[0].objective_type = ["simulated_user", "throughput_kbps", "throughput_mbps", "concurrent_connections", "connection_per_sec", "transactions_per_sec","connection_attempts_per_sec"]
-tp[0].objective_type = ["throughput_mbps"]
+tp[0].objective_type = ['throughput_mbps', 'concurrent_connections']
 tp[0].objective_value = [102]
 tp[0].timeline = ['Timeline1']
 
@@ -308,7 +308,31 @@
 # response1 = api.set_control_state(cs) 
 # print(response1)
 # cs.app.state = 'stop' #cs.app.state.START 
-# api.set_control_state(cs)            
+# api.set_control_state(cs)   
+
+# tp1 = config.trafficprofile.trafficprofile()
+# tp = tp1.trafficmap.name = "port pairs/full mesh/custum"
+# custom1 = tp1.trafficmap.customs.custom()
+
+# mt = custom1.mapping_type.range_pair 
+# mt.sources = [1,2] 
+# mt.destination = [2,1]
+
+# mt = custom1.mapping_type.mesh
+# mt.sources = True
+
+# tp[0].objective_value = [102]
+# tp[0].timeline = ['Timeline1']
+
+# obj_type = tp[0].objectives.objective()
+# tp[0].custom = ["Ipv4_traffic_map", "Ipv6_traffic_map"]
+# tp[0].custom.Ipv4_traffic_map.name = "Submap1"
+# tp[0].custom.Ipv4_traffic_map.enable_ip_mesh = True
+# tp[0].custom.Ipv4_traffic_map.mesh_type = "ip_range_mesh"
+# src = tp[0].custom.Ipv4_traffic_map.sources()
+# src.enable = True
+# src.vlan_id =1
+# src.destination_id = 1         
 
 
 

snappi_ixload/http_config.py

@@ -140,6 +140,9 @@ def _create_http_client(self, device):
                 response = self._api._request('POST', protocol_url, options)
                 protocol_url = protocol_url+response
                 #self._api._config_url[server.server.name] = protocol_url
+                self._api._config_url[http_client.name] = protocol_url
+                payload = {'name' : http_client.name}
+                response = self._api._request('PATCH', protocol_url, payload)
                 payload = self._api._set_payload(http, client_config._HTTP_CLIENT)
                 response = self._api._request('PATCH', protocol_url+"/agent", payload)
                 payload = self._api._set_payload(http_client, client_config._HTTP_CLIENTS)

snappi_ixload/http_server_config.py

@@ -75,6 +75,9 @@ def _create_http_server(self, device):
                 response = self._api._request('POST', protocol_url, options)
                 protocol_url = protocol_url+response
                 #self._api._config_url[server.server.name] = protocol_url
+                self._api._config_url[http_server.name] = protocol_url
+                payload = {'name' : http_server.name}
+                response = self._api._request('PATCH', protocol_url, payload)
                 payload = self._api._set_payload(http, server_config._HTTP_SERVER)
                 response = self._api._request('PATCH', protocol_url+"/agent", payload)
                 payload = self._api._set_payload(http_server, server_config._HTTP_SERVERS)