From 7191e2220fe1dc6e7ae4ff0af657bfe25b43379f Mon Sep 17 00:00:00 2001 From: "bernard.xiong@gmail.com" Date: Wed, 24 Nov 2010 23:59:27 +0000 Subject: add pthread magic assert. git-svn-id: https://rt-thread.googlecode.com/svn/trunk@1112 bbd45198-f89e-11dd-88c7-29a3b14d5316 --- components/pthreads/mqueue.c | 24 +++--------------------- 1 file changed, 3 insertions(+), 21 deletions(-) (limited to 'components/pthreads/mqueue.c') diff --git a/components/pthreads/mqueue.c b/components/pthreads/mqueue.c index bd31b4450a..f4869a0476 100644 --- a/components/pthreads/mqueue.c +++ b/components/pthreads/mqueue.c @@ -55,13 +55,15 @@ static posix_mq_t *posix_mq_find(const char* name) for (iter = posix_mq_list; iter != RT_NULL; iter = iter->next) { - object = (rt_object_t)&(iter->mq); + object = (rt_object_t)(iter->mq); if (strncmp(object->name, name, RT_NAME_MAX) == 0) { return iter; } } + + return RT_NULL; } int mq_setattr(mqd_t mqdes, const struct mq_attr *mqstat, @@ -193,13 +195,6 @@ ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned *msg_pri return -1; } - /* permission check */ - if (!(mqdes->flags & O_RDONLY)) - { - rt_set_errno(EBADF); - return -1; - } - result = rt_mq_recv(mqdes->mq->mq, msg_ptr, msg_len, RT_WAITING_FOREVER); if (result == RT_EOK) return msg_len; @@ -218,13 +213,6 @@ int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned msg_prio) return -1; } - /* permission check */ - if (!(mqdes->flags & O_WRONLY)) - { - rt_set_errno(EBADF); - return -1; - } - result = rt_mq_send(mqdes->mq->mq, (void*)msg_ptr, msg_len); if (result == RT_EOK) return 0; @@ -245,12 +233,6 @@ ssize_t mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len, rt_set_errno(EINVAL); return -1; } - /* permission check */ - if (!(mqdes->flags & O_RDONLY)) - { - rt_set_errno(EBADF); - return -1; - } tick = libc_time_to_tick(abs_timeout); -- cgit v1.3.1