Lines Matching defs:flow1
625 copy_flow_data(struct pflow_flow *flow1, struct pflow_flow *flow2,
628 flow1->src_ip = flow2->dest_ip = sk->addr[src].v4.s_addr;
629 flow1->src_port = flow2->dest_port = sk->port[src];
630 flow1->dest_ip = flow2->src_ip = sk->addr[dst].v4.s_addr;
631 flow1->dest_port = flow2->src_port = sk->port[dst];
633 flow1->dest_as = flow2->src_as =
634 flow1->src_as = flow2->dest_as = 0;
635 flow1->if_index_in = htons(st->if_index_in);
636 flow1->if_index_out = htons(st->if_index_out);
639 flow1->dest_mask = flow2->src_mask =
640 flow1->src_mask = flow2->dest_mask = 0;
642 flow1->flow_packets = htonl(st->packets[0]);
644 flow1->flow_octets = htonl(st->bytes[0]);
652 flow1->flow_start = flow2->flow_start = st->creation < 0 ||
654 flow1->flow_finish = flow2->flow_finish = st->expire < 0 ? htonl(0) :
656 flow1->tcp_flags = flow2->tcp_flags = 0;
657 flow1->protocol = flow2->protocol = sk->proto;
658 flow1->tos = flow2->tos = st->rule->tos;
662 copy_flow_ipfix_4_data(struct pflow_ipfix_flow4 *flow1,
666 flow1->src_ip = flow2->dest_ip = sk->addr[src].v4.s_addr;
667 flow1->src_port = flow2->dest_port = sk->port[src];
668 flow1->dest_ip = flow2->src_ip = sk->addr[dst].v4.s_addr;
669 flow1->dest_port = flow2->src_port = sk->port[dst];
671 flow1->if_index_in = htonl(st->if_index_in);
672 flow1->if_index_out = htonl(st->if_index_out);
676 flow1->flow_packets = htobe64(st->packets[0]);
678 flow1->flow_octets = htobe64(st->bytes[0]);
686 flow1->flow_start = flow2->flow_start = htobe64((time_second -
689 flow1->flow_start = flow2->flow_start = htobe64((pf_get_time() -
691 flow1->flow_finish = flow2->flow_finish = htobe64((pf_get_time() -
694 flow1->protocol = flow2->protocol = sk->proto;
695 flow1->tos = flow2->tos = st->rule->tos;
699 copy_flow_ipfix_6_data(struct pflow_ipfix_flow6 *flow1,
703 bcopy(&sk->addr[src].v6, &flow1->src_ip, sizeof(flow1->src_ip));
705 flow1->src_port = flow2->dest_port = sk->port[src];
706 bcopy(&sk->addr[dst].v6, &flow1->dest_ip, sizeof(flow1->dest_ip));
708 flow1->dest_port = flow2->src_port = sk->port[dst];
710 flow1->if_index_in = htonl(st->if_index_in);
711 flow1->if_index_out = htonl(st->if_index_out);
715 flow1->flow_packets = htobe64(st->packets[0]);
717 flow1->flow_octets = htobe64(st->bytes[0]);
725 flow1->flow_start = flow2->flow_start = htobe64((time_second -
728 flow1->flow_start = flow2->flow_start = htobe64((pf_get_time() -
730 flow1->flow_finish = flow2->flow_finish = htobe64((pf_get_time() -
733 flow1->protocol = flow2->protocol = sk->proto;
734 flow1->tos = flow2->tos = st->rule->tos;
960 struct pflow_flow flow1;
964 bzero(&flow1, sizeof(flow1));
968 copy_flow_data(&flow1, &flow2, st, sk, 1, 0);
970 copy_flow_data(&flow1, &flow2, st, sk, 0, 1);
973 ret = copy_flow_to_m(&flow1, sc);