Return to server_loop.ch CVS log

Up to [GnuMach] / OSKit-Mach / kern

Annotation of OSKit-Mach/kern/server_loop.ch, revision 1.1

1.1     ! root        1: /* 
        !             2:  * Mach Operating System
        !             3:  * Copyright (c) 1991,1990,1989,1988,1987 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:   kern/server_loop.c
        !            28:  *
        !            29:  *     A common server loop for builtin tasks.
        !            30:  */
        !            31: 
        !            32: /*
        !            33:  *     Must define symbols for:
        !            34:  *             SERVER_NAME             String name of this module
        !            35:  *             SERVER_LOOP             Routine name for the loop
        !            36:  *             SERVER_DISPATCH         MiG function(s) to handle message
        !            37:  *
        !            38:  *     Must redefine symbols for pager_server functions.
        !            39:  */
        !            40: 
        !            41: #include <mach/port.h>
        !            42: #include <mach/message.h>
        !            43: #include <vm/vm_kern.h>                /* for kernel_map */
        !            44: 
        !            45: void SERVER_LOOP(rcv_set, max_size)
        !            46: {
        !            47:        register mach_msg_header_t *in_msg;
        !            48:        register mach_msg_header_t *out_msg;
        !            49:        register mach_msg_header_t *tmp_msg;
        !            50:        vm_offset_t messages;
        !            51:        mach_msg_return_t r;
        !            52: 
        !            53:        /*
        !            54:         *      Allocate our message buffers.
        !            55:         */
        !            56: 
        !            57:        messages = kalloc(2 * max_size);
        !            58:        if (messages == 0)
        !            59:                panic(SERVER_NAME);
        !            60:        in_msg = (mach_msg_header_t *) messages;
        !            61:        out_msg = (mach_msg_header_t *) (messages + max_size);
        !            62: 
        !            63:        /*
        !            64:         *      Service loop... receive messages and process them.
        !            65:         */
        !            66: 
        !            67:        for (;;) {
        !            68:                /* receive first message */
        !            69: 
        !            70:            receive_msg:
        !            71:                r = mach_msg(in_msg, MACH_RCV_MSG, 0, max_size, rcv_set,
        !            72:                             MACH_MSG_TIMEOUT_NONE, MACH_PORT_NULL);
        !            73:                if (r == MACH_MSG_SUCCESS)
        !            74:                        break;
        !            75: 
        !            76:                printf("%s: receive failed, 0x%x.\n", SERVER_NAME, r);
        !            77:        }
        !            78: 
        !            79:        for (;;) {
        !            80:                /* process request message */
        !            81: 
        !            82:                (void) SERVER_DISPATCH(in_msg, out_msg);
        !            83: 
        !            84:                /* send reply and receive next request */
        !            85: 
        !            86:                if (out_msg->msgh_remote_port == MACH_PORT_NULL)
        !            87:                        goto receive_msg;
        !            88: 
        !            89:                r = mach_msg(out_msg, MACH_SEND_MSG|MACH_RCV_MSG,
        !            90:                             out_msg->msgh_size, max_size, rcv_set,
        !            91:                             MACH_MSG_TIMEOUT_NONE, MACH_PORT_NULL);
        !            92:                if (r != MACH_MSG_SUCCESS) {
        !            93:                        printf("%s: send/receive failed, 0x%x.\n",
        !            94:                               SERVER_NAME, r);
        !            95:                        goto receive_msg;
        !            96:                }
        !            97: 
        !            98:                /* swap message buffers */
        !            99: 
        !           100:                tmp_msg = in_msg; in_msg = out_msg; out_msg = tmp_msg;
        !           101:        }
        !           102: }

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