summaryrefslogtreecommitdiffstats
path: root/src/vnet/tcp
AgeCommit message (Expand)AuthorFilesLines
2019-05-27tcp: handle disconnects in rcv-processFlorin Coras1-0/+1
2019-04-16svm_fifo rework to avoid contention on cursizeSirshak Das1-1/+1
2019-04-08host stack: update stale copyrightFlorin Coras9-9/+9
2019-04-05tcp: do not delete session on establish popFlorin Coras3-29/+34
2019-04-04tcp: properly validate acks between snd_nxt and una_maxFlorin Coras1-2/+4
2019-04-04tcp: shorten wait in fin-wait-1 with fin rcvdFlorin Coras3-9/+18
2019-04-02tcp: improve rcv process ack processingFlorin Coras4-68/+79
2019-03-29tcp: remove sent rcv wnd 0 flagFlorin Coras3-13/+2
2019-03-29tcp: improve updating of rcv wndFlorin Coras1-10/+7
2019-03-28tcp: remove unused buffer flagsFlorin Coras2-23/+0
2019-03-27tcp: add cc algo lookup tableFlorin Coras2-7/+17
2019-03-23tcp: make default mtu configurableFlorin Coras3-7/+10
2019-03-22tcp: improve handling of snd_nxtFlorin Coras4-124/+91
2019-03-20tcp: disable cc elog debuggingFlorin Coras1-2/+2
2019-03-14tcp: drop anything but fins in TIME_WAITFlorin Coras1-0/+4
2019-03-13tcp: fix entering closing state while in fast recoveryFlorin Coras1-5/+15
2019-03-13tcp: avoid computing flags in push hdr inlineFlorin Coras1-26/+3
2019-03-12tcp: print congestion control algorithm in cliFlorin Coras1-11/+12
2019-03-08tcp: fix rcv_wnd computationFlorin Coras1-1/+1
2019-03-08session/tcp/vcl: fixes and optimizationsFlorin Coras3-9/+4
2019-03-08tcp: fix window probes in fin-wait-1Florin Coras2-15/+10
2019-03-06tcp: migrate old MULTIARCH macros to VLIB_NODE_FNFilip Tehlar4-109/+77
2019-03-02session: cleanup/rename functionsFlorin Coras4-28/+30
2019-03-01tcp: allow future acks if in windowFlorin Coras1-4/+9
2019-02-22tcp: keep snd sack block free listFlorin Coras3-2/+7
2019-02-22tcp: send enough dupacks to cover all sack holesFlorin Coras4-14/+37
2019-02-21tcp: drop outstanding data when entering closing stateFlorin Coras1-5/+13
2019-02-18session: move fifo allocation logic to app workerFlorin Coras1-1/+1
2019-02-18tcp: harden for high scale scenariosFlorin Coras5-29/+69
2019-02-18tcp: fix handling of retransmitted synsFlorin Coras2-16/+26
2019-02-09buffers: fix typoDamjan Marion1-1/+1
2019-02-09session: refactor listen logicFlorin Coras1-1/+1
2019-02-07tcp: fix fib_index for v6 ll packetsFlorin Coras1-0/+7
2019-02-07tcp: fix reset sending in syn-sentFlorin Coras3-6/+7
2019-02-06buffers: make buffer data size configurable from startup configDamjan Marion1-1/+1
2019-02-06transport: cleanupFlorin Coras2-11/+12
2019-02-04session: cleanup part 1Florin Coras1-5/+5
2019-02-02session: improve show session cliFlorin Coras1-1/+5
2019-02-02tcp: remove internal buffer cacheFlorin Coras2-81/+32
2019-01-20tcp: fix debugging without cc stats (VPP-1547)Florin Coras1-0/+1
2019-01-19buffers: remove free-list information from buffer metadataDamjan Marion1-1/+0
2019-01-18tcp: allow data in passive open ack (VPP-1545)Florin Coras1-2/+3
2019-01-12session: generate wrong thread errors instead of crashingFlorin Coras2-6/+7
2019-01-04tcp: fix reset in syn-sentFlorin Coras1-2/+1
2019-01-03tcp: add more closing state arcsFlorin Coras1-0/+19
2019-01-03tcp: better randomize issFlorin Coras2-4/+41
2019-01-01buffers: remove unused codeDamjan Marion1-2/+1
2019-01-01vcl/ldp: add write msg function and fine tuningFlorin Coras2-4/+7
2018-12-28session: free session after transport and app confirmFlorin Coras2-9/+9
2018-12-26tcp: add more last-ack arcsFlorin Coras1-0/+19
n_avail = vnet_sw_interface_get_mtu (vnet_get_main (), bk->sw_if_index, VNET_MTU_IP4); return (b); } static vlib_buffer_t * igmp_pkt_build_ip_header (igmp_pkt_build_t * bk, igmp_msg_type_t msg_type, const igmp_group_t * group) { ip4_header_t *ip4; vlib_buffer_t *b; u8 *option; b = igmp_pkt_get_buffer (bk); if (NULL == b) return (NULL); ip4 = vlib_buffer_get_current (b); clib_memset (ip4, 0, sizeof (ip4_header_t)); ip4->ip_version_and_header_length = 0x46; ip4->ttl = 1; ip4->protocol = IP_PROTOCOL_IGMP; ip4->tos = 0xc0; ip4_src_address_for_packet (&ip4_main.lookup_main, bk->sw_if_index, &ip4->src_address); vlib_buffer_append (b, sizeof (*ip4)); bk->n_avail -= sizeof (*ip4); switch (msg_type) { case IGMP_MSG_REPORT: ip4->dst_address.as_u32 = IGMP_MEMBERSHIP_REPORT_ADDRESS; break; case IGMP_MSG_QUERY: if (group != NULL) clib_memcpy_fast (&ip4->dst_address, &group->key->ip4, sizeof (ip4_address_t)); else ip4->dst_address.as_u32 = IGMP_GENERAL_QUERY_ADDRESS; break; } /* add the router alert options */ option = vlib_buffer_get_current (b); option[0] = 0x80 | 20; // IP4_ROUTER_ALERT_OPTION; option[1] = 4; // length option[2] = option[3] = 0; vlib_buffer_append (b, 4); bk->n_avail -= 4; return (b); } static vlib_buffer_t * igmp_pkt_build_report_v3 (igmp_pkt_build_report_t * br, const igmp_group_t * group) { igmp_membership_report_v3_t *report; vlib_buffer_t *b; b = igmp_pkt_build_ip_header (&br->base, IGMP_MSG_REPORT, group); if (NULL == b) return (NULL); report = vlib_buffer_get_current (b); report->header.type = IGMP_TYPE_membership_report_v3; report->header.code = 0; report->header.checksum = 0; report->unused = 0; vlib_buffer_append (b, sizeof (igmp_membership_report_v3_t)); br->base.n_avail -= sizeof (igmp_membership_report_v3_t); br->base.n_bytes += sizeof (igmp_membership_report_v3_t); return (b); } static void igmp_pkt_tx (igmp_pkt_build_t * bk) { const igmp_config_t *config; vlib_buffer_t *b; vlib_main_t *vm; vlib_frame_t *f; u32 *to_next; u32 ii; vm = vlib_get_main (); config = igmp_config_lookup (bk->sw_if_index); if (NULL == config) return; f = vlib_get_frame_to_node (vm, ip4_rewrite_mcast_node.index); to_next = vlib_frame_vector_args (f); vec_foreach_index (ii, bk->buffers) { b = vlib_get_buffer (vm, bk->buffers[ii]); vnet_buffer (b)->ip.adj_index[VLIB_TX] = config->adj_index; to_next[ii] = bk->buffers[ii]; f->n_vectors++; } vlib_put_frame_to_node (vm, ip4_rewrite_mcast_node.index, f); IGMP_DBG (" ..tx: %U", format_vnet_sw_if_index_name, vnet_get_main (), bk->sw_if_index); vec_free (bk->buffers); bk->buffers = 0; } static vlib_buffer_t * igmp_pkt_build_report_get_active (igmp_pkt_build_report_t * br) { if (NULL == br->base.buffers) return (NULL); return (vlib_get_buffer (vlib_get_main (), br->base.buffers[vec_len (br->base.buffers) - 1])); } static void igmp_pkt_build_report_bake (igmp_pkt_build_report_t * br) { igmp_membership_report_v3_t *igmp; ip4_header_t *ip4; vlib_buffer_t *b; b = igmp_pkt_build_report_get_active (br); b->current_data = 0; ip4 = vlib_buffer_get_current (b); igmp = (igmp_membership_report_v3_t *) (((u32 *) ip4) + 6); igmp->n_groups = clib_host_to_net_u16 (br->n_groups); igmp->header.checksum = ~ip_csum_fold (ip_incremental_checksum (0, igmp, br->base.n_bytes)); ip4->length = clib_host_to_net_u16 (b->current_length); ip4->checksum = ip4_header_checksum (ip4); br->base.n_bytes = br->base.n_avail = br->n_groups = 0; } void igmp_pkt_report_v3_send (igmp_pkt_build_report_t * br) { if (NULL == br->base.buffers) return; igmp_pkt_build_report_bake (br); igmp_pkt_tx (&br->base); } static u32 igmp_pkt_report_v3_get_size (const igmp_group_t * group) { ASSERT (IGMP_FILTER_MODE_INCLUDE == group->router_filter_mode); return ((hash_elts (group->igmp_src_by_key[IGMP_FILTER_MODE_INCLUDE]) * sizeof (ip4_address_t)) + sizeof (igmp_membership_group_v3_t)); } static igmp_membership_group_v3_t * igmp_pkt_report_v3_append_group (igmp_pkt_build_report_t * br, const ip46_address_t * grp, igmp_membership_group_v3_type_t type) { igmp_membership_group_v3_t *igmp_group; vlib_buffer_t *b; b = igmp_pkt_build_report_get_active (br); if (br->base.n_avail < sizeof (igmp_membership_group_v3_t)) { igmp_pkt_build_report_bake (br); b = igmp_pkt_build_report_v3 (br, NULL); if (NULL == b) return (NULL); } br->base.n_avail -= sizeof (igmp_membership_group_v3_t); br->base.n_bytes += sizeof (igmp_membership_group_v3_t); br->n_groups++; br->n_srcs = 0; igmp_group = vlib_buffer_get_current (b); vlib_buffer_append (b, sizeof (igmp_membership_group_v3_t)); igmp_group->type = type; igmp_group->n_aux_u32s = 0; igmp_group->n_src_addresses = 0; igmp_group->group_address.as_u32 = grp->ip4.as_u32; return (igmp_group); } /** * 4.2.16 " If the set of Group Records required in a Report does not fit within * the size limit of a single Report message (as determined by the MTU * of the network on which it will be sent), the Group Records are sent * in as many Report messages as needed to report the entire set. * If a single Group Record contains so many source addresses that it * does not fit within the size limit of a single Report message, if its * Type is not MODE_IS_EXCLUDE or CHANGE_TO_EXCLUDE_MODE, it is split * into multiple Group Records, each containing a different subset of * the source addresses and each sent in a separate Report message. If * its Type is MODE_IS_EXCLUDE or CHANGE_TO_EXCLUDE_MODE, a single Group * Record is sent, containing as many source addresses as can fit, and * the remaining source addresses are not reported; though the choice of * which sources to report is arbitrary, it is preferable to report the * same set of sources in each subsequent report, rather than reporting * different sources each time." */ static igmp_membership_group_v3_t * igmp_pkt_report_v3_append_src (igmp_pkt_build_report_t * br, igmp_membership_group_v3_t * igmp_group, const ip46_address_t * grp, igmp_membership_group_v3_type_t type, const ip46_address_t * src) { vlib_buffer_t *b; b = igmp_pkt_build_report_get_active (br); if (br->base.n_avail < sizeof (ip4_address_t)) { igmp_group->n_src_addresses = clib_host_to_net_u16 (br->n_srcs); igmp_pkt_build_report_bake (br); b = igmp_pkt_build_report_v3 (br, NULL); if (NULL == b) return (NULL); igmp_group = igmp_pkt_report_v3_append_group (br, grp, type); } igmp_group->src_addresses[br->n_srcs].as_u32 = src->ip4.as_u32; br->n_srcs++; br->base.n_avail -= sizeof (ip4_address_t); br->base.n_bytes += sizeof (ip4_address_t); vlib_buffer_append (b, sizeof (ip4_address_t)); return (igmp_group); } void igmp_pkt_report_v3_add_report (igmp_pkt_build_report_t * br, const ip46_address_t * grp, const ip46_address_t * srcs, igmp_membership_group_v3_type_t type) { igmp_membership_group_v3_t *igmp_group; const ip46_address_t *s; vlib_buffer_t *b; b = igmp_pkt_build_report_get_active (br); if (NULL == b) { b = igmp_pkt_build_report_v3 (br, NULL); if (NULL == b) /* failed to allocate buffer */ return; } igmp_group = igmp_pkt_report_v3_append_group (br, grp, type); if (NULL == igmp_group) return; /* *INDENT-OFF* */ vec_foreach(s, srcs) { igmp_group = igmp_pkt_report_v3_append_src(br, igmp_group, grp, type, s); if (NULL == igmp_group) return; }; /* *INDENT-ON* */ igmp_group->n_src_addresses = clib_host_to_net_u16 (br->n_srcs); IGMP_DBG (" ..add-group: %U", format_ip46_address, grp, IP46_TYPE_IP4); } void igmp_pkt_report_v3_add_group (igmp_pkt_build_report_t * br, const igmp_group_t * group, igmp_membership_group_v3_type_t type) { igmp_membership_group_v3_t *igmp_group; vlib_buffer_t *b; igmp_src_t *src; b = igmp_pkt_build_report_get_active (br); if (NULL == b) { b = igmp_pkt_build_report_v3 (br, NULL); if (NULL == b) /* failed to allocate buffer */ return; } /* * if the group won't fit in a partially full buffer, start again */ if ((0 != br->n_groups) && (igmp_pkt_report_v3_get_size (group) > br->base.n_avail)) { igmp_pkt_build_report_bake (br); b = igmp_pkt_build_report_v3 (br, NULL); if (NULL == b) /* failed to allocate buffer */ return; } igmp_group = igmp_pkt_report_v3_append_group (br, group->key, type); /* *INDENT-OFF* */ FOR_EACH_SRC (src, group, IGMP_FILTER_MODE_INCLUDE, ({ igmp_group = igmp_pkt_report_v3_append_src(br, igmp_group, group->key, type, src->key); if (NULL == igmp_group) return; })); /* *INDENT-ON* */ igmp_group->n_src_addresses = clib_host_to_net_u16 (br->n_srcs); IGMP_DBG (" ..add-group: %U srcs:%d", format_igmp_key, group->key, hash_elts (group->igmp_src_by_key[IGMP_FILTER_MODE_INCLUDE])); } void igmp_pkt_build_report_init (igmp_pkt_build_report_t * br, u32 sw_if_index) { clib_memset (br, 0, sizeof (*br)); br->base.sw_if_index = sw_if_index; } static vlib_buffer_t * igmp_pkt_build_query_get_active (igmp_pkt_build_query_t * bq) { if (NULL == bq->base.buffers) return (NULL); return (vlib_get_buffer (vlib_get_main (), bq->base.buffers[vec_len (bq->base.buffers) - 1])); } static vlib_buffer_t * igmp_pkt_build_query_v3 (igmp_pkt_build_query_t * bq, const igmp_group_t * group) { igmp_membership_query_v3_t *query; vlib_buffer_t *b; b = igmp_pkt_build_ip_header (&bq->base, IGMP_MSG_QUERY, group); if (NULL == b) return (NULL); query = vlib_buffer_get_current (b); query->header.type = IGMP_TYPE_membership_query; query->header.code = 0; query->header.checksum = 0; query->qqi_code = 0; query->resv_s_qrv = 0; if (NULL != group) query->group_address.as_u32 = group->key->ip4.as_u32; else query->group_address.as_u32 = 0; vlib_buffer_append (b, sizeof (igmp_membership_query_v3_t)); bq->base.n_avail -= sizeof (igmp_membership_query_v3_t); bq->base.n_bytes += sizeof (igmp_membership_query_v3_t); return (b); } void igmp_pkt_query_v3_add_group (igmp_pkt_build_query_t * bq, const igmp_group_t * group, const ip46_address_t * srcs) { vlib_buffer_t *b; b = igmp_pkt_build_query_get_active (bq); if (NULL == b) { b = igmp_pkt_build_query_v3 (bq, group); if (NULL == b) /* failed to allocate buffer */ return; } if (NULL != srcs) { igmp_membership_query_v3_t *query; const ip46_address_t *src; query = vlib_buffer_get_current (b); vec_foreach (src, srcs) { query->src_addresses[bq->n_srcs++].as_u32 = src->ip4.as_u32; vlib_buffer_append (b, sizeof (ip4_address_t)); bq->base.n_bytes += sizeof (ip4_address_t); bq->base.n_avail += sizeof (ip4_address_t); } } /* * else * general query and we're done */ } static void igmp_pkt_build_query_bake (igmp_pkt_build_query_t * bq) { igmp_membership_query_v3_t *igmp; ip4_header_t *ip4; vlib_buffer_t *b; b = igmp_pkt_build_query_get_active (bq); b->current_data = 0; ip4 = vlib_buffer_get_current (b); // account for options igmp = (igmp_membership_query_v3_t *) (((u32 *) ip4) + 6); igmp->n_src_addresses = clib_host_to_net_u16 (bq->n_srcs); igmp->header.checksum = ~ip_csum_fold (ip_incremental_checksum (0, igmp, bq->base.n_bytes)); ip4->length = clib_host_to_net_u16 (b->current_length); ip4->checksum = ip4_header_checksum (ip4); bq->base.n_bytes = bq->base.n_avail = bq->n_srcs = 0; } void igmp_pkt_query_v3_send (igmp_pkt_build_query_t * bq) { if (NULL == bq->base.buffers) return; igmp_pkt_build_query_bake (bq); igmp_pkt_tx (&bq->base); } void igmp_pkt_build_query_init (igmp_pkt_build_query_t * bq, u32 sw_if_index) { clib_memset (bq, 0, sizeof (*bq)); bq->base.sw_if_index = sw_if_index; } /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "gnu") * End: */