/*
 * netsniff-ng - the packet sniffing beast
 * Copyright 2009, 2010 Daniel Borkmann.
 * Subject to the GPL, version 2.
 */

#ifndef RING_H
#define RING_H

/*
 * "I love the smell of 10GbE in the morning. Smells like ... victory."
 *     - W. Richard Stevens, "Secret Teachings of the UNIX Environment"
 */

#include <stdio.h>
#include <stdint.h>
#include <linux/if_packet.h>
#include <linux/socket.h>
#include <linux/sockios.h>
#include <sys/ioctl.h>
#include <string.h>
#include <poll.h>
#include <sys/poll.h>

#include "xutils.h"
#include "built_in.h"
#include "die.h"

#ifndef PACKET_FANOUT
# define PACKET_FANOUT			18
# define PACKET_FANOUT_POLICY_HASH	0
# define PACKET_FANOUT_POLICY_LB	1
# define PACKET_FANOUT_POLICY_DEFAULT	PACKET_FANOUT_HASH
#endif

struct frame_map {
	struct tpacket2_hdr tp_h __aligned_tpacket;
	struct sockaddr_ll s_ll __align_tpacket(sizeof(struct tpacket2_hdr));
};

struct ring {
	struct iovec *frames;
	uint8_t *mm_space;
	size_t mm_len;
	struct tpacket_req layout;
	struct sockaddr_ll s_ll;
};

static inline void next_rnd_slot(unsigned int *it, struct ring *ring)
{
	*it = rand() % ring->layout.tp_frame_nr;
}

#define RING_SIZE_FALLBACK (1 << 26)

static inline unsigned int ring_size(char *ifname, unsigned int size)
{
	if (size > 0)
		return size;

	/*
	 * Device bitrate in bytes times two as ring size.
	 *    Fallback => ~    64,00 MB
	 *     10 MBit => ~     2,38 MB
	 *     54 MBit => ~    12,88 MB
	 *    100 MBit => ~    23,84 MB
	 *    300 MBit => ~    71,52 MB
	 *  1.000 MBit => ~   238,42 MB
	 * 10.000 MBit => ~ 2.384.18 MB
	 */
	size = device_bitrate(ifname);
	size = (size * 1000000) / 8;
	size = size * 2;
	if (size == 0)
		size = RING_SIZE_FALLBACK;

	return round_up_cacheline(size);
}

static inline unsigned int ring_frame_size(struct ring *ring)
{
	return ring->layout.tp_frame_size;
}

static inline void tpacket_hdr_clone(struct tpacket2_hdr *thdrd,
				     struct tpacket2_hdr *thdrs)
{
        thdrd->tp_sec = thdrs->tp_sec;
        thdrd->tp_nsec = thdrs->tp_nsec;
        thdrd->tp_snaplen = thdrs->tp_snaplen;
        thdrd->tp_len = thdrs->tp_len;
}

#ifndef POLLRDNORM
# define POLLRDNORM	0x0040
#endif
#ifndef POLLWRNORM
# define POLLWRNORM	0x0100
#endif
#ifndef POLLRDHUP
# define POLLRDHUP	0x2000
#endif

#define POLL_NEXT_PKT	0
#define POLL_MOVE_OUT	1

static inline void prepare_polling(int sock, struct pollfd *pfd)
{
	memset(pfd, 0, sizeof(*pfd));
	pfd->fd = sock;
	pfd->revents = 0;
	pfd->events = POLLIN | POLLRDNORM | POLLERR;
}

static inline void set_sockopt_fanout(int sock, unsigned int fanout_id,
				      unsigned int fanout_type)
{
	unsigned int fanout_arg = (fanout_id | (fanout_type << 16));
	int ret = setsockopt(sock, SOL_PACKET, PACKET_FANOUT, &fanout_arg,
			     sizeof(fanout_arg));
	if (ret)
		panic("No packet fanout support!\n");
}

static inline void set_sockopt_tpacket(int sock)
{
	int ret, val = TPACKET_V2;

	ret = setsockopt(sock, SOL_PACKET, PACKET_VERSION, &val, sizeof(val));
	if (ret)
		panic("Cannot set tpacketv2!\n");
}

#ifdef __WITH_HARDWARE_TIMESTAMPING
# include <linux/net_tstamp.h>

