summaryrefslogtreecommitdiff
path: root/rt/mq_timedreceive_t64.c
blob: d24937a4fffb584ec686bed91a01a4bf50c581da (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
/* Copyright (C) 2004-2017 Free Software Foundation, Inc.
   This file is part of the GNU C Library.

   The GNU C Library is free software; you can redistribute it and/or
   modify it under the terms of the GNU Lesser General Public
   License as published by the Free Software Foundation; either
   version 2.1 of the License, or (at your option) any later version.

   The GNU C Library is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   Lesser General Public License for more details.

   You should have received a copy of the GNU Lesser General Public
   License along with the GNU C Library; if not, see
   <http://www.gnu.org/licenses/>.  */

#include <errno.h>
#include <mqueue.h>

/* 64-bit time version */

extern int __y2038_linux_support;

/* Receive the oldest from highest priority messages in message queue
   MQDES, stop waiting if ABS_TIMEOUT expires.  */
ssize_t
__mq_timedreceive_t64 (mqd_t mqdes, char *__restrict msg_ptr, size_t msg_len,
		 unsigned int *__restrict msg_prio,
		 const struct timespec *__restrict abs_timeout)
{
  struct timespec ts32, *tsp32 = NULL;
  if (__y2038_linux_support)
  {
    /* TODO: use 64-bit syscall */
  }

  if (abs_timeout)
  {
    ts32.tv_sec = abs_timeout->tv_sec;
    ts32.tv_nsec = abs_timeout->tv_nsec;
    tsp32 = &ts32;
  }
  return mq_timedreceive(mqdes, msg_ptr, msg_len, msg_prio, tsp32);
}