summaryrefslogtreecommitdiffstats
path: root/src/vnet/session
AgeCommit message (Expand)AuthorFilesLines
2021-06-18session: improve ct locking with multiple workersFlorin Coras5-165/+239
2021-06-18session: udp accept session state should be updated by appjxm1-2/+0
2021-06-17session: optimize ct fifo segment allocationsFlorin Coras4-84/+359
2021-06-12session: fix listener ct transport retrieval on acceptFlorin Coras1-6/+8
2021-06-11session: half-open free only on main threadFlorin Coras1-4/+3
2021-06-03session: avoid ct connects loopFlorin Coras1-1/+2
2021-06-03session: lcl transport info on acceptFlorin Coras2-0/+3
2021-05-25srtp: basic implementation based on libsrtp2Florin Coras2-2/+3
2021-05-21session: improve main thread connects rpcFlorin Coras2-18/+26
2021-05-20session: fix transport half-open cleanup callFlorin Coras1-1/+1
2021-05-19session: cleanup event llist usageFlorin Coras3-41/+27
2021-05-19session: fix session queue node access on disableFlorin Coras1-1/+1
2021-05-18tls: fix dtls with no workersFlorin Coras2-1/+14
2021-05-18session: poll main thread if pending connectsFlorin Coras3-48/+76
2021-05-18session: only handle old ctrl events per dispatchFlorin Coras1-6/+12
2021-05-18session: move tx-buffers to tx ctxFlorin Coras2-16/+14
2021-05-16session: rpc for connects to mainFlorin Coras3-5/+88
2021-05-15session: fix coverity warningFlorin Coras1-1/+1
2021-05-14session: switch ct to vc and track half-opensFlorin Coras5-77/+220
2021-05-14tls: switch dtls to vc and track half-opensFlorin Coras3-10/+73
2021-05-12tls: switch to vc service and track half-open sessionsFlorin Coras5-6/+14
2021-05-12session: return connect session handle to appFlorin Coras6-32/+36
2021-05-12session: support half-close connectionliuyacan8-4/+114
2021-05-10session: use half-open sessions for vc establishmentFlorin Coras8-116/+111
2021-05-07session: connects seg manager is always firstFlorin Coras3-77/+23
2021-05-03session: lookup listener with iface addressliuyacan1-0/+26
2021-05-01vlib: refactor trajectory trace debug featureBenoît Ganne1-5/+0
2021-04-29session: accept notifies for sessions in created stateFlorin Coras1-0/+2
2021-04-29session: cleanup CREATED sessions when listener goes downliuyacan3-0/+63
2021-04-27session: fix mq ext config cleanupFlorin Coras1-2/+1
2021-04-26session: fix race condition in fifo allocationliuyacan3-43/+39
2021-04-23session: set connected session index for ctFlorin Coras1-2/+5
2021-04-23tls quic: improve error reportingFlorin Coras1-1/+4
2021-04-23session: set fifo's session index before vcl attachliuyacan1-0/+2
2021-04-22session: remove unused connect/listen msg membersFlorin Coras1-5/+0
2021-04-22vcl session: refactor passing of crypto contextFlorin Coras6-50/+36
2021-04-22vcl session: extended connect/listen configurationFlorin Coras4-18/+65
2021-04-20tcp: req app deq notification on fifo fullFlorin Coras1-0/+7
2021-04-15tcp: support for rate sample attr flagFlorin Coras1-1/+9
2021-04-14session: fix next node add on transport registrationFlorin Coras1-7/+2
2021-04-14session tcp vcl: api to update connection attributesFlorin Coras8-26/+159
2021-04-07session: fix coverity warningFlorin Coras2-6/+6
2021-04-06session: basic support for interrupt modeFlorin Coras4-4/+176
2021-04-05tcp: time infra improvementsFlorin Coras4-2/+22
2021-04-01session: always clean rx mqs on app detachFlorin Coras1-4/+3
2021-03-30session: interrupt mode for session node on main threadFlorin Coras1-15/+20
2021-03-29svm session vcl: per app rx message queuesFlorin Coras8-101/+496
2021-03-26vlib: convert foreach_vlib_main macro to be more gdb and clang-format friendlyDamjan Marion1-32/+28
2021-03-26vlib: introduce vlib_get_elog_main()Damjan Marion1-1/+1
2021-03-26vlib: introduce vlib_get_main_by_index(), vlib_get_n_threads()Damjan Marion4-4/+4
">f"Received frame has invalid source MAC address: " f"{pkt_recv[Ether].src} should be: {src_mac}" ) if pkt_recv[Ether].dst != dst_mac: raise RuntimeError( f"Received frame has invalid destination MAC address: " f"{pkt_recv[Ether].dst} should be: {dst_mac}" ) if not pkt_recv.haslayer(IPv6): raise RuntimeError( f"Not an IPv6 packet received: {pkt_recv!r}" ) ip6_pkt = pkt_recv[IPv6] if ip6_pkt.src != dir_srcsid: raise RuntimeError( f"Outer IPv6 packet has invalid source address: " f"{ip6_pkt.src} should be: {dir_srcsid}" ) dir_dstsids = [dir_dstsid2, dir_dstsid1] if dir_dstsid3 == u"None" \ else [dir_dstsid3, dir_dstsid2, dir_dstsid1] if not static_proxy \ else [dir_dstsid3, dir_dstsid2] segleft = len(dir_dstsids) - segleft_corr if not static_proxy \ else len(dir_dstsids) - segleft_corr + 1 if ip6_pkt.dst != dir_dstsids[segleft]: raise RuntimeError( f"Outer IPv6 packet has invalid destination address: " f"{ip6_pkt.dst} should be: {dir_dstsids[segleft]}" ) if dir_dstsid2 == u"None": if ip6_pkt.haslayer(IPv6ExtHdrSegmentRouting): raise RuntimeError( f"Segment Routing Header in received packet: {pkt_recv!r}" ) if ip6_pkt.nh != 41: # ipv6nh[41] == IPv6 raise RuntimeError( f"Outer IPv6 packet has invalid next header: " f"{ip6_pkt.nh} should be: 41 ({ipv6nh[41]})" ) ip6_pkt = ip6_pkt[IPv6][1] else: if not pkt_recv.haslayer(IPv6ExtHdrSegmentRouting): raise RuntimeError( f"No Segment Routing Header in received packet: {pkt_recv!r}" ) if ip6_pkt.nh != 43: # ipv6nh[43] == Routing Header raise RuntimeError( f"Outer IPv6 packet has invalid next header: " f"{pkt_recv[IPv6][0].nh} should be: 43 ({ipv6nh[43]})" ) ip6_pkt = ip6_pkt[IPv6ExtHdrSegmentRouting] if ip6_pkt.addresses != dir_dstsids: raise RuntimeError( f"Segment Routing Header has invalid addresses: " f"{ip6_pkt.addresses} should be: {dir_dstsids}" ) if ip6_pkt.segleft != segleft: raise RuntimeError( f"Segment Routing Header has invalid segleft value: " f"{ip6_pkt.segleft} should be: {segleft}" ) if ip6_pkt.nh != 41: # ipv6nh[41] == IPv6 raise RuntimeError( f"Segment Routing Header has invalid next header: " f"{ip6_pkt.nh} should be: 41 ({ipv6nh[41]})" ) ip6_pkt = ip6_pkt[IPv6] if ip6_pkt.src != src_ip: raise RuntimeError( f"Inner IPv6 packet has invalid source address: " f"{ip6_pkt.src} should be: {src_ip}" ) if ip6_pkt.dst != dst_ip: raise RuntimeError( f"Inner IPv6 packet has invalid destination address: " f"{ip6_pkt.dst} should be: {dst_ip}" ) if ip6_pkt.nh != 59: # ipv6nh[59] == No Next Header raise RuntimeError( f"Inner IPv6 packet has invalid next header: " f"{ip6_pkt.nh} should be: 59 ({ipv6nh[59]})" ) def check_ip(pkt_recv, src_mac, dst_mac, src_ip, dst_ip): """Check received IPv6 packet. :param pkt_recv: Received packet to verify. :param src_mac: Source MAC address. :param dst_mac: Destination MAC address. :param src_ip: Source IP/IPv6 address. :param dst_ip: Destination IP/IPv6 address. :type pkt_recv: scapy.Ether :type src_mac: str :type dst_mac: str :type src_ip: str :type dst_ip: str :raises RuntimeError: If received packet is invalid. """ if pkt_recv[Ether].src != src_mac: raise RuntimeError( f"Received frame has invalid source MAC address: " f"{pkt_recv[Ether].src} should be: {src_mac}" ) if pkt_recv[Ether].dst != dst_mac: raise RuntimeError( f"Received frame has invalid destination MAC address: " f"{pkt_recv[Ether].dst} should be: {dst_mac}" ) if not pkt_recv.haslayer(IPv6): raise RuntimeError( f"Not an {IPv6.name} packet received: {pkt_recv!r}" ) if pkt_recv[IPv6].dst != dst_ip: raise RuntimeError( f"Received packet has invalid destination address: " f"{pkt_recv[IPv6.name].dst} should be: {dst_ip}" ) if pkt_recv[IPv6].src != src_ip: raise RuntimeError( f"Received packet has invalid destination address: " f"{pkt_recv[IPv6.name].dst} should be: {src_ip}" ) if pkt_recv[IPv6].nh != 59: # ipv6nh[59] == No Next Header raise RuntimeError( f"Received IPv6 packet has invalid next header: " f"{IPv6.nh} should be: 59 ({ipv6nh[59]})" ) def main(): """Send, receive and check IPv6 and IPv6ExtHdrSegmentRouting packets.""" args = TrafficScriptArg( [ u"tx_src_mac", u"tx_dst_mac", u"rx_src_mac", u"rx_dst_mac", u"src_ip", u"dst_ip", u"dir0_srcsid", u"dir0_dstsid1", u"dir0_dstsid2", u"dir1_srcsid", u"dir1_dstsid1", u"dir1_dstsid2", u"decap", u"dir0_dstsid3", u"dir1_dstsid3", u"static_proxy" ] ) tx_txq = TxQueue(args.get_arg(u"tx_if")) tx_rxq = RxQueue(args.get_arg(u"tx_if")) rx_txq = TxQueue(args.get_arg(u"rx_if")) rx_rxq = RxQueue(args.get_arg(u"rx_if")) tx_src_mac = args.get_arg(u"tx_src_mac") tx_dst_mac = args.get_arg(u"tx_dst_mac") rx_src_mac = args.get_arg(u"rx_src_mac") rx_dst_mac = args.get_arg(u"rx_dst_mac") src_ip = args.get_arg(u"src_ip") dst_ip = args.get_arg(u"dst_ip") dir0_srcsid = args.get_arg(u"dir0_srcsid") dir0_dstsid1 = args.get_arg(u"dir0_dstsid1") dir0_dstsid2 = args.get_arg(u"dir0_dstsid2") dir1_srcsid = args.get_arg(u"dir1_srcsid") dir1_dstsid1 = args.get_arg(u"dir1_dstsid1") dir1_dstsid2 = args.get_arg(u"dir1_dstsid2") decap = args.get_arg(u"decap") dir0_dstsid3 = args.get_arg(u"dir0_dstsid3") dir1_dstsid3 = args.get_arg(u"dir1_dstsid3") static_proxy = args.get_arg(u"static_proxy") ip_pkt = IPv6(src=src_ip, dst=dst_ip) sent_packets = list() tx_pkt_send = (Ether(src=tx_src_mac, dst=tx_dst_mac) / ip_pkt) tx_pkt_send /= Raw() size_limit = 78 if len(tx_pkt_send) < size_limit: tx_pkt_send[Raw].load += (b"\0" * (size_limit - len(tx_pkt_send))) sent_packets.append(tx_pkt_send) tx_txq.send(tx_pkt_send) while True: rx_pkt_recv = rx_rxq.recv(2) if rx_pkt_recv is None: raise RuntimeError(f"{IPv6.name} packet Rx timeout") if rx_pkt_recv.haslayer(ICMPv6ND_NS): # read another packet in the queue if the current one is ICMPv6ND_NS continue elif rx_pkt_recv.haslayer(ICMPv6MLReport2): # read another packet in the queue if the current one is # ICMPv6MLReport2 continue elif rx_pkt_recv.haslayer(ICMPv6ND_RA): # read another packet in the queue if the current one is # ICMPv6ND_RA continue # otherwise process the current packet break check_srv6( rx_pkt_recv, rx_src_mac, rx_dst_mac, src_ip, dst_ip, dir0_srcsid, dir0_dstsid1, dir0_dstsid2, dir0_dstsid3, 1 ) ip_pkt = IPv6(src=dst_ip, dst=src_ip) ip_pkt /= Raw() if len(ip_pkt) < (size_limit - 14): ip_pkt[Raw].load += (b"\0" * (size_limit - 14 - len(ip_pkt))) rx_pkt_send = ( Ether(src=rx_dst_mac, dst=rx_src_mac) / IPv6(src=dir1_srcsid, dst=dir1_dstsid1) / IPv6ExtHdrSegmentRouting( segleft=1 if dir1_dstsid3 == u"None" else 2, lastentry=1 if dir1_dstsid3 == u"None" else 2, addresses=[dir1_dstsid2, dir1_dstsid1] if dir1_dstsid3 == u"None" else [dir1_dstsid3, dir1_dstsid2, dir1_dstsid1] ) / ip_pkt ) if dir1_dstsid2 != u"None" else ( Ether(src=rx_dst_mac, dst=rx_src_mac) / IPv6(src=dir1_srcsid, dst=dir1_dstsid1) / ip_pkt ) rx_txq.send(rx_pkt_send) while True: tx_pkt_recv = tx_rxq.recv(2, ignore=sent_packets) if tx_pkt_recv is None: raise RuntimeError(f"{IPv6.name} packet Rx timeout") if tx_pkt_recv.haslayer(ICMPv6ND_NS): # read another packet in the queue if the current one is ICMPv6ND_NS continue elif tx_pkt_recv.haslayer(ICMPv6MLReport2): # read another packet in the queue if the current one is # ICMPv6MLReport2 continue elif tx_pkt_recv.haslayer(ICMPv6ND_RA): # read another packet in the queue if the current one is # ICMPv6ND_RA continue # otherwise process the current packet break if decap == u"True": check_ip(tx_pkt_recv, tx_dst_mac, tx_src_mac, dst_ip, src_ip) else: check_srv6( tx_pkt_recv, tx_dst_mac, tx_src_mac, dst_ip, src_ip, dir1_srcsid, dir1_dstsid1, dir1_dstsid2, dir1_dstsid3, 2, bool(static_proxy == u"True") ) sys.exit(0) if __name__ == u"__main__": main()