static inline int set_sockopt_hwtimestamp(int sock, const char *dev)
{
	int timesource, ret;
	struct hwtstamp_config hwconfig;
	struct ifreq ifr;

	if (!strncmp("any", dev, strlen("any")))
		return -1;

	memset(&hwconfig, 0, sizeof(hwconfig));
	hwconfig.tx_type = HWTSTAMP_TX_OFF;
	hwconfig.rx_filter = HWTSTAMP_FILTER_ALL;

	memset(&ifr, 0, sizeof(ifr));
	strlcpy(ifr.ifr_name, dev, sizeof(ifr.ifr_name));
	ifr.ifr_data = &hwconfig;

	ret = ioctl(sock, SIOCSHWTSTAMP, &ifr);
	if (ret < 0)
		return -1;

	timesource = SOF_TIMESTAMPING_RAW_HARDWARE;

	return setsockopt(sock, SOL_PACKET, PACKET_TIMESTAMP, &timesource,
			  sizeof(timesource));
}
#else
static inline int set_sockopt_hwtimestamp(int sock, const char *dev)
{
	return -1;
}
#endif
#endif /* RING_H */
25df22a49e4f7a0bfed0d6'/><table><tr><td colspan='2'/></tr><tr><td class='label'>context:</td><td class='ctrl'><select name='context' onchange='this.form.submit();'><option value='1'>1</option><option value='2'>2</option><option value='3' selected='selected'>3</option><option value='4'>4</option><option value='5'>5</option><option value='6'>6</option><option value='7'>7</option><option value='8'>8</option><option value='9'>9</option><option value='10'>10</option><option value='15'>15</option><option value='20'>20</option><option value='25'>25</option><option value='30'>30</option><option value='35'>35</option><option value='40'>40</option></select></td></tr><tr><td class='label'>space:</td><td class='ctrl'><select name='ignorews' onchange='this.form.submit();'><option value='0' selected='selected'>include</option><option value='1'>ignore</option></select></td></tr><tr><td class='label'>mode:</td><td class='ctrl'><select name='dt' onchange='this.form.submit();'><option value='0' selected='selected'>unified</option><option value='1'>ssdiff</option><option value='2'>stat only</option></select></td></tr><tr><td/><td class='ctrl'><noscript><input type='submit' value='reload'/></noscript></td></tr></table></form></div><table summary='commit info' class='commit-info'>
<tr><th>author</th><td>Linus Torvalds &lt;torvalds@linux-foundation.org&gt;</td><td class='right'>2017-01-05 23:06:06 -0800</td></tr>
<tr><th>committer</th><td>Linus Torvalds &lt;torvalds@linux-foundation.org&gt;</td><td class='right'>2017-01-05 23:06:06 -0800</td></tr>
<tr><th>commit</th><td colspan='2' class='oid'><a href='/cgit.cgi/linux/net-next.git/commit/include/net/phonet/gprs.h?h=nds-private-remove&amp;id=6989606a7224a2d5a925df22a49e4f7a0bfed0d6'>6989606a7224a2d5a925df22a49e4f7a0bfed0d6</a> (<a href='/cgit.cgi/linux/net-next.git/patch/include/net/phonet/gprs.h?id=6989606a7224a2d5a925df22a49e4f7a0bfed0d6'>patch</a>)</td></tr>
<tr><th>tree</th><td colspan='2' class='oid'><a href='/cgit.cgi/linux/net-next.git/tree/?h=nds-private-remove&amp;id=6989606a7224a2d5a925df22a49e4f7a0bfed0d6'>2fb686a4dea9a7f4beec97fde510f2840c8e06f9</a> /<a href='/cgit.cgi/linux/net-next.git/tree/include/net/phonet/gprs.h?h=nds-private-remove&amp;id=6989606a7224a2d5a925df22a49e4f7a0bfed0d6'>include/net/phonet/gprs.h</a></td></tr>
<tr><th>parent</th><td colspan='2' class='oid'><a href='/cgit.cgi/linux/net-next.git/commit/include/net/phonet/gprs.h?h=nds-private-remove&amp;id=ed40875dd4b4c7b5c991db9e06c984180ab0b3ce'>ed40875dd4b4c7b5c991db9e06c984180ab0b3ce</a> (<a href='/cgit.cgi/linux/net-next.git/diff/include/net/phonet/gprs.h?h=nds-private-remove&amp;id=6989606a7224a2d5a925df22a49e4f7a0bfed0d6&amp;id2=ed40875dd4b4c7b5c991db9e06c984180ab0b3ce'>diff</a>)</td></tr><tr><th>parent</th><td colspan='2' class='oid'><a href='/cgit.cgi/linux/net-next.git/commit/include/net/phonet/gprs.h?h=nds-private-remove&amp;id=be29d20f3f5db1f0b4e49a4f6eeedf840e2bf9b1'>be29d20f3f5db1f0b4e49a4f6eeedf840e2bf9b1</a> (<a href='/cgit.cgi/linux/net-next.git/diff/include/net/phonet/gprs.h?h=nds-private-remove&amp;id=6989606a7224a2d5a925df22a49e4f7a0bfed0d6&amp;id2=be29d20f3f5db1f0b4e49a4f6eeedf840e2bf9b1'>diff</a>)</td></tr></table>
<div class='commit-subject'>Merge branch 'stable-4.10' of git://git.infradead.org/users/pcmoore/audit</div><div class='commit-msg'>Pull audit fixes from Paul Moore:
 "Two small fixes relating to audit's use of fsnotify.

  The first patch plugs a leak and the second fixes some lock
  shenanigans. The patches are small and I banged on this for an
  afternoon with our testsuite and didn't see anything odd"

* 'stable-4.10' of git://git.infradead.org/users/pcmoore/audit:
  audit: Fix sleep in atomic
  fsnotify: Remove fsnotify_duplicate_mark()
</div><div class='diffstat-header'><a href='/cgit.cgi/linux/net-next.git/diff/?h=nds-private-remove&amp;id=6989606a7224a2d5a925df22a49e4f7a0bfed0d6'>Diffstat</a> (limited to 'include/net/phonet/gprs.h')</div><table summary='diffstat' class='diffstat'>