探讨read的返回值的三种情况

882阅读　0评论2011-12-07　小尾巴鱼121121
分类：

作者：gfree.wind@gmail.com
博客：blog.focus-linux.net   linuxfocus.blog.chinaunix.net 
 
本文的copyleft归gfree.wind@gmail.com所有，使用GPL发布，可以自由拷贝，转载。但转载请保持文档的完整性，注明原作者及原链接，严禁用于任何商业用途。
======================================================================================================

今天探讨一个很看似简单的API “read”的返回值问题。read的返回值有哪几个值？每个值又是在什么情况下发生的？

先问一下男人吧：man 2 read
RETURN VALUE
       On success, the number of bytes read is returned (zero indicates end of file), and the file position is advanced by this number.  It is not an error if this number is smaller than the number of bytes requested; this may happen for example because fewer  bytes  are  actually available  right  now (maybe because we were close to end-of-file, or because we are reading from a pipe, or from a terminal), or because read() was interrupted by a signal.  On error, -1 is returned, and errno is set appropriately.  In this case it is left unspecified whether the file position (if any) changes.

从上面的描述中，read的返回值一共有三种情况：
1. 大于0：成功读取的字节数；
2. 等于0：到达文件尾；
3. -1：发生错误，通过errno确定具体错误值。
Note：本次讨论只限于阻塞的fd，不讨论非阻塞的情况。

通过这个man的介绍，看似read的应用很简单，但真的是这样吗？莫忘了Linux中文件是一个很common的概念。它可以是一个真实的文件，也可以是一个socket，一个设备，等等。对于真实的文件，文件尾EOF是一个确定的情况。

那么如果是一个socket，它的返回值何时为0呢？还有，在read的过程中，如果被信号中断，究竟是返回-1，还是返回一个正值或者0呢？当对端关闭后，是否socket还可以读取对端关闭socket前发送的数据呢？

为了搞清楚socket的行为，必须要研究一下对应的kernel的代码。本次以unix域的TCP连接的socket为例，来探讨一下socket的行为。

unix_stream_recvmsg为unix域的TCP连接的socket的读取函数：
  1. static int unix_stream_recvmsg(struct kiocb *iocb, struct socket *sock,
  2.              struct msghdr *msg, size_t size,
  3.              int flags)
  4. {
  5.     struct sock_iocb *siocb = kiocb_to_siocb(iocb);
  6.     struct scm_cookie tmp_scm;
  7.     struct sock *sk = sock->sk;
  8.     struct unix_sock *u = unix_sk(sk);
  9.     struct sockaddr_un *sunaddr = msg->msg_name;
  10.     int copied = 0;
  11.     int check_creds = 0;
  12.     int target;
  13.     int err = 0;
  14.     long timeo;

  16.     err = -EINVAL;
  17.     if (sk->sk_state != TCP_ESTABLISHED)
  18.         goto out;

  20.     err = -EOPNOTSUPP;
  21.     if (flags&MSG_OOB)
  22.         goto out;

  24.     target = sock_rcvlowat(sk, flags&MSG_WAITALL, size);
  25.     timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT);

  27.     msg->msg_namelen = 0;

  29.     /* Lock the socket to prevent queue disordering
  30.      * while sleeps in memcpy_tomsg
  31.      */

  33.     if (!siocb->scm) {
  34.         siocb->scm = &tmp_scm;
  35.         memset(&tmp_scm, 0, sizeof(tmp_scm));
  36.     }

  38.     mutex_lock(&u->readlock);

  40.     do {
  41.         int chunk;
  42.         struct sk_buff *skb;

  44.         unix_state_lock(sk);
  45.         skb = skb_dequeue(&sk->sk_receive_queue);
  46.         if (skb == NULL) {
  47.             if (copied >= target)
  48.                 goto unlock;

  50.             /*
  51.              *    POSIX 1003.1g mandates this order.
  52.              */

  54.             err = sock_error(sk);
  55.             if (err)
  56.                 goto unlock;
  57.             if (sk->sk_shutdown & RCV_SHUTDOWN)
  58.                 goto unlock;

  60.             unix_state_unlock(sk);
  61.             err = -EAGAIN;
  62.             if (!timeo)
  63.                 break;
  64.             mutex_unlock(&u->readlock);

  66.             timeo = unix_stream_data_wait(sk, timeo);

  68.             if (signal_pending(current)) {
  69.                 err = sock_intr_errno(timeo);
  70.                 goto out;
  71.             }
  72.             mutex_lock(&u->readlock);
  73.             continue;
  74.  unlock:
  75.             unix_state_unlock(sk);
  76.             break;
  77.         }
  78.         unix_state_unlock(sk);

  80.         if (check_creds) {
  81.             /* Never glue messages from different writers */
  82.             if ((UNIXCB(skb).pid != siocb->scm->pid) ||
  83.              (UNIXCB(skb).cred != siocb->scm->cred)) {
  84.                 skb_queue_head(&sk->sk_receive_queue, skb);
  85.                 break;
  86.             }
  87.         } else {
  88.             /* Copy credentials */
  89.             scm_set_cred(siocb->scm, UNIXCB(skb).pid, UNIXCB(skb).cred);
  90.             check_creds = 1;
  91.         }

  93.         /* Copy address just once */
  94.         if (sunaddr) {
  95.             unix_copy_addr(msg, skb->sk);
  96.             sunaddr = NULL;
  97.         }

  99.         chunk = min_t(unsigned int, skb->len, size);
  100.         if (memcpy_toiovec(msg->msg_iov, skb->data, chunk)) {
  101.             skb_queue_head(&sk->sk_receive_queue, skb);
  102.             if (copied == 0)
  103.                 copied = -EFAULT;
  104.             break;
  105.         }
  106.         copied += chunk;
  107.         size -= chunk;

  109.         /* Mark read part of skb as used */
  110.         if (!(flags & MSG_PEEK)) {
  111.             skb_pull(skb, chunk);

  113.             if (UNIXCB(skb).fp)
  114.                 unix_detach_fds(siocb->scm, skb);

  116.             /* put the skb back if we didn't use it up.. */
  117.             if (skb->len) {
  118.                 skb_queue_head(&sk->sk_receive_queue, skb);
  119.                 break;
  120.             }

  122.             consume_skb(skb);

  124.             if (siocb->scm->fp)
  125.                 break;
  126.         } else {
  127.             /* It is questionable, see note in unix_dgram_recvmsg.
  128.              */
  129.             if (UNIXCB(skb).fp)
  130.                 siocb->scm->fp = scm_fp_dup(UNIXCB(skb).fp);

  132.             /* put message back and return */
  133.             skb_queue_head(&sk->sk_receive_queue, skb);
  134.             break;
  135.         }
  136.     } while (size);

  138.     mutex_unlock(&u->readlock);
  139.     scm_recv(sock, msg, siocb->scm, flags);
  140. out:
  141.     return copied ? : err;
  142. }
