关于netlink socket的问题

sleepaholic

netlink socket可以使用select函数么

我在应用程序中创建了一个netlink socket， 用想用select(fd + 1, &fdRead, 0, 0, &tv)来看当前有没有从内核发来消息，有的话再用recvmsg()函数接收，但是我发现select函数始终不能返回正数。直接用recvmsg()可以收到消息，但是我不想程序被阻塞。

哪位高手有好的解决方法，谢了先

scutan

使用perror打印一下出错原因呢。

Godbach

可以使用的。LZ可以参考一下iptables实现代码中libipq.c和libipq.h，这个里面是封装了基于Netlink的IP Queue机制，里面使用了select机制。

Godbach

iptables的libipq.c中的代码：

1. 
   
2. static ssize_t ipq_netlink_recvfrom(const struct ipq_handle *h,
   
3.                                     unsigned char *buf, size_t len,
   
4.                                     int timeout)
   
5. {
   
6.         int addrlen, status;
   
7.         struct nlmsghdr *nlh;
   
8. 
   
9.         if (len < sizeof(struct nlmsgerr)) {
   
10.                 ipq_errno = IPQ_ERR_RECVBUF;
    
11.                 return -1;
    
12.         }
    
13.         addrlen = sizeof(h->peer);
    
14. 
    
15.         if (timeout != 0) {
    
16.                 int ret;
    
17.                 struct timeval tv;
    
18.                 fd_set read_fds;
    
19.                
    
20.                 if (timeout < 0) {
    
21.                         /* non-block non-timeout */
    
22.                         tv.tv_sec = 0;
    
23.                         tv.tv_usec = 0;
    
24.                 } else {
    
25.                         tv.tv_sec = timeout / 1000000;
    
26.                         tv.tv_usec = timeout % 1000000;
    
27.                 }
    
28. 
    
29.                 FD_ZERO(&read_fds);
    
30.                 FD_SET(h->fd, &read_fds);
    
31.                 ret = select(h->fd+1, &read_fds, NULL, NULL, &tv);
    
32.                 if (ret < 0) {
    
33.                         if (errno == EINTR) {
    
34.                                 return 0;
    
35.                         } else {
    
36.                                 ipq_errno = IPQ_ERR_RECV;
    
37.                                 return -1;
    
38.                         }
    
39.                 }
    
40.                 if (!FD_ISSET(h->fd, &read_fds)) {
    
41.                         ipq_errno = IPQ_ERR_TIMEOUT;
    
42.                         return 0;
    
43.                 }
    
44.         }
    
45.         status = recvfrom(h->fd, buf, len, 0,
    
46.                               (struct sockaddr *)&h->peer, &addrlen);
    
47.         if (status < 0) {
    
48.                 ipq_errno = IPQ_ERR_RECV;
    
49.                 return status;
    
50.         }
    
51.         if (addrlen != sizeof(h->peer)) {
    
52.                 ipq_errno = IPQ_ERR_RECV;
    
53.                 return -1;
    
54.         }
    
55.         if (h->peer.nl_pid != 0) {
    
56.                 ipq_errno = IPQ_ERR_RECV;
    
57.                 return -1;
    
58.         }
    
59.         if (status == 0) {
    
60.                 ipq_errno = IPQ_ERR_NLEOF;
    
61.                 return -1;
    
62.         }
    
63.         nlh = (struct nlmsghdr *)buf;
    
64.         if (nlh->nlmsg_flags & MSG_TRUNC || nlh->nlmsg_len > status) {
    
65.                 ipq_errno = IPQ_ERR_RTRUNC;
    
66.                 return -1;
    
67.         }
    
68.         return status;
    
69. }

复制代码

emmoblin

在应用层netlink与普通的socket没有任何区别

Godbach

原帖由 emmoblin 于 2008-12-20 21:03 发表
在应用层netlink与普通的socket没有任何区别

netlink就是使用socket通信的。