summaryrefslogtreecommitdiff
path: root/mig/server.c
diff options
context:
space:
mode:
authorRoland McGrath <roland@gnu.org>1998-07-19 06:48:50 +0000
committerRoland McGrath <roland@gnu.org>1998-07-19 06:48:50 +0000
commit3f07f7d0137a757f1908805f809ddcba8ba4c21e (patch)
tree5a99942a2b6bdfb8e81cffff059a7d16f3553e24 /mig/server.c
parent1ffb1ca21b8db814cdbd8638b6c3b1ddece5aec1 (diff)
* mig: Subdirectory removed, now in separate dist.
Diffstat (limited to 'mig/server.c')
-rw-r--r--mig/server.c1322
1 files changed, 0 insertions, 1322 deletions
diff --git a/mig/server.c b/mig/server.c
deleted file mode 100644
index 07e4964..0000000
--- a/mig/server.c
+++ /dev/null
@@ -1,1322 +0,0 @@
-/*
- * Mach Operating System
- * Copyright (c) 1991,1990 Carnegie Mellon University
- * All Rights Reserved.
- *
- * Permission to use, copy, modify and distribute this software and its
- * documentation is hereby granted, provided that both the copyright
- * notice and this permission notice appear in all copies of the
- * software, derivative works or modified versions, and any portions
- * thereof, and that both notices appear in supporting documentation.
- *
- * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
- * CONDITION. CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND FOR
- * ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
- *
- * Carnegie Mellon requests users of this software to return to
- *
- * Software Distribution Coordinator or Software.Distribution@CS.CMU.EDU
- * School of Computer Science
- * Carnegie Mellon University
- * Pittsburgh PA 15213-3890
- *
- * any improvements or extensions that they make and grant Carnegie Mellon
- * the rights to redistribute these changes.
- */
-
-#include <assert.h>
-
-#include "write.h"
-#include "utils.h"
-#include "global.h"
-#include "error.h"
-#include "cpu.h"
-
-static void
-WriteIncludes(FILE *file)
-{
- fprintf(file, "#define EXPORT_BOOLEAN\n");
- fprintf(file, "#include <mach/boolean.h>\n");
- fprintf(file, "#include <mach/kern_return.h>\n");
- fprintf(file, "#include <mach/message.h>\n");
- fprintf(file, "#include <mach/mig_errors.h>\n");
- fprintf(file, "#include <mach/mig_support.h>\n");
- if (IsKernelServer)
- fprintf(file, "#include <ipc/ipc_port.h>\n");
- fprintf(file, "\n");
-}
-
-static void
-WriteGlobalDecls(FILE *file)
-{
- if (RCSId != strNULL)
- WriteRCSDecl(file, strconcat(SubsystemName, "_server"), RCSId);
-
- /* Used for locations in the request message, *not* reply message.
- Reply message locations aren't dependent on IsKernelServer. */
-
- if (IsKernelServer)
- {
- fprintf(file, "#define msgh_request_port\tmsgh_remote_port\n");
- fprintf(file, "#define MACH_MSGH_BITS_REQUEST(bits)");
- fprintf(file, "\tMACH_MSGH_BITS_REMOTE(bits)\n");
- fprintf(file, "#define msgh_reply_port\t\tmsgh_local_port\n");
- fprintf(file, "#define MACH_MSGH_BITS_REPLY(bits)");
- fprintf(file, "\tMACH_MSGH_BITS_LOCAL(bits)\n");
- }
- else
- {
- fprintf(file, "#define msgh_request_port\tmsgh_local_port\n");
- fprintf(file, "#define MACH_MSGH_BITS_REQUEST(bits)");
- fprintf(file, "\tMACH_MSGH_BITS_LOCAL(bits)\n");
- fprintf(file, "#define msgh_reply_port\t\tmsgh_remote_port\n");
- fprintf(file, "#define MACH_MSGH_BITS_REPLY(bits)");
- fprintf(file, "\tMACH_MSGH_BITS_REMOTE(bits)\n");
- }
- fprintf(file, "\n");
-}
-
-static void
-WriteProlog(FILE *file)
-{
- fprintf(file, "/* Module %s */\n", SubsystemName);
- fprintf(file, "\n");
-
- WriteIncludes(file);
- WriteBogusDefines(file);
- WriteGlobalDecls(file);
-}
-
-
-static void
-WriteSymTabEntries(FILE *file, const statement_t *stats)
-{
- register const statement_t *stat;
- register u_int current = 0;
-
- for (stat = stats; stat != stNULL; stat = stat->stNext)
- if (stat->stKind == skRoutine) {
- register num = stat->stRoutine->rtNumber;
- const char *name = stat->stRoutine->rtName;
-
- while (++current <= num)
- fprintf(file,"\t\t\t{ \"\", 0, 0 },\n");
- fprintf(file, "\t{ \"%s\", %d, _X%s },\n",
- name,
- SubsystemBase + current - 1,
- name);
- }
- while (++current <= rtNumber)
- fprintf(file,"\t{ \"\", 0, 0 },\n");
-}
-
-static void
-WriteArrayEntries(FILE *file, const statement_t *stats)
-{
- register u_int current = 0;
- register const statement_t *stat;
-
- for (stat = stats; stat != stNULL; stat = stat->stNext)
- if (stat->stKind == skRoutine)
- {
- register const routine_t *rt = stat->stRoutine;
-
- while (current++ < rt->rtNumber)
- fprintf(file, "\t\t0,\n");
- fprintf(file, "\t\t_X%s,\n", rt->rtName);
- }
- while (current++ < rtNumber)
- fprintf(file, "\t\t\t0,\n");
-}
-
-static void
-WriteEpilog(FILE *file, const statement_t *stats)
-{
- fprintf(file, "\n");
-
- /*
- * First, the symbol table
- */
- fprintf(file, "static mig_routine_t %s_routines[] = {\n", ServerDemux);
-
- WriteArrayEntries(file, stats);
-
- fprintf(file, "};\n");
- fprintf(file, "\n");
-
- /*
- * Then, the server routine
- */
- fprintf(file, "mig_external boolean_t %s\n", ServerDemux);
- fprintf(file, "\t(mach_msg_header_t *InHeadP, mach_msg_header_t *OutHeadP)\n");
-
- fprintf(file, "{\n");
- fprintf(file, "\tregister mach_msg_header_t *InP = InHeadP;\n");
-
- fprintf(file, "\tregister mig_reply_header_t *OutP = (mig_reply_header_t *) OutHeadP;\n");
-
- fprintf(file, "\n");
-
- WriteStaticDecl(file, itRetCodeType,
- itRetCodeType->itDeallocate, itRetCodeType->itLongForm,
- !IsKernelServer, "RetCodeType");
- fprintf(file, "\n");
-
- fprintf(file, "\tregister mig_routine_t routine;\n");
- fprintf(file, "\n");
-
- fprintf(file, "\tOutP->Head.msgh_bits = ");
- fprintf(file, "MACH_MSGH_BITS(MACH_MSGH_BITS_REPLY(InP->msgh_bits), 0);\n");
- fprintf(file, "\tOutP->Head.msgh_size = sizeof *OutP;\n");
- fprintf(file, "\tOutP->Head.msgh_remote_port = InP->msgh_reply_port;\n");
- fprintf(file, "\tOutP->Head.msgh_local_port = MACH_PORT_NULL;\n");
- fprintf(file, "\tOutP->Head.msgh_seqno = 0;\n");
- fprintf(file, "\tOutP->Head.msgh_id = InP->msgh_id + 100;\n");
- fprintf(file, "\n");
- WritePackMsgType(file, itRetCodeType,
- itRetCodeType->itDeallocate, itRetCodeType->itLongForm,
- !IsKernelServer, "OutP->RetCodeType", "RetCodeType");
- fprintf(file, "\n");
-
- fprintf(file, "\tif ((InP->msgh_id > %d) || (InP->msgh_id < %d) ||\n",
- SubsystemBase + rtNumber - 1, SubsystemBase);
- fprintf(file, "\t ((routine = %s_routines[InP->msgh_id - %d]) == 0)) {\n",
- ServerDemux, SubsystemBase);
- fprintf(file, "\t\tOutP->RetCode = MIG_BAD_ID;\n");
- fprintf(file, "\t\treturn FALSE;\n");
- fprintf(file, "\t}\n");
-
- /* Call appropriate routine */
- fprintf(file, "\t(*routine) (InP, &OutP->Head);\n");
- fprintf(file, "\treturn TRUE;\n");
- fprintf(file, "}\n");
- fprintf(file, "\n");
-
- /*
- * Then, the <subsystem>_server_routine routine
- */
- fprintf(file, "mig_external mig_routine_t %s_routine\n", ServerDemux);
- fprintf(file, "\t(const mach_msg_header_t *InHeadP)\n");
-
- fprintf(file, "{\n");
- fprintf(file, "\tregister int msgh_id;\n");
- fprintf(file, "\n");
- fprintf(file, "\tmsgh_id = InHeadP->msgh_id - %d;\n", SubsystemBase);
- fprintf(file, "\n");
- fprintf(file, "\tif ((msgh_id > %d) || (msgh_id < 0))\n",
- rtNumber - 1);
- fprintf(file, "\t\treturn 0;\n");
- fprintf(file, "\n");
- fprintf(file, "\treturn %s_routines[msgh_id];\n", ServerDemux);
- fprintf(file, "}\n");
- fprintf(file, "\n");
-
- /* symtab */
-
- if (GenSymTab) {
- fprintf(file,"\nmig_symtab_t _%sSymTab[] = {\n",SubsystemName);
- WriteSymTabEntries(file,stats);
- fprintf(file,"};\n");
- fprintf(file,"int _%sSymTabBase = %d;\n",SubsystemName,SubsystemBase);
- fprintf(file,"int _%sSymTabEnd = %d;\n",SubsystemName,SubsystemBase+rtNumber);
- }
-}
-
-/*
- * Returns the return type of the server-side work function.
- * Suitable for "extern %s serverfunc()".
- */
-static const char *
-ServerSideType(const routine_t *rt)
-{
- if (rt->rtServerReturn == argNULL)
- return "void";
- else
- return rt->rtServerReturn->argType->itTransType;
-}
-
-static void
-WriteLocalVarDecl(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *it = arg->argType;
-
- if (it->itInLine && it->itVarArray)
- {
- register const ipc_type_t *btype = it->itElement;
-
- fprintf(file, "\t%s %s[%d]", btype->itTransType,
- arg->argVarName, it->itNumber/btype->itNumber);
- }
- else
- fprintf(file, "\t%s %s", it->itTransType, arg->argVarName);
-}
-
-static void
-WriteLocalPtrDecl(FILE *file, register const argument_t *arg)
-{
- fprintf(file, "\t%s *%sP",
- FetchServerType(arg->argType->itElement),
- arg->argVarName);
-}
-
-static void
-WriteServerArgDecl(FILE *file, const argument_t *arg)
-{
- fprintf(file, "%s %s%s",
- arg->argType->itTransType,
- arg->argByReferenceServer ? "*" : "",
- arg->argVarName);
-}
-
-/*
- * Writes the local variable declarations which are always
- * present: InP, OutP, the server-side work function.
- */
-static void
-WriteVarDecls(FILE *file, const routine_t *rt)
-{
- int i;
- boolean_t NeedMsghSize = FALSE;
- boolean_t NeedMsghSizeDelta = FALSE;
-
- fprintf(file, "\tregister Request *In0P = (Request *) InHeadP;\n");
- for (i = 1; i <= rt->rtMaxRequestPos; i++)
- fprintf(file, "\tregister Request *In%dP;\n", i);
- fprintf(file, "\tregister Reply *OutP = (Reply *) OutHeadP;\n");
-
- fprintf(file, "\tmig_external %s %s\n",
- ServerSideType(rt), rt->rtServerName);
- fprintf(file, "\t\t(");
- WriteList(file, rt->rtArgs, WriteServerArgDecl, akbServerArg, ", ", "");
- fprintf(file, ");\n");
- fprintf(file, "\n");
-
- if (!rt->rtSimpleFixedReply)
- fprintf(file, "\tboolean_t msgh_simple;\n");
- else if (!rt->rtSimpleCheckRequest)
- {
- fprintf(file, "#if\tTypeCheck\n");
- fprintf(file, "\tboolean_t msgh_simple;\n");
- fprintf(file, "#endif\t/* TypeCheck */\n");
- fprintf(file, "\n");
- }
-
- /* if either request or reply is variable, we may need
- msgh_size_delta and msgh_size */
-
- if (rt->rtNumRequestVar > 0)
- NeedMsghSize = TRUE;
- if (rt->rtMaxRequestPos > 0)
- NeedMsghSizeDelta = TRUE;
-
- if (rt->rtNumReplyVar > 1)
- NeedMsghSize = TRUE;
- if (rt->rtMaxReplyPos > 0)
- NeedMsghSizeDelta = TRUE;
-
- if (NeedMsghSize)
- fprintf(file, "\tunsigned int msgh_size;\n");
- if (NeedMsghSizeDelta)
- fprintf(file, "\tunsigned int msgh_size_delta;\n");
-
- if (NeedMsghSize || NeedMsghSizeDelta)
- fprintf(file, "\n");
-}
-
-static void
-WriteMsgError(FILE *file, const char *error_msg)
-{
- fprintf(file, "\t\t{ OutP->RetCode = %s; return; }\n", error_msg);
-}
-
-static void
-WriteReplyInit(FILE *file, const routine_t *rt)
-{
- boolean_t printed_nl = FALSE;
-
- if (rt->rtSimpleFixedReply)
- {
- if (!rt->rtSimpleSendReply) /* complex reply message */
- {
- printed_nl = TRUE;
- fprintf(file, "\n");
- fprintf(file,
- "\tOutP->Head.msgh_bits |= MACH_MSGH_BITS_COMPLEX;\n");
- }
- }
- else
- {
- printed_nl = TRUE;
- fprintf(file, "\n");
- fprintf(file, "\tmsgh_simple = %s;\n",
- strbool(rt->rtSimpleSendReply));
- }
-
- if (rt->rtNumReplyVar == 0)
- {
- if (!printed_nl)
- fprintf(file, "\n");
- fprintf(file, "\tOutP->Head.msgh_size = %d;\n", rt->rtReplySize);
- }
-}
-
-static void
-WriteReplyHead(FILE *file, const routine_t *rt)
-{
- if ((!rt->rtSimpleFixedReply) ||
- (rt->rtNumReplyVar > 1))
- {
- fprintf(file, "\n");
- if (rt->rtMaxReplyPos > 0)
- fprintf(file, "\tOutP = (Reply *) OutHeadP;\n");
- }
-
- if (!rt->rtSimpleFixedReply)
- {
- fprintf(file, "\tif (!msgh_simple)\n");
- fprintf(file,
- "\t\tOutP->Head.msgh_bits |= MACH_MSGH_BITS_COMPLEX;\n");
- }
- if (rt->rtNumReplyVar > 1)
- fprintf(file, "\tOutP->Head.msgh_size = msgh_size;\n");
-}
-
-static void
-WriteCheckHead(FILE *file, const routine_t *rt)
-{
- fprintf(file, "#if\tTypeCheck\n");
- if (rt->rtNumRequestVar > 0)
- fprintf(file, "\tmsgh_size = In0P->Head.msgh_size;\n");
- if (!rt->rtSimpleCheckRequest)
- fprintf(file, "\tmsgh_simple = !(In0P->Head.msgh_bits & MACH_MSGH_BITS_COMPLEX);\n");
-
- if (rt->rtNumRequestVar > 0)
- fprintf(file, "\tif ((msgh_size < %d)",
- rt->rtRequestSize);
- else
- fprintf(file, "\tif ((In0P->Head.msgh_size != %d)",
- rt->rtRequestSize);
-
- if (rt->rtSimpleCheckRequest)
- fprintf(file, " ||\n\t %s(In0P->Head.msgh_bits & MACH_MSGH_BITS_COMPLEX)",
- rt->rtSimpleReceiveRequest ? "" : "!");
- fprintf(file, ")\n");
- WriteMsgError(file, "MIG_BAD_ARGUMENTS");
- fprintf(file, "#endif\t/* TypeCheck */\n");
- fprintf(file, "\n");
-}
-
-static void
-WriteTypeCheck(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *it = arg->argType;
- register const routine_t *rt = arg->argRoutine;
-
- fprintf(file, "#if\tTypeCheck\n");
- if (akCheck(arg->argKind, akbRequestQC))
- fprintf(file, "\tif (* (int *) &In%dP->%s != * (int *) &%sCheck)\n",
- arg->argRequestPos, arg->argTTName, arg->argVarName);
- else
- {
- fprintf(file, "\tif (");
- if (!it->itIndefinite) {
- fprintf(file, "(In%dP->%s%s.msgt_inline != %s) ||\n\t ",
- arg->argRequestPos, arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "",
- strbool(it->itInLine));
- }
- fprintf(file, "(In%dP->%s%s.msgt_longform != %s) ||\n",
- arg->argRequestPos, arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "",
- strbool(arg->argLongForm));
- if (it->itOutName == MACH_MSG_TYPE_POLYMORPHIC)
- {
- if (!rt->rtSimpleCheckRequest)
- fprintf(file, "\t (MACH_MSG_TYPE_PORT_ANY(In%dP->%s.msgt%s_name) && msgh_simple) ||\n",
- arg->argRequestPos, arg->argTTName,
- arg->argLongForm ? "l" : "");
- }
- else
- fprintf(file, "\t (In%dP->%s.msgt%s_name != %s) ||\n",
- arg->argRequestPos, arg->argTTName,
- arg->argLongForm ? "l" : "",
- it->itOutNameStr);
- if (!it->itVarArray)
- fprintf(file, "\t (In%dP->%s.msgt%s_number != %d) ||\n",
- arg->argRequestPos, arg->argTTName,
- arg->argLongForm ? "l" : "",
- it->itNumber);
- fprintf(file, "\t (In%dP->%s.msgt%s_size != %d))\n",
- arg->argRequestPos, arg->argTTName,
- arg->argLongForm ? "l" : "",
- it->itSize);
- }
- WriteMsgError(file, "MIG_BAD_ARGUMENTS");
- fprintf(file, "#endif\t/* TypeCheck */\n");
- fprintf(file, "\n");
-}
-
-static void
-WriteCheckArgSize(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *ptype = arg->argType;
- register const ipc_type_t *btype = ptype->itElement;
- const argument_t *count = arg->argCount;
- int multiplier = btype->itTypeSize / btype->itNumber;
-
- if (ptype->itIndefinite) {
- /*
- * Check descriptor. If out-of-line, use standard size.
- */
- fprintf(file, "(In%dP->%s%s.msgt_inline) ? ",
- arg->argRequestPos,
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- }
-
- if (btype->itTypeSize % 4 != 0)
- fprintf(file, "(");
-
- if (multiplier > 1)
- fprintf(file, "%d * ", multiplier);
-
- fprintf(file, "In%dP->%s", arg->argRequestPos, count->argMsgField);
-
- /* If the base type size of the data field isn`t a multiple of 4,
- we have to round up. */
- if (btype->itTypeSize % 4 != 0)
- fprintf(file, " + 3) & ~3");
-
- if (ptype->itIndefinite) {
- fprintf(file, " : sizeof(%s *)", FetchServerType(btype));
- }
-}
-
-static void
-WriteCheckMsgSize(FILE *file, register const argument_t *arg)
-{
- register const routine_t *rt = arg->argRoutine;
-
- /* If there aren't any more In args after this, then
- we can use the msgh_size_delta value directly in
- the TypeCheck conditional. */
-
- if (arg->argRequestPos == rt->rtMaxRequestPos)
- {
- fprintf(file, "#if\tTypeCheck\n");
- fprintf(file, "\tif (msgh_size != %d + (", rt->rtRequestSize);
- WriteCheckArgSize(file, arg);
- fprintf(file, "))\n");
-
- WriteMsgError(file, "MIG_BAD_ARGUMENTS");
- fprintf(file, "#endif\t/* TypeCheck */\n");
- }
- else
- {
- /* If there aren't any more variable-sized arguments after this,
- then we must check for exact msg-size and we don't need to
- update msgh_size. */
-
- boolean_t LastVarArg = arg->argRequestPos+1 == rt->rtNumRequestVar;
-
- /* calculate the actual size in bytes of the data field. note
- that this quantity must be a multiple of four. hence, if
- the base type size isn't a multiple of four, we have to
- round up. note also that btype->itNumber must
- divide btype->itTypeSize (see itCalculateSizeInfo). */
-
- fprintf(file, "\tmsgh_size_delta = ");
- WriteCheckArgSize(file, arg);
- fprintf(file, ";\n");
- fprintf(file, "#if\tTypeCheck\n");
-
- /* Don't decrement msgh_size until we've checked that
- it won't underflow. */
-
- if (LastVarArg)
- fprintf(file, "\tif (msgh_size != %d + msgh_size_delta)\n",
- rt->rtRequestSize);
- else
- fprintf(file, "\tif (msgh_size < %d + msgh_size_delta)\n",
- rt->rtRequestSize);
- WriteMsgError(file, "MIG_BAD_ARGUMENTS");
-
- if (!LastVarArg)
- fprintf(file, "\tmsgh_size -= msgh_size_delta;\n");
-
- fprintf(file, "#endif\t/* TypeCheck */\n");
- }
- fprintf(file, "\n");
-}
-
-static const char *
-InArgMsgField(register const argument_t *arg)
-{
- static char buffer[100];
-
- /*
- * Inside the kernel, the request and reply port fields
- * really hold ipc_port_t values, not mach_port_t values.
- * Hence we must cast the values.
- */
-
- if (IsKernelServer &&
- ((akIdent(arg->argKind) == akeRequestPort) ||
- (akIdent(arg->argKind) == akeReplyPort)))
- sprintf(buffer, "(ipc_port_t) In%dP->%s",
- arg->argRequestPos, arg->argMsgField);
- else
- sprintf(buffer, "In%dP->%s",
- arg->argRequestPos, arg->argMsgField);
-
- return buffer;
-}
-
-static void
-WriteExtractArgValue(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *it = arg->argType;
-
- if (arg->argMultiplier > 1)
- WriteCopyType(file, it, "%s", "/* %s */ %s / %d",
- arg->argVarName, InArgMsgField(arg), arg->argMultiplier);
- else if (it->itInTrans != strNULL)
- WriteCopyType(file, it, "%s", "/* %s */ %s(%s)",
- arg->argVarName, it->itInTrans, InArgMsgField(arg));
- else
- WriteCopyType(file, it, "%s", "/* %s */ %s",
- arg->argVarName, InArgMsgField(arg));
- fprintf(file, "\n");
-}
-
-static void
-WriteInitializeCount(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *ptype = arg->argParent->argType;
- register const ipc_type_t *btype = ptype->itElement;
-
- /*
- * Initialize 'count' argument for variable-length inline OUT parameter
- * with maximum allowed number of elements.
- */
-
- fprintf(file, "\t%s = %d;\n", arg->argVarName,
- ptype->itNumber/btype->itNumber);
-
- /*
- * If the user passed in a count, then we use the minimum.
- * We can't let the user completely override our maximum,
- * or the user might convince the server to overwrite the buffer.
- */
-
- if (arg->argCInOut != argNULL) {
- const char *msgfield = InArgMsgField(arg->argCInOut);
-
- fprintf(file, "\tif (%s < %s)\n", msgfield, arg->argVarName);
- fprintf(file, "\t\t%s = %s;\n", arg->argVarName, msgfield);
- }
-
- fprintf(file, "\n");
-}
-
-static void
-WriteInitializePtr(FILE *file, register const argument_t *arg)
-{
- if (akCheck(arg->argKind, akbVarNeeded))
- fprintf(file, "\t%sP = %s;\n",
- arg->argVarName, arg->argVarName);
- else
- fprintf(file, "\t%sP = OutP->%s;\n",
- arg->argVarName, arg->argMsgField);
-}
-
-static void
-WriteTypeCheckArg(FILE *file, register const argument_t *arg)
-{
- if (akCheck(arg->argKind, akbRequest)) {
- WriteTypeCheck(file, arg);
-
- if (akCheck(arg->argKind, akbVariable))
- WriteCheckMsgSize(file, arg);
- }
-}
-
-static void
-WriteAdjustRequestMsgPtr(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *ptype = arg->argType;
-
- fprintf(file,
- "\tIn%dP = (Request *) ((char *) In%dP + msgh_size_delta - %d);\n\n",
- arg->argRequestPos+1, arg->argRequestPos,
- ptype->itTypeSize + ptype->itPadSize);
-}
-
-static void
-WriteTypeCheckRequestArgs(FILE *file, register const routine_t *rt)
-{
- register const argument_t *arg;
- register const argument_t *lastVarArg;
-
- lastVarArg = argNULL;
- for (arg = rt->rtArgs; arg != argNULL; arg = arg->argNext) {
-
- /*
- * Advance message pointer if the last request argument was
- * variable-length and the request position will change.
- */
- if (lastVarArg != argNULL &&
- lastVarArg->argRequestPos < arg->argRequestPos)
- {
- WriteAdjustRequestMsgPtr(file, lastVarArg);
- lastVarArg = argNULL;
- }
-
- /*
- * Type-check the argument.
- */
- WriteTypeCheckArg(file, arg);
-
- /*
- * Remember whether this was variable-length.
- */
- if (akCheckAll(arg->argKind, akbVariable|akbRequest))
- lastVarArg = arg;
- }
-}
-
-static void
-WriteExtractArg(FILE *file, register const argument_t *arg)
-{
- if (akCheckAll(arg->argKind, akbSendRcv|akbVarNeeded))
- WriteExtractArgValue(file, arg);
-
- if ((akIdent(arg->argKind) == akeCount) &&
- akCheck(arg->argKind, akbReturnSnd))
- {
- register ipc_type_t *ptype = arg->argParent->argType;
-
- if (ptype->itInLine && ptype->itVarArray)
- WriteInitializeCount(file, arg);
- }
-
- if (akCheckAll(arg->argKind, akbReturnSnd|akbPointer))
- WriteInitializePtr(file, arg);
-}
-
-static void
-WriteServerCallArg(FILE *file, register const argument_t *arg)
-{
- const ipc_type_t *it = arg->argType;
- boolean_t NeedClose = FALSE;
-
- if (arg->argByReferenceServer)
- fprintf(file, "&");
-
- if ((it->itInTrans != strNULL) &&
- akCheck(arg->argKind, akbSendRcv) &&
- !akCheck(arg->argKind, akbVarNeeded))
- {
- fprintf(file, "%s(", it->itInTrans);
- NeedClose = TRUE;
- }
-
- if (akCheck(arg->argKind, akbPointer))
- fprintf(file, "%sP", arg->argVarName);
- else if (akCheck(arg->argKind, akbVarNeeded))
- fprintf(file, "%s", arg->argVarName);
- else if (akCheck(arg->argKind, akbSendRcv)) {
- if (akCheck(arg->argKind, akbIndefinite)) {
- fprintf(file, "(In%dP->%s%s.msgt_inline) ",
- arg->argRequestPos,
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- fprintf(file, "? %s ", InArgMsgField(arg));
- fprintf(file, ": *((%s **)%s)",
- FetchServerType(arg->argType->itElement),
- InArgMsgField(arg));
- }
- else
- fprintf(file, "%s", InArgMsgField(arg));
- }
- else
- fprintf(file, "OutP->%s", arg->argMsgField);
-
- if (NeedClose)
- fprintf(file, ")");
-
- if (!arg->argByReferenceServer && (arg->argMultiplier > 1))
- fprintf(file, " / %d", arg->argMultiplier);
-}
-
-static void
-WriteDestroyArg(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *it = arg->argType;
-
- if (akCheck(arg->argKind, akbIndefinite)) {
- /*
- * Deallocate only if out-of-line.
- */
- argument_t *count = arg->argCount;
- ipc_type_t *btype = it->itElement;
- int multiplier = btype->itTypeSize / btype->itNumber;
-
- fprintf(file, "\tif (!In%dP->%s%s.msgt_inline)\n",
- arg->argRequestPos,
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- fprintf(file, "\t\t%smig_deallocate(* (vm_offset_t *) %s, ",
- SubrPrefix, InArgMsgField(arg));
- if (multiplier > 1)
- fprintf(file, "%d * ", multiplier);
- fprintf(file, " %s);\n", InArgMsgField(count));
- } else {
- if (akCheck(arg->argKind, akbVarNeeded))
- fprintf(file, "\t%s(%s);\n", it->itDestructor, arg->argVarName);
- else
- fprintf(file, "\t%s(%s);\n", it->itDestructor,
- InArgMsgField(arg));
- }
-}
-
-static void
-WriteDestroyPortArg(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *it = arg->argType;
-
- /*
- * If a translated port argument occurs in the body of a request
- * message, and the message is successfully processed, then the
- * port right should be deallocated. However, the called function
- * didn't see the port right; it saw the translation. So we have
- * to release the port right for it.
- */
-
- if ((it->itInTrans != strNULL) &&
- (it->itOutName == MACH_MSG_TYPE_PORT_SEND))
- {
- fprintf(file, "\n");
- fprintf(file, "\tif (IP_VALID(%s))\n", InArgMsgField(arg));
- fprintf(file, "\t\t%sipc_port_release_send(%s);\n",
- SubrPrefix, InArgMsgField(arg));
- }
-}
-
-/*
- * Check whether WriteDestroyPortArg would generate any code for arg.
- */
-static boolean_t
-CheckDestroyPortArg(register const argument_t *arg)
-{
- register const ipc_type_t *it = arg->argType;
-
- if ((it->itInTrans != strNULL) &&
- (it->itOutName == MACH_MSG_TYPE_PORT_SEND))
- {
- return TRUE;
- }
- return FALSE;
-}
-
-static void
-WriteServerCall(FILE *file, const routine_t *rt)
-{
- boolean_t NeedClose = FALSE;
-
- fprintf(file, "\t");
- if (rt->rtServerReturn != argNULL)
- {
- const argument_t *arg = rt->rtServerReturn;
- const ipc_type_t *it = arg->argType;
-
- fprintf(file, "OutP->%s = ", arg->argMsgField);
- if (it->itOutTrans != strNULL)
- {
- fprintf(file, "%s(", it->itOutTrans);
- NeedClose = TRUE;
- }
- }
- fprintf(file, "%s(", rt->rtServerName);
- WriteList(file, rt->rtArgs, WriteServerCallArg, akbServerArg, ", ", "");
- if (NeedClose)
- fprintf(file, ")");
- fprintf(file, ");\n");
-}
-
-static void
-WriteGetReturnValue(FILE *file, register const routine_t *rt)
-{
- if (rt->rtServerReturn != rt->rtRetCode)
- fprintf(file, "\tOutP->%s = KERN_SUCCESS;\n",
- rt->rtRetCode->argMsgField);
-}
-
-static void
-WriteCheckReturnValue(FILE *file, register const routine_t *rt)
-{
- if (rt->rtServerReturn == rt->rtRetCode)
- {
- fprintf(file, "\tif (OutP->%s != KERN_SUCCESS)\n",
- rt->rtRetCode->argMsgField);
- fprintf(file, "\t\treturn;\n");
- }
-}
-
-static void
-WritePackArgType(FILE *file, register const argument_t *arg)
-{
- fprintf(file, "\n");
-
- WritePackMsgType(file, arg->argType,
- arg->argType->itIndefinite ? d_NO : arg->argDeallocate,
- arg->argLongForm, !IsKernelServer,
- "OutP->%s", "%s", arg->argTTName);
-}
-
-static void
-WritePackArgValue(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *it = arg->argType;
-
- fprintf(file, "\n");
-
- if (it->itInLine && it->itVarArray) {
-
- if (it->itString) {
- /*
- * Copy variable-size C string with mig_strncpy.
- * Save the string length (+ 1 for trailing 0)
- * in the argument`s count field.
- */
- fprintf(file,
- "\tOutP->%s = %smig_strncpy(OutP->%s, %s, %d);\n",
- arg->argCount->argMsgField,
- SubrPrefix,
- arg->argMsgField,
- arg->argVarName,
- it->itNumber);
- }
- else {
- register argument_t *count = arg->argCount;
- register ipc_type_t *btype = it->itElement;
-
- /* Note btype->itNumber == count->argMultiplier */
-
- if (it->itIndefinite) {
- /*
- * If we are packing argument, it must be from
- * a local variable.
- */
- fprintf(file, "\tif (%sP != %s) {\n",
- arg->argVarName,
- arg->argVarName);
- fprintf(file, "\t\tOutP->%s%s.msgt_inline = FALSE;\n",
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- if (arg->argDeallocate == d_YES)
- fprintf(file, "\t\tOutP->%s%s.msgt_deallocate = TRUE;\n",
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- else if (arg->argDeallocate == d_MAYBE)
- fprintf(file, "\t\tOutP->%s%s.msgt_deallocate = %s;\n",
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "",
- arg->argDealloc->argVarName);
- fprintf(file, "\t\t*((%s **)OutP->%s) = %sP;\n",
- FetchServerType(btype),
- arg->argMsgField,
- arg->argVarName);
- if (!arg->argRoutine->rtSimpleFixedReply)
- fprintf(file, "\t\tmsgh_simple = FALSE;\n");
- fprintf(file, "\t}\n\telse {\n\t");
- }
- fprintf(file, "\tmemcpy(OutP->%s, %s, ",
- arg->argMsgField, arg->argVarName);
- if (btype->itTypeSize > 1)
- fprintf(file, "%d * ",
- btype->itTypeSize);
- fprintf(file, "%s);\n",
- count->argVarName);
- if (it->itIndefinite)
- fprintf(file, "\t}\n");
- }
- }
- else if (arg->argMultiplier > 1)
- WriteCopyType(file, it, "OutP->%s", "/* %s */ %d * %s",
- arg->argMsgField,
- arg->argMultiplier,
- arg->argVarName);
- else if (it->itOutTrans != strNULL)
- WriteCopyType(file, it, "OutP->%s", "/* %s */ %s(%s)",
- arg->argMsgField, it->itOutTrans, arg->argVarName);
- else
- WriteCopyType(file, it, "OutP->%s", "/* %s */ %s",
- arg->argMsgField, arg->argVarName);
-}
-
-static void
-WriteCopyArgValue(FILE *file, register const argument_t *arg)
-{
- fprintf(file, "\n");
- WriteCopyType(file, arg->argType, "/* %d */ OutP->%s", "In%dP->%s",
- arg->argRequestPos, arg->argMsgField);
-}
-
-static void
-WriteAdjustMsgSimple(FILE *file, register const argument_t *arg)
-{
- /* akbVarNeeded must be on */
-
- if (!arg->argRoutine->rtSimpleFixedReply)
- {
- fprintf(file, "\n");
- fprintf(file, "\tif (MACH_MSG_TYPE_PORT_ANY(%s))\n", arg->argVarName);
- fprintf(file, "\t\tmsgh_simple = FALSE;\n");
- }
-}
-
-static void
-WriteAdjustMsgCircular(FILE *file, register const argument_t *arg)
-{
- fprintf(file, "\n");
-
- if (arg->argType->itOutName == MACH_MSG_TYPE_POLYMORPHIC)
- fprintf(file, "\tif (%s == MACH_MSG_TYPE_PORT_RECEIVE)\n",
- arg->argPoly->argVarName);
-
- /*
- * The carried port right can be accessed in OutP->XXXX. Normally
- * the server function stuffs it directly there. If it is InOut,
- * then it has already been copied into the reply message.
- * If the server function deposited it into a variable (perhaps
- * because the reply message is variable-sized) then it has already
- * been copied into the reply message. Note we must use InHeadP
- * (or In0P->Head) and OutHeadP to access the message headers,
- * because of the variable-sized messages.
- */
-
- fprintf(file, "\tif (IP_VALID((ipc_port_t) InHeadP->msgh_reply_port) &&\n");
- fprintf(file, "\t IP_VALID((ipc_port_t) OutP->%s) &&\n", arg->argMsgField);
- fprintf(file, "\t %sipc_port_check_circularity((ipc_port_t) OutP->%s, (ipc_port_t) InHeadP->msgh_reply_port))\n",
- SubrPrefix, arg->argMsgField);
- fprintf(file, "\t\tOutHeadP->msgh_bits |= MACH_MSGH_BITS_CIRCULAR;\n");
-}
-
-/*
- * Calculate the size of a variable-length message field.
- */
-static void
-WriteArgSize(FILE *file, register const argument_t *arg)
-{
- register const ipc_type_t *ptype = arg->argType;
- register int bsize = ptype->itElement->itTypeSize;
- register const argument_t *count = arg->argCount;
-
- if (ptype->itIndefinite) {
- /*
- * Check descriptor. If out-of-line, use standard size.
- */
- fprintf(file, "(OutP->%s%s.msgt_inline) ? ",
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- }
-
- if (bsize % 4 != 0)
- fprintf(file, "(");
-
- if (bsize > 1)
- fprintf(file, "%d * ", bsize);
- if (ptype->itString)
- /* get count from descriptor in message */
- fprintf(file, "OutP->%s", count->argMsgField);
- else
- /* get count from argument */
- fprintf(file, "%s", count->argVarName);
-
- /*
- * If the base type size is not a multiple of sizeof(int) [4],
- * we have to round up.
- */
- if (bsize % 4 != 0)
- fprintf(file, " + 3) & ~3");
-
- if (ptype->itIndefinite) {
- fprintf(file, " : sizeof(%s *)",
- FetchServerType(ptype->itElement));
- }
-}
-
-/*
- * Adjust message size and advance reply pointer.
- * Called after packing a variable-length argument that
- * has more arguments following.
- */
-static void
-WriteAdjustMsgSize(FILE *file, register const argument_t *arg)
-{
- register routine_t *rt = arg->argRoutine;
- register ipc_type_t *ptype = arg->argType;
-
- /* There are more Out arguments. We need to adjust msgh_size
- and advance OutP, so we save the size of the current field
- in msgh_size_delta. */
-
- fprintf(file, "\tmsgh_size_delta = ");
- WriteArgSize(file, arg);
- fprintf(file, ";\n");
-
- if (rt->rtNumReplyVar == 1)
- /* We can still address the message header directly. Fill
- in the size field. */
-
- fprintf(file, "\tOutP->Head.msgh_size = %d + msgh_size_delta;\n",
- rt->rtReplySize);
- else
- if (arg->argReplyPos == 0)
- /* First variable-length argument. The previous msgh_size value
- is the minimum reply size. */
-
- fprintf(file, "\tmsgh_size = %d + msgh_size_delta;\n",
- rt->rtReplySize);
- else
- fprintf(file, "\tmsgh_size += msgh_size_delta;\n");
-
- fprintf(file,
- "\tOutP = (Reply *) ((char *) OutP + msgh_size_delta - %d);\n",
- ptype->itTypeSize + ptype->itPadSize);
-}
-
-/*
- * Calculate the size of the message. Called after the
- * last argument has been packed.
- */
-static void
-WriteFinishMsgSize(FILE *file, register const argument_t *arg)
-{
- /* No more Out arguments. If this is the only variable Out
- argument, we can assign to msgh_size directly. */
-
- if (arg->argReplyPos == 0) {
- fprintf(file, "\tOutP->Head.msgh_size = %d + (",
- arg->argRoutine->rtReplySize);
- WriteArgSize(file, arg);
- fprintf(file, ");\n");
- }
- else {
- fprintf(file, "\tmsgh_size += ");
- WriteArgSize(file, arg);
- fprintf(file, ";\n");
- }
-}
-
-static void
-WritePackArg(FILE *file, register const argument_t *arg)
-{
- if (akCheck(arg->argKind, akbReplyInit))
- WritePackArgType(file, arg);
-
- if ((akIdent(arg->argKind) == akePoly) &&
- akCheck(arg->argKind, akbReturnSnd))
- WriteAdjustMsgSimple(file, arg);
-
- if (akCheckAll(arg->argKind, akbReturnSnd|akbVarNeeded))
- WritePackArgValue(file, arg);
- else if (akCheckAll(arg->argKind, akbReturnSnd|akbVariable)) {
- register const ipc_type_t *it = arg->argType;
-
- if (it->itString) {
- /* Need to call strlen to calculate the size of the argument. */
- fprintf(file, "\tOutP->%s = strlen(OutP->%s) + 1;\n",
- arg->argCount->argMsgField, arg->argMsgField);
- } else if (it->itIndefinite) {
- /*
- * We know that array is in reply message.
- */
- fprintf(file, "\tif (%sP != OutP->%s) {\n",
- arg->argVarName,
- arg->argMsgField);
- fprintf(file, "\t\tOutP->%s%s.msgt_inline = FALSE;\n",
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- if (arg->argDeallocate == d_YES)
- fprintf(file, "\t\tOutP->%s%s.msgt_deallocate = TRUE;\n",
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "");
- else if (arg->argDeallocate == d_MAYBE)
- fprintf(file, "\t\tOutP->%s%s.msgt_deallocate = %s;\n",
- arg->argTTName,
- arg->argLongForm ? ".msgtl_header" : "",
- arg->argDealloc->argVarName);
- fprintf(file, "\t\t*((%s **)OutP->%s) = %sP;\n",
- FetchServerType(it->itElement),
- arg->argMsgField,
- arg->argVarName);
- if (!arg->argRoutine->rtSimpleFixedReply)
- fprintf(file, "\t\tmsgh_simple = FALSE;\n");
- fprintf(file, "\t}\n");
- }
- }
-
- if (akCheck(arg->argKind, akbReplyCopy))
- WriteCopyArgValue(file, arg);
-
- /*
- * If this is a KernelServer, and the reply message contains
- * a receive right, we must check for the possibility of a
- * port/message circularity. If queueing the reply message
- * would cause a circularity, we mark the reply message
- * with the circular bit.
- */
-
- if (IsKernelServer &&
- akCheck(arg->argKind, akbReturnSnd) &&
- ((arg->argType->itOutName == MACH_MSG_TYPE_PORT_RECEIVE) ||
- (arg->argType->itOutName == MACH_MSG_TYPE_POLYMORPHIC)))
- WriteAdjustMsgCircular(file, arg);
-}
-
-/*
- * Handle reply arguments - fill in message types and copy arguments
- * that need to be copied.
- */
-static void
-WritePackReplyArgs(FILE *file, register const routine_t *rt)
-{
- register const argument_t *arg;
- register const argument_t *lastVarArg;
-
- lastVarArg = argNULL;
- for (arg = rt->rtArgs; arg != argNULL; arg = arg->argNext) {
-
- /*
- * Adjust message size and advance message pointer if
- * the last reply argument was variable-length and the
- * request position will change.
- */
- if (lastVarArg != argNULL &&
- lastVarArg->argReplyPos < arg->argReplyPos)
- {
- WriteAdjustMsgSize(file, lastVarArg);
- lastVarArg = argNULL;
- }
-
- /*
- * Copy the argument
- */
- WritePackArg(file, arg);
-
- /*
- * Remember whether this was variable-length.
- */
- if (akCheckAll(arg->argKind, akbReturnSnd|akbVariable))
- lastVarArg = arg;
- }
-
- /*
- * Finish the message size.
- */
- if (lastVarArg != argNULL)
- WriteFinishMsgSize(file, lastVarArg);
-}
-
-static void
-WriteFieldDecl(FILE *file, const argument_t *arg)
-{
- WriteFieldDeclPrim(file, arg, FetchServerType);
-}
-
-static void
-WriteRoutine(FILE *file, register const routine_t *rt)
-{
- fprintf(file, "\n");
-
- fprintf(file, "/* %s %s */\n", rtRoutineKindToStr(rt->rtKind), rt->rtName);
- fprintf(file, "mig_internal void _X%s\n", rt->rtName);
- fprintf(file, "\t(mach_msg_header_t *InHeadP, mach_msg_header_t *OutHeadP)\n");
-
- fprintf(file, "{\n");
- WriteStructDecl(file, rt->rtArgs, WriteFieldDecl, akbRequest, "Request");
- WriteStructDecl(file, rt->rtArgs, WriteFieldDecl, akbReply, "Reply");
-
- WriteVarDecls(file, rt);
-
- WriteList(file, rt->rtArgs, WriteCheckDecl, akbRequestQC, "\n", "\n");
- WriteList(file, rt->rtArgs,
- IsKernelServer ? WriteTypeDeclOut : WriteTypeDeclIn,
- akbReplyInit, "\n", "\n");
-
- WriteList(file, rt->rtArgs, WriteLocalVarDecl,
- akbVarNeeded, ";\n", ";\n\n");
- WriteList(file, rt->rtArgs, WriteLocalPtrDecl,
- akbPointer, ";\n", ";\n\n");
-
- WriteCheckHead(file, rt);
-
- WriteTypeCheckRequestArgs(file, rt);
- WriteList(file, rt->rtArgs, WriteExtractArg, akbNone, "", "");
-
- WriteServerCall(file, rt);
- WriteGetReturnValue(file, rt);
-
- WriteReverseList(file, rt->rtArgs, WriteDestroyArg, akbDestroy, "", "");
-
- /*
- * For one-way routines, it doesn`t make sense to check the return
- * code, because we return immediately afterwards. However,
- * kernel servers may want to deallocate port arguments - and the
- * deallocation must not be done if the return code is not KERN_SUCCESS.
- */
- if (rt->rtOneWay || rt->rtNoReplyArgs)
- {
- if (IsKernelServer)
- {
- if (rtCheckMaskFunction(rt->rtArgs, akbSendBody|akbSendRcv,
- CheckDestroyPortArg))
- {
- WriteCheckReturnValue(file, rt);
- }
- WriteReverseList(file, rt->rtArgs, WriteDestroyPortArg,
- akbSendBody|akbSendRcv, "", "");
- }
- }
- else
- {
- WriteCheckReturnValue(file, rt);
-
- if (IsKernelServer)
- WriteReverseList(file, rt->rtArgs, WriteDestroyPortArg,
- akbSendBody|akbSendRcv, "", "");
-
- WriteReplyInit(file, rt);
- WritePackReplyArgs(file, rt);
- WriteReplyHead(file, rt);
- }
-
- fprintf(file, "}\n");
-}
-
-void
-WriteServer(FILE *file, const statement_t *stats)
-{
- register const statement_t *stat;
-
- WriteProlog(file);
- for (stat = stats; stat != stNULL; stat = stat->stNext)
- switch (stat->stKind)
- {
- case skRoutine:
- WriteRoutine(file, stat->stRoutine);
- break;
- case skImport:
- case skSImport:
- WriteImport(file, stat->stFileName);
- break;
- case skUImport:
- break;
- default:
- fatal("WriteServer(): bad statement_kind_t (%d)",
- (int) stat->stKind);
- }
- WriteEpilog(file, stats);
-}