Added test script analogue to the LTP test to check the CAN networklayer.

[socketcan-devel.git] / test / tst-rcv-own-msgs.c

diff --git a/test/tst-rcv-own-msgs.c b/test/tst-rcv-own-msgs.c
index ed96e3bc17a555ed9a0820f2442e90f70a66b21e..e7c704b491d9039668bdd66dcafcb5f608724205 100644 (file)
--- a/test/tst-rcv-own-msgs.c
+++ b/test/tst-rcv-own-msgs.c
@@ -62,15 +62,30 @@
 
 #define max(a,b) (a > b ? a : b)
 
-void read_sockets(int s, int t)
+struct rxs {
+       int s;
+       int t;
+};
+
+struct rxs test_sockets(int s, int t, canid_t can_id)
 {
        fd_set rdfs;
        struct timeval tv;
        int m = max(s,t)+1;
        int have_rx = 1;
        struct can_frame frame;
+       struct rxs rx;
        int ret;
 
+       frame.can_id = can_id;
+       frame.can_dlc = 0;
+       if (write(s, &frame, sizeof(frame)) < 0) {
+               perror("write");
+               exit(1);
+       }
+
+       rx.s = rx.t = 0;
+
        while (have_rx) {
 
                FD_ZERO(&rdfs);
@@ -80,7 +95,8 @@ void read_sockets(int s, int t)
                tv.tv_usec = 50000; /* 50ms timeout */
                have_rx = 0;
 
-               if ((ret = select(m, &rdfs, NULL, NULL, &tv)) < 0) {
+               ret = select(m, &rdfs, NULL, NULL, &tv);
+               if (ret < 0) {
                        perror("select");
                        exit(1);
                }
@@ -93,7 +109,11 @@ void read_sockets(int s, int t)
                                perror("read");
                                exit(1);
                        }
-                       printf (" s : %x\n", frame.can_id);
+                       if (frame.can_id != can_id) {
+                               fprintf(stderr, "received wrong can_id!\n");
+                               exit(1);
+                       }
+                       rx.s++;
                }
 
                if (FD_ISSET(t, &rdfs)) {
@@ -104,27 +124,19 @@ void read_sockets(int s, int t)
                                perror("read");
                                exit(1);
                        }
-                       printf (" t : %x\n", frame.can_id);
+                       if (frame.can_id != can_id) {
+                               fprintf(stderr, "received wrong can_id!\n");
+                               exit(1);
+                       }
+                       rx.t++;
                }
-
        }
 
-       printf(" timeout\n");
+       /* timeout */
 
+       return rx;
 }
 
-void write_socket(int s, int val)
-{
-       static struct can_frame frame;
-
-       frame.can_id = val;
-       if (write(s, &frame, sizeof(frame)) < 0) {
-               perror("write");
-               exit(1);
-       }
-}
-
-
 void setopts(int s, int loopback, int recv_own_msgs)
 {
        setsockopt(s, SOL_CAN_RAW, CAN_RAW_LOOPBACK,
@@ -132,7 +144,8 @@ void setopts(int s, int loopback, int recv_own_msgs)
        setsockopt(s, SOL_CAN_RAW, CAN_RAW_RECV_OWN_MSGS,
                   &recv_own_msgs, sizeof(recv_own_msgs));
 
-       printf("sockopt %c %c\n", (loopback)?'L':'-', (recv_own_msgs)?'R':'-');
+       printf("check loopback %d recv_own_msgs %d ... ",
+              loopback, recv_own_msgs);
 }
 
 
@@ -141,9 +154,13 @@ int main(int argc, char **argv)
        int s, t;
        struct sockaddr_can addr;
        struct ifreq ifr;
-       int ifindex;
-       int i = 0;
+       struct rxs rx;
 
+       /* check command line options */
+       if (argc != 2) {
+               fprintf(stderr, "Usage: %s <device>\n", argv[0]);
+               return 1;
+       }
 
        if ((s = socket(PF_CAN, SOCK_RAW, CAN_RAW)) < 0) {
                perror("socket");
@@ -154,12 +171,13 @@ int main(int argc, char **argv)
                return 1;
        }
 
-       strcpy(ifr.ifr_name, "vcan0");
-       ioctl(s, SIOCGIFINDEX, &ifr);
-       ifindex = ifr.ifr_ifindex;
-
+       strcpy(ifr.ifr_name, argv[1]);
+       if (ioctl(s, SIOCGIFINDEX, &ifr) < 0) {
+               perror("SIOCGIFINDEX");
+               return 1;
+       }
+       addr.can_ifindex = ifr.ifr_ifindex;
        addr.can_family = AF_CAN;
-       addr.can_ifindex = ifindex;
 
        if (bind(s, (struct sockaddr *)&addr, sizeof(addr)) < 0) {
                perror("bind");
@@ -170,29 +188,57 @@ int main(int argc, char **argv)
                return 1;
        }
 
+       printf("Starting PF_CAN frame flow test.\n");
+       printf("checking socket default settings ... ");
+       rx = test_sockets(s, t, 0x340);
+       if (rx.s == 0 && rx.t == 1)
+               printf("ok.\n");
+       else {
+               printf("failure!\n");
+               return 1;
+       }
 
-       /* perform the default settings */
-       printf("sockopt default\n");
-       write_socket(s, i++);
-       read_sockets(s, t);
-
+       /* check loopback 0 recv_own_msgs 0 */
        setopts(s, 0, 0);
-       write_socket(s, i++);
-       read_sockets(s, t);
+       rx = test_sockets(s, t, 0x341);
+       if (rx.s == 0 && rx.t == 0)
+               printf("ok.\n");
+       else {
+               printf("failure!\n");
+               return 1;
+       }
 
+       /* check loopback 0 recv_own_msgs 1 */
        setopts(s, 0, 1);
-       write_socket(s, i++);
-       read_sockets(s, t);
+       rx = test_sockets(s, t, 0x342);
+       if (rx.s == 0 && rx.t == 0)
+               printf("ok.\n");
+       else {
+               printf("failure!\n");
+               return 1;
+       }
 
+       /* check loopback 1 recv_own_msgs 0 */
        setopts(s, 1, 0);
-       write_socket(s, i++);
-       read_sockets(s, t);
+       rx = test_sockets(s, t, 0x343);
+       if (rx.s == 0 && rx.t == 1)
+               printf("ok.\n");
+       else {
+               printf("failure!\n");
+               return 1;
+       }
 
+       /* check loopback 1 recv_own_msgs 1 */
        setopts(s, 1, 1);
-       write_socket(s, i++);
-       read_sockets(s, t);
+       rx = test_sockets(s, t, 0x344);
+       if (rx.s == 1 && rx.t == 1)
+               printf("ok.\n");
+       else {
+               printf("failure!\n");
+               return 1;
+       }
 
-       printf("done.\n");
+       printf("PF_CAN frame flow test was successful.\n");
 
        close(s);
        close(t);