summaryrefslogtreecommitdiffstats
path: root/src/vnet/session
AgeCommit message (Expand)AuthorFilesLines
2017-10-10session: add support for application namespacingFlorin Coras21-630/+2462
2017-10-09vppapigen: support per-file (major,minor,patch) version stampsDave Barach1-1/+3
2017-09-20session: store tep port in net orderFlorin Coras2-7/+7
2017-09-19session/tcp: improve preallocated segment handlingFlorin Coras4-53/+61
2017-09-18Fixes for issues Coverity has reported (VPP-972)Chris Luke3-38/+12
2017-09-12tcp: horizontal scaling improvmentsFlorin Coras2-12/+15
2017-09-07Fix session connect_* api message handling.Dave Wallace3-46/+47
2017-09-06Improve "show segment-manager segments"Dave Barach1-6/+48
2017-09-01Add fixed-size, preallocated pool supportDave Barach3-22/+33
2017-08-30tcp: re-enable persist timer if no data available to sendFlorin Coras1-1/+7
2017-08-29session: segment manager improvementsFlorin Coras7-163/+341
2017-08-25tcp: retransmit and multi-buffer segment fixes and improvementsFlorin Coras4-33/+101
2017-08-18session: fix multi-buffer segmentsFlorin Coras1-19/+22
2017-08-16tcp: fix v6 sessionsroot3-6/+8
2017-08-16tcp: improve builtin http serverFlorin Coras3-11/+12
2017-08-15tcp: state machine improvementsFlorin Coras4-9/+8
2017-08-11Fix tcp multi buffer segments retransmissionFlorin Coras2-17/+28
2017-08-10Improve the svm fifo allocatorDave Barach1-3/+10
2017-08-10TCP proxy prototypeDave Barach6-23/+44
2017-08-02Fix tcp tx buffer allocationFlorin Coras4-18/+116
2017-07-30Make tcp active open data structures thread safeFlorin Coras8-81/+59
2017-07-25Cleanup/refactor session layer codeFlorin Coras11-899/+1044
2017-07-21Improvements to tcp rx path and debuggingFlorin Coras5-14/+130
2017-07-20Prevent double freeing of first segment manager.Dave Wallace1-1/+2
2017-07-15Fixes and improved tcp/session debuggingFlorin Coras3-49/+329
2017-07-14vnet_buffer_t flags cleanupDamjan Marion1-1/+1
2017-07-11Horizontal (nSessions) scaling draftDave Barach10-97/+198
2017-07-06Unlink /dev/shm files on application detach.Dave Wallace4-5/+36
2017-06-22Improve svm fifo and tcp tx path performance (VPP-846)Florin Coras2-9/+11
2017-06-19Overall tcp performance improvements (VPP-846)Florin Coras7-13/+34
2017-06-14Fix session api connect sock handler.Dave Wallace1-1/+10
2017-06-09Implement sack based tcp loss recovery (RFC 6675)Florin Coras4-33/+63
2017-06-07Small update to session APIFlorin Coras2-1/+5
2017-06-01Improve fifo allocator performanceDave Barach7-67/+83
2017-05-20Improve session debuggingFlorin Coras1-17/+30
2017-05-18Remove nop code from session_manager_add_first_segment().Dave Wallace1-2/+0
2017-05-17VPP-846: tcp perf / scale / hardeningDave Barach3-38/+90
2017-05-16Fixes to tcp active opens and receptionDave Barach1-1/+5
2017-05-15Fix builtin tcp clientDave Barach2-1/+5
2017-05-10Multi-thread enablement for the debug cli http serverDave Barach2-1/+15
2017-05-10Builtin debug cli http serverDave Barach2-5/+12
2017-05-09Fix remaining 32-bit compile issuesDamjan Marion2-8/+8
2017-05-09Add support for tcp/session buffer chainsFlorin Coras3-65/+200
2017-05-07Include TCP options in segment size computationFlorin Coras1-1/+1
2017-05-04Fixes and improvements in session hashtable keysClement Durand1-53/+35
2017-05-01TCP ooo reception fixesFlorin Coras2-3/+19
2017-04-25Session/tcp coverity fixesFlorin Coras1-0/+6
2017-04-25"autoreply" flag: autogenerate standard xxx_reply_t messagesDave Barach1-61/+7
2017-04-24Session layer improvementsFlorin Coras10-218/+330
2017-04-21[VPP-704]./uri_tcp_test slave , uri test segment faultflyingeagle231-1/+1
span class="nd">@staticmethod def start_vpp_service(node, retries=60): """Start VPP service on the specified node. :param node: VPP node. :param retries: Number of times (default 60) to re-try waiting. :type node: dict :type retries: int :raises RuntimeError: If VPP service fails to start. """ DUTSetup.start_service(node, Constants.VPP_UNIT) # Sleep 1 second, up to <retry> times, # and verify if VPP is running. for _ in range(retries): time.sleep(1) command = 'vppctl show pci' ret, stdout, _ = exec_cmd(node, command, timeout=30, sudo=True) if not ret and 'Connection refused' not in stdout: break else: raise RuntimeError('VPP failed to start on host {name}'. format(name=node['host'])) DUTSetup.get_service_logs(node, Constants.VPP_UNIT) @staticmethod def start_vpp_service_on_all_duts(nodes): """Start up the VPP service on all nodes. :param nodes: Nodes in the topology. :type nodes: dict """ for node in nodes.values(): if node['type'] == NodeType.DUT: VPPUtil.start_vpp_service(node) @staticmethod def stop_vpp_service(node): """Stop VPP service on the specified node. :param node: VPP node. :type node: dict :raises RuntimeError: If VPP service fails to stop. """ DUTSetup.stop_service(node, Constants.VPP_UNIT) @staticmethod def stop_vpp_service_on_all_duts(nodes): """Stop VPP service on all nodes. :param nodes: Nodes in the topology. :type nodes: dict """ for node in nodes.values(): if node['type'] == NodeType.DUT: VPPUtil.stop_vpp_service(node) @staticmethod def verify_vpp_on_dut(node): """Verify that VPP is installed on DUT node. :param node: DUT node. :type node: dict :raises RuntimeError: If failed to restart VPP, get VPP version or get VPP interfaces. """ VPPUtil.vpp_show_version_verbose(node) VPPUtil.vpp_show_interfaces(node) @staticmethod def verify_vpp_on_all_duts(nodes): """Verify that VPP is installed on all DUT nodes. :param nodes: Nodes in the topology. :type nodes: dict """ for node in nodes.values(): if node['type'] == NodeType.DUT: VPPUtil.start_vpp_service(node) VPPUtil.verify_vpp_on_dut(node) @staticmethod def vpp_show_version(node, verbose=False): """Run "show_version" API command. :param node: Node to run command on. :param verbose: Show version, compile date and compile location if True otherwise show only version. :type node: dict :type verbose: bool :raises PapiError: If no reply received for show_version API command. """ # TODO: move composition of api data to separate method api_data = list() api = dict(api_name='show_version') api_args = dict() api['api_args'] = api_args api_data.append(api) api_reply = None with PapiExecutor(node) as papi_executor: papi_executor.execute_papi(api_data) try: papi_executor.papi_should_have_passed() except AssertionError: raise RuntimeError('Failed to get VPP version on host: {host}'. format(host=node['host'])) api_reply = papi_executor.get_papi_reply() if api_reply is not None: version_data = api_reply[0]['api_reply']['show_version_reply'] ver = version_data['version'].rstrip('\0x00') if verbose: date = version_data['build_date'].rstrip('\0x00') loc = version_data['build_directory'].rstrip('\0x00') version = \ 'VPP Version: {ver}\n' \ 'Compile date: {date}\n' \ 'Compile location: {loc}\n '\ .format(ver=ver, date=date, loc=loc) else: version = 'VPP version:{ver}'.format(ver=ver) logger.info(version) else: raise PapiError('No reply received for show_version API command on ' 'host {host}'.format(host=node['host'])) @staticmethod def vpp_show_version_verbose(node): """Run "show_version" API command and return verbose string of version data. :param node: Node to run command on. :type node: dict """ VPPUtil.vpp_show_version(node, verbose=True) @staticmethod def show_vpp_version_on_all_duts(nodes): """Show VPP version on all DUTs. :param nodes: VPP nodes. :type nodes: dict """ for node in nodes.values(): if node['type'] == NodeType.DUT: VPPUtil.vpp_show_version_verbose(node) @staticmethod def vpp_show_interfaces(node): """Run "show interface" CLI command. :param node: Node to run command on. :type node: dict """ vat = VatExecutor() vat.execute_script("show_interface.vat", node, json_out=False) try: vat.script_should_have_passed() except AssertionError: raise RuntimeError('Failed to get VPP interfaces on host: {name}'. format(name=node['host'])) @staticmethod def vpp_show_crypto_device_mapping(node): """Run "show crypto device mapping" CLI command. :param node: Node to run command on. :type node: dict """ vat = VatExecutor() vat.execute_script("show_crypto_device_mapping.vat", node, json_out=False) @staticmethod def vpp_api_trace_dump(node): """Run "api trace custom-dump" CLI command. :param node: Node to run command on. :type node: dict """ vat = VatExecutor() vat.execute_script("api_trace_dump.vat", node, json_out=False) @staticmethod def vpp_api_trace_save(node): """Run "api trace save" CLI command. :param node: Node to run command on. :type node: dict """ vat = VatExecutor() vat.execute_script("api_trace_save.vat", node, json_out=False) @staticmethod def vpp_enable_traces_on_dut(node): """Enable vpp packet traces on the DUT node. :param node: DUT node to set up. :type node: dict """ vat = VatExecutor() vat.execute_script("enable_dpdk_traces.vat", node, json_out=False) vat.execute_script("enable_vhost_user_traces.vat", node, json_out=False) vat.execute_script("enable_memif_traces.vat", node, json_out=False) @staticmethod def vpp_enable_traces_on_all_duts(nodes): """Enable vpp packet traces on all DUTs in the given topology. :param nodes: Nodes in the topology. :type nodes: dict """ for node in nodes.values(): if node['type'] == NodeType.DUT: VPPUtil.vpp_enable_traces_on_dut(node) @staticmethod def vpp_enable_elog_traces_on_dut(node): """Enable API/CLI/Barrier traces on the DUT node. :param node: DUT node to set up. :type node: dict """ vat = VatExecutor() vat.execute_script("elog_trace_api_cli_barrier.vat", node, json_out=False) @staticmethod def vpp_enable_elog_traces_on_all_duts(nodes): """Enable API/CLI/Barrier traces on all DUTs in the given topology. :param nodes: Nodes in the topology. :type nodes: dict """ for node in nodes.values(): if node['type'] == NodeType.DUT: VPPUtil.vpp_enable_elog_traces_on_dut(node) @staticmethod def show_event_logger_on_dut(node): """Show event logger on the DUT node. :param node: DUT node to show traces on. :type node: dict """ vat = VatExecutor() vat.execute_script("show_event_logger.vat", node, json_out=False) @staticmethod def show_event_logger_on_all_duts(nodes): """Show event logger on all DUTs in the given topology. :param nodes: Nodes in the topology. :type nodes: dict """ for node in nodes.values(): if node['type'] == NodeType.DUT: VPPUtil.show_event_logger_on_dut(node)