From 37da2899f40661e3e9631e497da8dc59b971cbd0 Mon Sep 17 00:00:00 2001
From: "Charles.Forsyth" <devnull@localhost>
Date: Fri, 22 Dec 2006 17:07:39 +0000
Subject: 20060303a

---
 appl/collab/lib/messages.m | 42 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 appl/collab/lib/messages.m

(limited to 'appl/collab/lib/messages.m')

diff --git a/appl/collab/lib/messages.m b/appl/collab/lib/messages.m
new file mode 100644
index 00000000..ab1c679a
--- /dev/null
+++ b/appl/collab/lib/messages.m
@@ -0,0 +1,42 @@
+Messages:  module
+{
+	PATH:	con "/dis/collab/lib/messages.dis";
+
+	Msg: adt {
+		from:	cyclic ref User;
+		data:		array of byte;
+		next:		cyclic ref Msg;
+	};
+
+	Msglist: adt {
+		tail:		ref Msg;
+		readers:	list of (ref User, ref Readreq);
+
+		new:		fn(): ref Msglist;
+		flushfid:	fn(nil: self ref Msglist, fid: int);
+		flushtag:	fn(nil: self ref Msglist, tag: int);
+		wait:		fn(nil: self ref Msglist, u: ref User, r: ref Readreq);
+		write:	fn(nil: self ref Msglist, m: ref Msg): list of (ref User, ref Readreq);
+		queue:	fn(nil: self ref Msglist): ref Msg;
+	};
+
+	Readreq: adt {
+		tag:	int;
+		fid:	int;
+		count:	int;
+		offset:	big;
+	};
+
+	User: adt {
+		id:	int;
+		fid:	int;
+		name:	string;
+		queue:	cyclic ref Msg;
+
+		new:	fn(fid: int, name: string): ref User;
+		initqueue:	fn(nil: self ref User, msgs: ref Msglist);
+		read:	fn(nil: self ref User): ref Msg;
+	};
+
+	init:	fn();
+};
-- 
cgit v1.2.3