Author: hiren
Date: Thu Mar 19 00:23:16 2015
New Revision: 280237
URL: https://svnweb.freebsd.org/changeset/base/280237

Log:
  Add connection flow type to siftr(4).
  
  Suggested by: adrian
  Sponsored by: Limelight Networks

Modified:
  head/share/man/man4/siftr.4
  head/sys/netinet/siftr.c

Modified: head/share/man/man4/siftr.4
==============================================================================
--- head/share/man/man4/siftr.4 Thu Mar 19 00:04:25 2015        (r280236)
+++ head/share/man/man4/siftr.4 Thu Mar 19 00:23:16 2015        (r280237)
@@ -342,6 +342,15 @@ A caveat: Zero '0' either represents a v
 not being set. There is no easy way to differentiate without looking at actual
 network interface card and drivers being used.
 .El
+.Bl -tag -offset indent -width Va
+.It Va 28
+Flow type for the connection.
+Flowtype defines which protocol fields are hashed to produce the flowid. 
+A complete listing is available in
+.Pa sys/mbuf.h
+under
+.Dv M_HASHTYPE_* .
+.El
 .Pp
 The third type of log message is written to the file when the module is 
disabled
 and ceases collecting data from the running kernel.

Modified: head/sys/netinet/siftr.c
==============================================================================
--- head/sys/netinet/siftr.c    Thu Mar 19 00:04:25 2015        (r280236)
+++ head/sys/netinet/siftr.c    Thu Mar 19 00:23:16 2015        (r280237)
@@ -229,6 +229,8 @@ struct pkt_node {
        int                     t_segqlen;
        /* Flowid for the connection. */
        u_int                   flowid; 
+       /* Flow type for the connection. */
+       u_int                   flowtype;       
        /* Link to next pkt_node in the list. */
        STAILQ_ENTRY(pkt_node)  nodes;
 };
@@ -488,7 +490,8 @@ siftr_process_pkt(struct pkt_node * pkt_
                    pkt_node->rcv_buf_cc,
                    pkt_node->sent_inflight_bytes,
                    pkt_node->t_segqlen,
-                   pkt_node->flowid);
+                   pkt_node->flowid,
+                   pkt_node->flowtype);
        } else { /* IPv4 packet */
                pkt_node->ip_laddr[0] = FIRST_OCTET(pkt_node->ip_laddr[3]);
                pkt_node->ip_laddr[1] = SECOND_OCTET(pkt_node->ip_laddr[3]);
@@ -504,7 +507,7 @@ siftr_process_pkt(struct pkt_node * pkt_
                log_buf->ae_bytesused = snprintf(log_buf->ae_data,
                    MAX_LOG_MSG_LEN,
                    "%c,0x%08x,%jd.%06ld,%u.%u.%u.%u,%u,%u.%u.%u.%u,%u,%ld,%ld,"
-                   
"%ld,%ld,%ld,%u,%u,%u,%u,%u,%u,%u,%d,%u,%u,%u,%u,%u,%u,%u\n",
+                   
"%ld,%ld,%ld,%u,%u,%u,%u,%u,%u,%u,%d,%u,%u,%u,%u,%u,%u,%u,%u\n",
                    direction[pkt_node->direction],
                    pkt_node->hash,
                    (intmax_t)pkt_node->tval.tv_sec,
@@ -538,7 +541,8 @@ siftr_process_pkt(struct pkt_node * pkt_
                    pkt_node->rcv_buf_cc,
                    pkt_node->sent_inflight_bytes,
                    pkt_node->t_segqlen,
-                   pkt_node->flowid);
+                   pkt_node->flowid,
+                   pkt_node->flowtype);
 #ifdef SIFTR_IPV6
        }
 #endif
@@ -792,6 +796,7 @@ siftr_siftdata(struct pkt_node *pn, stru
        pn->sent_inflight_bytes = tp->snd_max - tp->snd_una;
        pn->t_segqlen = tp->t_segqlen;
        pn->flowid = inp->inp_flowid;
+       pn->flowtype = inp->inp_flowtype;
 
        /* We've finished accessing the tcb so release the lock. */
        if (inp_locally_locked)
_______________________________________________
svn-src-head@freebsd.org mailing list
http://lists.freebsd.org/mailman/listinfo/svn-src-head
To unsubscribe, send any mail to "svn-src-head-unsubscr...@freebsd.org"

Reply via email to