Fix readmsg.

Readmsg passes all tests successfully.

* readmsg/msglist.c (msglist): Check return from mu_message_get_streamref.
* readmsg/readmsg.c (print_header, print_body): Check return values.

@@ -118,24 +118,31 @@ msglist (mu_mailbox_t mbox, int show_all, int argc, char **argv,
 	  int found = 0;
 	  int found = 0;
 	  for (j = 1; j <= total; j++)
 	  for (j = 1; j <= total; j++)
 	    {
 	    {
+	      int status;
 	      char buf[128];
 	      char buf[128];
 	      size_t len = 0;
 	      size_t len = 0;
 	      mu_message_t msg = NULL;
 	      mu_message_t msg = NULL;
 	      mu_stream_t stream = NULL;
 	      mu_stream_t stream = NULL;
 
 
 	      mu_mailbox_get_message (mbox, j, &msg);
 	      mu_mailbox_get_message (mbox, j, &msg);
-	      mu_message_get_streamref (msg, &stream);
-	      while (mu_stream_readline (stream, buf, sizeof buf, &len) == 0
-		     && len > 0)
+	      status = mu_message_get_streamref (msg, &stream);
+	      if (status)
+		mu_error (_("cannot read message: %s"),
+			  mu_strerror (status));
+	      else
 		{
 		{
-		  if (strstr (buf, argv[i]) != NULL)
+		  while (mu_stream_readline (stream, buf, sizeof buf, &len) == 0
+			 && len > 0)
 		    {
 		    {
-		      addset (set, n, j);
-		      found = 1;
-		      break;
+		      if (strstr (buf, argv[i]) != NULL)
+			{
+			  addset (set, n, j);
+			  found = 1;
+			  break;
+			}
 		    }
 		    }
+		  mu_stream_destroy (&stream);
 		}
 		}
-	      mu_stream_destroy (&stream);
 	      if (found && !show_all)
 	      if (found && !show_all)
 		break;
 		break;
 	    }
 	    }

@@ -222,11 +222,18 @@ print_header (mu_message_t message, int unix_header, int weedc, char **weedv)
     }
     }
   else
   else
     {
     {
+      int status;
       size_t count;
       size_t count;
       size_t i;
       size_t i;
 
 
-      mu_header_get_field_count (header, &count);
-
+      status = mu_header_get_field_count (header, &count);
+      if (status)
+	{
+	  mu_error (_("cannot get number of headers: %s"),
+		    mu_strerror (status));
+	  return;
+	}
+      
       for (i = 1; i <= count; i++)
       for (i = 1; i <= count; i++)
 	{
 	{
 	  int j;
 	  int j;
@@ -259,6 +266,7 @@ print_header (mu_message_t message, int unix_header, int weedc, char **weedv)
 static void
 static void
 print_body (mu_message_t message)
 print_body (mu_message_t message)
 {
 {
+  int status;
   char buf[128];
   char buf[128];
   mu_body_t body = NULL;
   mu_body_t body = NULL;
   mu_stream_t stream = NULL;
   mu_stream_t stream = NULL;
@@ -266,7 +274,12 @@ print_body (mu_message_t message)
   mu_message_get_body (message, &body);
   mu_message_get_body (message, &body);
 
 
   /* FIXME: Use mu_stream_copy */
   /* FIXME: Use mu_stream_copy */
-  mu_body_get_streamref (body, &stream);
+  status = mu_body_get_streamref (body, &stream);
+  if (status)
+    {
+      mu_error (_("cannot get body stream: %s"), mu_strerror (status));
+      return;
+    }
 
 
   while (mu_stream_read (stream, buf, sizeof (buf) - 1, &len) == 0
   while (mu_stream_read (stream, buf, sizeof (buf) - 1, &len) == 0
 	 && len != 0)
 	 && len != 0)