sysdeps/unix/sysv/linux/mq_timedreceive.c

   1 /* Receive a message from a message queue with a timeout.  Linux version.
   2    Copyright (C) 2017-2021 Free Software Foundation, Inc.
   3    This file is part of the GNU C Library.
   4
   5    The GNU C Library is free software; you can redistribute it and/or
   6    modify it under the terms of the GNU Lesser General Public
   7    License as published by the Free Software Foundation; either
   8    version 2.1 of the License, or (at your option) any later version.
   9
  10    The GNU C Library is distributed in the hope that it will be useful,
  11    but WITHOUT ANY WARRANTY; without even the implied warranty of
  12    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13    Lesser General Public License for more details.
  14
  15    You should have received a copy of the GNU Lesser General Public
  16    License along with the GNU C Library; if not, see
  17    <https://www.gnu.org/licenses/>.  */
  18
  19 #include <mqueue.h>
  20 #include <sysdep-cancel.h>
  21
  22 /* Receive the oldest from highest priority messages in message queue
  23    MQDES, stop waiting if ABS_TIMEOUT expires.  */
  24 ssize_t
  25 __mq_timedreceive_time64 (mqd_t mqdes, char *__restrict msg_ptr, size_t msg_len,
  26                           unsigned int *__restrict msg_prio,
  27                           const struct __timespec64 *__restrict abs_timeout)
  28 {
  29 #ifndef __NR_mq_timedreceive_time64
  30 # define __NR_mq_timedreceive_time64 __NR_mq_timedreceive
  31 #endif
  32   int ret = SYSCALL_CANCEL (mq_timedreceive_time64, mqdes, msg_ptr, msg_len,
  33                             msg_prio, abs_timeout);
  34
  35 #ifndef __ASSUME_TIME64_SYSCALLS
  36   if (ret == 0 || errno != ENOSYS)
  37     return ret;
  38
  39   struct timespec ts32;
  40   if (abs_timeout != NULL)
  41     {
  42       if (! in_time_t_range (abs_timeout->tv_sec))
  43         {
  44           __set_errno (EOVERFLOW);
  45           return -1;
  46         }
  47
  48       ts32 = valid_timespec64_to_timespec (*abs_timeout);
  49     }
  50
  51   ret = SYSCALL_CANCEL (mq_timedreceive, mqdes, msg_ptr, msg_len, msg_prio,
  52                         abs_timeout != NULL ? &ts32 : NULL);
  53 #endif
  54
  55   return ret;
  56 }
  57
  58 #if __TIMESIZE != 64
  59 librt_hidden_def (__mq_timedreceive_time64)
  60
  61 ssize_t
  62 __mq_timedreceive (mqd_t mqdes, char *__restrict msg_ptr, size_t msg_len,
  63                    unsigned int *__restrict msg_prio,
  64                    const struct timespec *__restrict abs_timeout)
  65 {
  66   struct __timespec64 ts64;
  67   if (abs_timeout != NULL)
  68     ts64 = valid_timespec_to_timespec64 (*abs_timeout);
  69
  70   return __mq_timedreceive_time64 (mqdes, msg_ptr, msg_len, msg_prio,
  71                                    abs_timeout != NULL ? &ts64 : NULL);
  72 }
  73 #endif
  74
  75 hidden_def (__mq_timedreceive)
  76 weak_alias (__mq_timedreceive, mq_timedreceive)
  77 hidden_weak (mq_timedreceive)