在这个函数中只有一个出口：
  1. return copied ? : err;
copied在unix_stream_recvmsg为已读取的字节数。那么这行代码的意义就比较明显了，当已读取了一定数据，那么read的返回值即为读取的字节数。当没有读取任何数据时，就返回err。

下面看前面提出的两个问题：
1. 何时返回值为0；
2. 被信号中断时，read的返回值是什么？
3. 对端关闭后，是否可以继续读取对端关闭前发送的数据呢？

先看第一个问题：何时返回值为0。这需要copied为0，且err为0。
  1.             err = sock_error(sk);
  2.             if (err)
  3.                 goto unlock;
  4.             if (sk->sk_shutdown & RCV_SHUTDOWN)
  5.                 goto unlock;
这几行代码告诉了我们答案。首先这几行代码是在socket的receive queue没有数据时，才会运行到达的。当socket没有错误时，会继续坚持socket的RCV_SHUTDOWN标志位，如果设置了该标志位，则goto 到unlock，直至最后的return返回语句。此时，copied为0时，err也会为0.
而sk->sk_shutdown的标志位会在两种情况下被设置，参见unix_shutdown函数。在unix_shutdown函数，由API close或者shutdown触发，它不仅设置了本端的sk_shutdown标志位，还会设置对端相对应的sk_shutdown标志位。所以无论是本端还是对端调用shutdown或者close时，都有可能导致本端的read返回为0。这里之所以说可能导致，是因为shutdown时可以指定shutdown的行为，是关闭发送还是接收。

第二个问题，被信号中断时，返回值是什么？
  1.             timeo = unix_stream_data_wait(sk, timeo);

  3.             if (signal_pending(current)) {
  4.                 err = sock_intr_errno(timeo);
  5.                 goto out;
  6.             }
这几行代码是这个问题的答案。这几行代码同样是处于receive queue为空的判断中。那么，这说明如果receive queue中已有数据，且大于要读取的字节数，那么在这个函数中，根本就不会去判断是否有pending的信号，返回值为读取的字节数。如果receive queue中没有足够的数据，那么就会运行到此处，检查是否有pending的信号。当有信号pending时，这时的返回值就决定于copied的值。如果已读取了一些字节，那么就返回copied即已读取了的字节数——小于我们要去读取的字节数。如果没有读取任何字节，那么就返回-1，且errno为EINTR。

第三个问题，对端关闭后，是否可以读取对端在关闭之前发送的数据。
从前面两个问题以及第一个问题的答案。这个问题的答案也很明显了。在unix_stream_recvmsg中，只要receive queue中有数据，那么就不会去检查是否sk_shutdown的标志。所以答案是，即使对端关闭socket，本端仍可以读取对端在关闭之前发送的数据。

本文只探讨了unix域的TCP连接的socket的读取情况。至于其它种类的socket的read行为，我猜测Linux仍然会采取一致的行为——有心人可以去看代码验证一下。

注：本文产生于与crazyhadoop的讨论。


上一篇：ldd3学习之七：中断处理
下一篇：Yii框架使用CDbCriteria引发的一个错误