recv 和 send 是阻塞的吗？

qfmeal

1.使用fcntl(sockfd,F_SETFL,O_NONBLOCK)；  把socket设置成非阻塞的了。
2.直接使用 recv 接收数据，第四个flags参数设置为0

想问一下这个时候recv或者send是阻塞还是非阻塞的？  谢谢

cokeboL

是非阻塞
另外设置的时候

1. int flag = fcntl(sockfd, F_GETFL);
   
2. if(fcntl(sockfd, F_SETFL, flag | O_NONBLOCK) < 0){
   
3.     close(sockfd);
   
4.     return;
   
5. }
   

复制代码

lxyscls

回复 1# qfmeal

man recv

       MSG_DONTWAIT (since Linux 2.2)
              Enables nonblocking operation; if the operation would block, the call fails with the error EAGAIN  or  EWOULDBLOCK
              (this can also be enabled using the O_NONBLOCK flag with the F_SETFL fcntl(2)).

flags = 0，应该就是不设置标志位。已经设置为non-block，recv/send也就是non-block

/usr/include/bits/socket.h

1. enum
   
2.   {
   
3.     MSG_OOB     = 0x01, /* Process out-of-band data.  */
   
4. #define MSG_OOB     MSG_OOB
   
5.     MSG_PEEK        = 0x02, /* Peek at incoming messages.  */
   
6. #define MSG_PEEK    MSG_PEEK
   
7.     MSG_DONTROUTE   = 0x04, /* Don't use local routing.  */
   
8. #define MSG_DONTROUTE   MSG_DONTROUTE
   
9. #ifdef __USE_GNU
   
10.     /* DECnet uses a different name.  */
    
11.     MSG_TRYHARD     = MSG_DONTROUTE,
    
12. # define MSG_TRYHARD    MSG_DONTROUTE
    
13. #endif
    
14.     MSG_CTRUNC      = 0x08, /* Control data lost before delivery.  */
    
15. #define MSG_CTRUNC  MSG_CTRUNC
    
16.     MSG_PROXY       = 0x10, /* Supply or ask second address.  */
    
17. #define MSG_PROXY   MSG_PROXY
    
18.     MSG_TRUNC       = 0x20,
    
19. #define MSG_TRUNC   MSG_TRUNC
    
20.     MSG_DONTWAIT    = 0x40, /* Nonblocking IO.  */
    
21. #define MSG_DONTWAIT    MSG_DONTWAIT
    
22.     MSG_EOR     = 0x80, /* End of record.  */
    
23. #define MSG_EOR     MSG_EOR
    
24.     MSG_WAITALL     = 0x100, /* Wait for a full request.  */
    
25. #define MSG_WAITALL MSG_WAITALL
    
26.     MSG_FIN     = 0x200,
    
27. #define MSG_FIN     MSG_FIN
    
28.     MSG_SYN     = 0x400,
    
29. #define MSG_SYN     MSG_SYN
    
30.     MSG_CONFIRM     = 0x800, /* Confirm path validity.  */
    
31. #define MSG_CONFIRM MSG_CONFIRM
    
32.     MSG_RST     = 0x1000,
    
33. #define MSG_RST     MSG_RST
    
34.     MSG_ERRQUEUE    = 0x2000, /* Fetch message from error queue.  */
    
35. #define MSG_ERRQUEUE    MSG_ERRQUEUE
    
36.     MSG_NOSIGNAL    = 0x4000, /* Do not generate SIGPIPE.  */
    
37. #define MSG_NOSIGNAL    MSG_NOSIGNAL
    
38.     MSG_MORE        = 0x8000,  /* Sender will send more.  */
    
39. #define MSG_MORE    MSG_MORE
    
40.     MSG_WAITFORONE  = 0x10000, /* Wait for at least one packet to return.*/
    
41. #define MSG_WAITFORONE  MSG_WAITFORONE
    
42. 
    
43.     MSG_CMSG_CLOEXEC    = 0x40000000    /* Set close_on_exit for file
    
44.                        descriptor received through
    
45.                        SCM_RIGHTS.  */
    
46. #define MSG_CMSG_CLOEXEC MSG_CMSG_CLOEXEC
    
47.                                                                     

复制代码

lxyscls

回复 1# qfmeal
delete repeated

lxyscls

回复 1# qfmeal

delete repeated

yulihua49

qfmeal 发表于 2017-07-13 23:11
1.使用fcntl(sockfd,F_SETFL,O_NONBLOCK)；  把socket设置成非阻塞的了。
2.直接使用 recv 接收数据，第四 ...

没设就是阻塞的。设成非阻塞，你怎么等待完成？这是个问题。
我的做法是AIO＋eventfd＋epoll＋协程。。。复杂了。

yulihua49

qfmeal 发表于 2017-07-13 23:11
1.使用fcntl(sockfd,F_SETFL,O_NONBLOCK)；  把socket设置成非阻塞的了。
2.直接使用 recv 接收数据，第四 ...

http://blog.chinaunix.net/uid-16979052-id-3840266.html
这个是非阻塞，AIO。是一个简单的例子，可以运行，没什么用，最后线程还是在等待epoll事件。
加入协程机制后，才有意义，等待epoll之前，应该yield，放弃这个任务干点别的有意义的事。