source: rtems/cpukit/posix/src/mqueuerecvsupp.c @ 874297f3

4.104.114.84.95
Last change on this file since 874297f3 was 874297f3, checked in by Ralf Corsepius <ralf.corsepius@…>, on 04/16/04 at 10:01:03

Remove stray white spaces.

  • Property mode set to 100644
File size: 2.9 KB
Line 
1/*
2 *  NOTE:  The structure of the routines is identical to that of POSIX
3 *         Message_queues to leave the option of having unnamed message
4 *         queues at a future date.  They are currently not part of the
5 *         POSIX standard but unnamed message_queues are.  This is also
6 *         the reason for the apparently unnecessary tracking of
7 *         the process_shared attribute.  [In addition to the fact that
8 *         it would be trivial to add pshared to the mq_attr structure
9 *         and have process private message queues.]
10 *
11 *         This code ignores the O_RDONLY/O_WRONLY/O_RDWR flag at open
12 *         time.
13 *
14 *  $Id$
15 */
16
17#if HAVE_CONFIG_H
18#include "config.h"
19#endif
20
21#include <stdarg.h>
22
23#include <pthread.h>
24#include <limits.h>
25#include <errno.h>
26#include <fcntl.h>
27#include <mqueue.h>
28
29#include <rtems/system.h>
30#include <rtems/score/watchdog.h>
31#include <rtems/seterr.h>
32#include <rtems/posix/mqueue.h>
33#include <rtems/posix/time.h>
34
35/*PAGE
36 *
37 *  _POSIX_Message_queue_Receive_support
38 *
39 *  NOTE: XXX Document how size, priority, length, and the buffer go
40 *        through the layers.
41 */
42
43ssize_t _POSIX_Message_queue_Receive_support(
44  mqd_t               mqdes,
45  char               *msg_ptr,
46  size_t              msg_len,
47  unsigned int       *msg_prio,
48  Watchdog_Interval   timeout
49)
50{
51  POSIX_Message_queue_Control     *the_mq;
52  POSIX_Message_queue_Control_fd  *the_mq_fd;
53  Objects_Locations                location;
54  uint32_t                         length_out;
55
56  the_mq_fd = _POSIX_Message_queue_Get_fd( mqdes, &location );
57  switch ( location ) {
58    case OBJECTS_ERROR:
59      rtems_set_errno_and_return_minus_one( EBADF );
60    case OBJECTS_REMOTE:
61      _Thread_Dispatch();
62      return POSIX_MP_NOT_IMPLEMENTED();
63      rtems_set_errno_and_return_minus_one( EINVAL );
64    case OBJECTS_LOCAL:
65      if ( (the_mq_fd->oflag & O_ACCMODE) == O_WRONLY ) {
66        _Thread_Enable_dispatch();
67        rtems_set_errno_and_return_minus_one( EBADF );
68      }
69
70      the_mq = the_mq_fd->Queue;
71
72      if ( msg_len < the_mq->Message_queue.maximum_message_size ) {
73        _Thread_Enable_dispatch();
74        rtems_set_errno_and_return_minus_one( EMSGSIZE );
75      }
76
77      /*
78       *  Now if something goes wrong, we return a "length" of -1
79       *  to indicate an error.
80       */
81
82      length_out = -1;
83
84      _CORE_message_queue_Seize(
85        &the_mq->Message_queue,
86        mqdes,
87        msg_ptr,
88        &length_out,
89        (the_mq_fd->oflag & O_NONBLOCK) ? FALSE : TRUE,
90        timeout
91      );
92
93      _Thread_Enable_dispatch();
94      *msg_prio =
95        _POSIX_Message_queue_Priority_from_core(_Thread_Executing->Wait.count);
96
97      if ( !_Thread_Executing->Wait.return_code )
98        return length_out;
99
100      rtems_set_errno_and_return_minus_one(
101        _POSIX_Message_queue_Translate_core_message_queue_return_code(
102          _Thread_Executing->Wait.return_code
103        )
104      );
105  }
106  return POSIX_BOTTOM_REACHED();
107}
Note: See TracBrowser for help on using the repository browser.