Как я могу контролировать статус NIC (вверх / вниз) в программе на C без опроса ядра? - PullRequest
Новая
       27

Как я могу контролировать статус NIC (вверх / вниз) в программе на C без опроса ядра?

16 голосов
/ 29 августа 2011

Теперь мне нужно получить статус NIC (вверх или вниз) в режиме реального времени. Это означает, что я должен отлавливать прерывания ядра, когда сетевая плата вверх или вниз в заблокированном цикле.

Первый мой глупый метод заключается в том, чтобы проверить / sys / class / net / eth0 / operstate или использовать ioctl чтобы получить ifflag каждые 100 мс в цикле. Но 100 мс слишком долго, чтобы приложение перенаправляло трафик, а также опрашивал ядро ​​каждые 100 мсек - не очень хорошая идея.

Как только я замечаю функцию inotify , которая может отслеживать файлы в режиме блокировки. Но, к сожалению, он не может отслеживать файл / sys / class / net / eth0 / operstate, поскольку / sys находится в ОЗУ, а не на диске.

Итак, есть ли какие-либо методы, кроме написания модуля ядра, для перехвата прерывания NIC (вверх / вниз) в программе на языке C с блочным режимом?

Ответы [ 3 ]

15 голосов
/ 29 августа 2011

Да, откройте сокет netlink и прослушайте группы многоадресной рассылки RTMGRP_LINK (события создания / удаления / увеличения / уменьшения сетевого интерфейса).

Справочная страница netlink здесь имеет конкретный пример для этого.

8 голосов
/ 13 июня 2014

После небольшого исследования / чтения в Интернете мне удалось составить рабочий код для мониторинга состояния сетевой карты. 

#include <asm/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <errno.h>
#include <stdio.h>
#include <string.h>
#include <net/if.h>
#include <netinet/in.h>
#include <linux/netlink.h>
#include <linux/rtnetlink.h>
#include <stdlib.h>
#include <sys/time.h>
#include <sys/types.h>

int
read_event (int sockint)
{
  int status;
  int ret = 0;
  char buf[4096];
  struct iovec iov = { buf, sizeof buf };
  struct sockaddr_nl snl;
  struct msghdr msg = { (void *) &snl, sizeof snl, &iov, 1, NULL, 0, 0 };
  struct nlmsghdr *h;
  struct ifinfomsg *ifi;

  status = recvmsg (sockint, &msg, 0);

  if (status < 0)
  {
      /* Socket non-blocking so bail out once we have read everything */
      if (errno == EWOULDBLOCK || errno == EAGAIN)
      return ret;

      /* Anything else is an error */
      printf ("read_netlink: Error recvmsg: %d\n", status);
      perror ("read_netlink: Error: ");
      return status;
  }

  if (status == 0)
   {
      printf ("read_netlink: EOF\n");
   }

  // We need to handle more than one message per 'recvmsg'
  for (h = (struct nlmsghdr *) buf; NLMSG_OK (h, (unsigned int) status);
       h = NLMSG_NEXT (h, status))
    {
      //Finish reading 
      if (h->nlmsg_type == NLMSG_DONE)
        return ret;

      // Message is some kind of error 
      if (h->nlmsg_type == NLMSG_ERROR)
    {
          printf ("read_netlink: Message is an error - decode TBD\n");
          return -1;        // Error
        }

      if (h->nlmsg_type == RTM_NEWLINK)
        {
        ifi = NLMSG_DATA (h);
            printf ("NETLINK::%s\n", (ifi->ifi_flags & IFF_RUNNING) ? "Up" : "Down");
    }
    }

  return ret;
}

int
main (int argc, char *argv[])
{
  fd_set rfds, wfds;
  struct timeval tv;
  int retval;
  struct sockaddr_nl addr;

  int nl_socket = socket (AF_NETLINK, SOCK_RAW, NETLINK_ROUTE);
  if (nl_socket < 0)
    {
      printf ("Socket Open Error!");
      exit (1);
    }

  memset ((void *) &addr, 0, sizeof (addr));

  addr.nl_family = AF_NETLINK;
  addr.nl_pid = getpid ();
  addr.nl_groups = RTMGRP_LINK | RTMGRP_IPV4_IFADDR | RTMGRP_IPV6_IFADDR;
//  addr.nl_groups = RTMGRP_LINK;

  if (bind (nl_socket, (struct sockaddr *) &addr, sizeof (addr)) < 0)
    {
      printf ("Socket bind failed!");
      exit (1);
    }

  while (1)
    {
      FD_ZERO (&rfds);
      FD_CLR (nl_socket, &rfds);
      FD_SET (nl_socket, &rfds);

      tv.tv_sec = 10;
      tv.tv_usec = 0;

      retval = select (FD_SETSIZE, &rfds, NULL, NULL, &tv);
      if (retval == -1)
        printf ("Error select() \n");
      else if (retval)
        {
          printf ("Event recieved >> ");
          read_event (nl_socket);
        }
      else
        printf ("## Select TimedOut ## \n");
    }
  return 0;
}
0 голосов
/ 29 августа 2011

Вы пробовали отслеживать файл /sys/class/net/eth0/operstate с помощью функции select или poll? Насколько я могу сказать, sysfs файлы должны вести себя так же, как и обычные файлы: при каждом изменении вы должны получить уведомление о дескрипторе файла, что что-то изменилось, и вы должны быть в состоянии ответить соответственно.

...