practicas/pipi/src/test_ipin.cpp

   1
   2 #include "ipin.h"
   3 #include "ipaddr.h"
   4 #include "dev.h"
   5 #include <iostream>
   6 #include <cstdlib>
   7 #include <unistd.h>
   8 #include <fcntl.h>
   9 #include <sys/types.h>
  10 #include <sys/ipc.h>
  11 #include <sys/msg.h>
  12
  13 // Uso: ./test_ipin ip mtu router forward proto queue_id
  14
  15 int main(int argc, char* argv[])
  16 {
  17     IPAddr addr("10.10.10.1");
  18     unsigned mtu = 25;
  19     bool router = false;
  20     bool forward = false;
  21     unsigned proto = 0;
  22     key_t queue_id = DEV_DEFAULT_KEY;
  23     if (argc > 1)
  24         addr = IPAddr(argv[1]);
  25     if (argc > 2)
  26         mtu = atoi(argv[2]);
  27     if (argc > 3)
  28         router = atoi(argv[3]);
  29     if (argc > 4)
  30         forward = atoi(argv[4]);
  31     if (argc > 5)
  32         proto = atoi(argv[5]);
  33     if (argc > 6)
  34         queue_id = atoi(argv[6]);
  35     int que_id = msgget(queue_id, IPC_CREAT | 0666);
  36     assert(que_id != -1);
  37     Dev dev(addr, mtu, queue_id);
  38     que_id = msgget(queue_id+1, IPC_CREAT | 0666);
  39     assert(que_id != -1);
  40     Dev fwque(addr, DEV_MAX_MTU, queue_id+1);
  41     IPIn ipin(addr, dev, fwque, router, forward, std::cerr);
  42     struct msqid_ds minfo;
  43     for (msgctl(dev.que_id, IPC_STAT, &minfo); minfo.msg_qnum;
  44             msgctl(dev.que_id, IPC_STAT, &minfo))
  45     {
  46         IPAddr src, dst;
  47         std::cout << "Quedan " << minfo.msg_qnum << " mensajes en la cola\n";
  48         std::string s = ipin.recv(proto, src, dst);
  49         std::cout << "Recibido '" << s << "' (len " << s.size() << ") de "
  50             << src << " para " << dst << " (proto = " << proto << ")\n";
  51     }
  52     return 0;
  53 }
  54
  55 // vim: set et sw=4 sts=4 :