aboutsummaryrefslogtreecommitdiffstats
path: root/test/test_mpcap.py
blob: d77b543799f198464a075371fcbdffa183b78ed6 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
#!/usr/bin/env python3

import unittest

from framework import VppTestCase, VppTestRunner, running_extended_tests
from vpp_ip_route import VppIpTable, VppIpRoute, VppRoutePath
import os


class TestMpcap(VppTestCase):
    """ Mpcap Unit Test Cases """

    @classmethod
    def setUpClass(cls):
        super(TestMpcap, cls).setUpClass()

    @classmethod
    def tearDownClass(cls):
        super(TestMpcap, cls).tearDownClass()

    def setUp(self):
        super(TestMpcap, self).setUp()

    def tearDown(self):
        super(TestMpcap, self).tearDown()

    def test_mpcap_unittest(self):
        """ Mapped pcap file test """
        cmds = ["packet-generator new {\n"
                " name mpcap\n"
                " limit 15\n"
                " size 128-128\n"
                " interface local0\n"
                " node mpcap-unittest\n"
                " data {\n"
                "   IP6: 00:d0:2d:5e:86:85 -> 00:0d:ea:d0:00:00\n"
                "   ICMP: db00::1 -> db00::2\n"
                "   incrementing 30\n"
                "   }\n",
                "trace add pg-input 15",
                "pa en",
                "show trace",
                "show error"]

        for cmd in cmds:
            self.logger.info(self.vapi.cli(cmd))

        size = os.path.getsize("/tmp/mpcap_unittest.pcap")
        os.remove("/tmp/mpcap_unittest.pcap")
        if size != 2184:
            self.logger.critical("BUG: file size %d not 2184" % size)
            self.assertNotIn('WrongMPCAPFileSize', 'WrongMPCAPFileSize')

if __name__ == '__main__':
    unittest.main(testRunner=VppTestRunner)
pan> #include <vppinfra/error.h> #include <vppinfra/format.h> typedef struct _socket_t { /* File descriptor. */ i32 fd; /* Config string for socket HOST:PORT or just HOST. */ char *config; u32 flags; #define CLIB_SOCKET_F_IS_SERVER (1 << 0) #define CLIB_SOCKET_F_IS_CLIENT (0 << 0) #define CLIB_SOCKET_F_RX_END_OF_FILE (1 << 2) #define CLIB_SOCKET_F_NON_BLOCKING_CONNECT (1 << 3) #define CLIB_SOCKET_F_ALLOW_GROUP_WRITE (1 << 4) #define CLIB_SOCKET_F_SEQPACKET (1 << 5) #define CLIB_SOCKET_F_PASSCRED (1 << 6) /* Transmit buffer. Holds data waiting to be written. */ u8 *tx_buffer; /* Receive buffer. Holds data read from socket. */ u8 *rx_buffer; /* Peer socket we are connected to. */ struct sockaddr_in peer; /* Credentials, populated if CLIB_SOCKET_F_PASSCRED is set */ pid_t pid; uid_t uid; gid_t gid; clib_error_t *(*write_func) (struct _socket_t * sock); clib_error_t *(*read_func) (struct _socket_t * sock, int min_bytes); clib_error_t *(*close_func) (struct _socket_t * sock); clib_error_t *(*recvmsg_func) (struct _socket_t * s, void *msg, int msglen, int fds[], int num_fds); clib_error_t *(*sendmsg_func) (struct _socket_t * s, void *msg, int msglen, int fds[], int num_fds); uword private_data; } clib_socket_t; /* socket config format is host:port. Unspecified port causes a free one to be chosen starting from IPPORT_USERRESERVED (5000). */ clib_error_t *clib_socket_init (clib_socket_t * socket); clib_error_t *clib_socket_accept (clib_socket_t * server, clib_socket_t * client); always_inline uword clib_socket_is_server (clib_socket_t * sock) { return (sock->flags & CLIB_SOCKET_F_IS_SERVER) != 0; } always_inline uword clib_socket_is_client (clib_socket_t * s) { return !clib_socket_is_server (s); } always_inline uword clib_socket_is_connected (clib_socket_t * sock) { return sock->fd > 0; } always_inline int clib_socket_rx_end_of_file (clib_socket_t * s) { return s->flags & CLIB_SOCKET_F_RX_END_OF_FILE; } always_inline void * clib_socket_tx_add (clib_socket_t * s, int n_bytes) { u8 *result; vec_add2 (s->tx_buffer, result, n_bytes); return result; } always_inline void clib_socket_tx_add_va_formatted (clib_socket_t * s, char *fmt, va_list * va) { s->tx_buffer = va_format (s->tx_buffer, fmt, va); } always_inline clib_error_t * clib_socket_tx (clib_socket_t * s) { return s->write_func (s); } always_inline clib_error_t * clib_socket_rx (clib_socket_t * s, int n_bytes) { return s->read_func (s, n_bytes); } always_inline clib_error_t * clib_socket_sendmsg (clib_socket_t * s, void *msg, int msglen, int fds[], int num_fds) { return s->sendmsg_func (s, msg, msglen, fds, num_fds); } always_inline clib_error_t * clib_socket_recvmsg (clib_socket_t * s, void *msg, int msglen, int fds[], int num_fds) { return s->recvmsg_func (s, msg, msglen, fds, num_fds); } always_inline void clib_socket_free (clib_socket_t * s) { vec_free (s->tx_buffer); vec_free (s->rx_buffer); if (clib_mem_is_heap_object (s->config)) vec_free (s->config); clib_memset (s, 0, sizeof (s[0])); } always_inline clib_error_t * clib_socket_close (clib_socket_t * sock) { clib_error_t *err; err = (*sock->close_func) (sock); return err; } void clib_socket_tx_add_formatted (clib_socket_t * s, char *fmt, ...); #endif /* _clib_included_socket_h */ /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "gnu") * End: */