Return to ipc_mqueue.h CVS log

Up to [GnuMach] / OSKit-Mach / ipc

Annotation of OSKit-Mach/ipc/ipc_mqueue.h, revision 1.1.1.1

1.1       root        1: /*
                      2:  * Mach Operating System
                      3:  * Copyright (c) 1991,1990,1989 Carnegie Mellon University
                      4:  * All Rights Reserved.
                      5:  *
                      6:  * Permission to use, copy, modify and distribute this software and its
                      7:  * documentation is hereby granted, provided that both the copyright
                      8:  * notice and this permission notice appear in all copies of the
                      9:  * software, derivative works or modified versions, and any portions
                     10:  * thereof, and that both notices appear in supporting documentation.
                     11:  *
                     12:  * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
                     13:  * CONDITION.  CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND FOR
                     14:  * ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
                     15:  *
                     16:  * Carnegie Mellon requests users of this software to return to
                     17:  *
                     18:  *  Software Distribution Coordinator  or  [email protected]
                     19:  *  School of Computer Science
                     20:  *  Carnegie Mellon University
                     21:  *  Pittsburgh PA 15213-3890
                     22:  *
                     23:  * any improvements or extensions that they make and grant Carnegie Mellon
                     24:  * the rights to redistribute these changes.
                     25:  */
                     26: /*
                     27:  *     File:   ipc/ipc_mqueue.h
                     28:  *     Author: Rich Draves
                     29:  *     Date:   1989
                     30:  *
                     31:  *     Definitions for message queues.
                     32:  */
                     33: 
                     34: #ifndef        _IPC_IPC_MQUEUE_H_
                     35: #define _IPC_IPC_MQUEUE_H_
                     36: 
                     37: #include <mach/message.h>
                     38: #include <kern/assert.h>
                     39: #include <kern/lock.h>
                     40: #include <kern/macro_help.h>
                     41: #include <ipc/ipc_kmsg.h>
                     42: #include <ipc/ipc_thread.h>
                     43: 
                     44: typedef struct ipc_mqueue {
                     45:        decl_simple_lock_data(, imq_lock_data)
                     46:        struct ipc_kmsg_queue imq_messages;
                     47:        struct ipc_thread_queue imq_threads;
                     48: } *ipc_mqueue_t;
                     49: 
                     50: #define        IMQ_NULL                ((ipc_mqueue_t) 0)
                     51: 
                     52: #define        imq_lock_init(mq)       simple_lock_init(&(mq)->imq_lock_data)
                     53: #define        imq_lock(mq)            simple_lock(&(mq)->imq_lock_data)
                     54: #define        imq_lock_try(mq)        simple_lock_try(&(mq)->imq_lock_data)
                     55: #define        imq_unlock(mq)          simple_unlock(&(mq)->imq_lock_data)
                     56: 
                     57: extern void
                     58: ipc_mqueue_init(/* ipc_mqueue_t */);
                     59: 
                     60: extern void
                     61: ipc_mqueue_move(/* ipc_mqueue_t, ipc_mqueue_t, ipc_port_t */);
                     62: 
                     63: extern void
                     64: ipc_mqueue_changed(/* ipc_mqueue_t, mach_msg_return_t */);
                     65: 
                     66: extern mach_msg_return_t
                     67: ipc_mqueue_send(/* ipc_kmsg_t, mach_msg_option_t, mach_msg_timeout_t */);
                     68: 
                     69: #define        IMQ_NULL_CONTINUE       ((void (*)()) 0)
                     70: 
                     71: extern mach_msg_return_t
                     72: ipc_mqueue_receive(/* ipc_mqueue_t, mach_msg_option_t,
                     73:                      mach_msg_size_t, mach_msg_timeout_t,
                     74:                      boolean_t, void (*)(),
                     75:                      ipc_kmsg_t *, mach_port_seqno_t * */);
                     76: 
                     77: /*
                     78:  *     extern void
                     79:  *     ipc_mqueue_send_always(ipc_kmsg_t);
                     80:  *
                     81:  *     Unfortunately, to avoid warnings/lint about unused variables
                     82:  *     when assertions are turned off, we need two versions of this.
                     83:  */
                     84: 
                     85: #include <kern/assert.h>
                     86: 
                     87: #if    MACH_ASSERT
                     88: 
                     89: #define        ipc_mqueue_send_always(kmsg)                                    \
                     90: MACRO_BEGIN                                                            \
                     91:        mach_msg_return_t mr;                                           \
                     92:                                                                        \
                     93:        mr = ipc_mqueue_send((kmsg), MACH_SEND_ALWAYS,                  \
                     94:                             MACH_MSG_TIMEOUT_NONE);                    \
                     95:        assert(mr == MACH_MSG_SUCCESS);                                 \
                     96: MACRO_END
                     97: 
                     98: #else  /* MACH_ASSERT */
                     99: 
                    100: #define        ipc_mqueue_send_always(kmsg)                                    \
                    101: MACRO_BEGIN                                                            \
                    102:        (void) ipc_mqueue_send((kmsg), MACH_SEND_ALWAYS,                \
                    103:                               MACH_MSG_TIMEOUT_NONE);                  \
                    104: MACRO_END
                    105: 
                    106: #endif /* MACH_ASSERT */
                    107: 
                    108: #endif /* _IPC_IPC_MQUEUE_H_ */

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.