Initial source

1 files changed, 78 insertions, 0 deletions

diff --git a/ipc/ipc_target.c b/ipc/ipc_target.c
new file mode 100644
index 0000000..b791db2
--- /dev/null
+++ b/ipc/ipc_target.c
@@ -0,0 +1,78 @@
+/*
+ * Copyright (c) 1994 The University of Utah and
+ * the Computer Systems Laboratory (CSL).  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.
+ *
+ * THE UNIVERSITY OF UTAH AND CSL ALLOW FREE USE OF THIS SOFTWARE IN ITS "AS
+ * IS" CONDITION.  THE UNIVERSITY OF UTAH AND CSL DISCLAIM ANY LIABILITY OF
+ * ANY KIND FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
+ *
+ * CSL requests users of this software to return to csl-dist@cs.utah.edu any
+ * improvements that they make and grant CSL redistribution rights.
+ */
+/*
+ *	File:	ipc_target.c
+ *
+ *	Implementation for common part of IPC ports and port sets
+ *	representing a target of messages and migrating RPCs.
+ */
+
+#include "sched_prim.h"
+#include "ipc_target.h"
+
+void
+ipc_target_init(struct ipc_target *ipt, mach_port_t name)
+{
+	ipt->ipt_name = name;
+	ipc_mqueue_init(&ipt->ipt_messages);
+
+#ifdef MIGRATING_THREADS
+	ipt->ipt_type = IPT_TYPE_MESSAGE_RPC;
+	ipt->ipt_acts = 0;
+
+	ipc_target_machine_init(ipt);
+#endif
+}
+
+void
+ipc_target_terminate(struct ipc_target *ipt)
+{
+}
+
+#ifdef MIGRATING_THREADS
+struct Act *
+ipc_target_block(struct ipc_target *ipt)
+{
+	struct Act *act;
+
+	ipt_lock(ipt);
+	while ((act = ipt->ipt_acts) == 0) {
+		/* XXX mp unsafe */
+		ipt->ipt_waiting = 1;
+		ipt_unlock(ipt);
+		thread_wait((int)&ipt->ipt_acts, FALSE);
+		ipt_lock(ipt);
+	}
+	ipt->ipt_acts = act->ipt_next;
+	ipt_unlock(ipt);
+
+	return act;
+}
+
+void
+ipc_target_wakeup(struct ipc_target *ipt)
+{
+	ipt_lock(ipt);
+	if (ipt->ipt_waiting) {
+		thread_wakeup((int)&ipt->ipt_acts);
+		ipt->ipt_waiting = 0;
+	}
+	ipt_unlock(ipt);
+}
+#endif /* MIGRATING_THREADS */
+