Monday, November 08, 2010 at 12:05 AM.

---

system.verbs.builtins.realtime.client.getUpdates

on getUpdates (adrserver) {
	<<Changes
		<<8/13/10; 9:38:07 AM by DW
			<<Process the updates in a separate thread so we can more quickly get back to getting updates.
		<<8/12/10; 6:31:05 AM by DW
			<<Add randomstring param to getupdates RPC call.
		<<8/7/10; 4:01:58 AM by DW
			<<New parameter adrserver.
		<<7/30/10; 9:31:19 AM by DW
			<<Move the counter outside the try, so we count loops when there are errors too.
		<<7/21/10; 11:48:03 AM by DW
			<<Maintain adrdata^.client.stats.ctConsecutiveErrors.
		<<7/15/10; 10:09:17 AM by DW
			<<Cribbed from instantOutline.root.
		<<2/3/09; 10:56:03 AM by DW
			<<Use the parameterized roomname, not the fixed one.
		<<1/1/09; 7:08:38 PM by DW
			<<Massive change -- we no longer poll. Instead we use FriendFeed's realtime updates capability. Much more responsive, and less of a resource hog. Total win-win.
		<<7/21/08; 5:58:03 AM by DW
			<<Add stats for tracking how long calls to FF take.
		<<7/19/08; 2:48:41 PM by DW
			<<Don't process updates from "davewiner" and "bullmancuso" -- these are just temporary limits, until we safe-up everything for users who don't exist anymore (they became dave and bull).
		<<7/19/08; 1:37:15 PM by DW
			<<When processing updates, just set the dirty bits on the users, read the outlines after the loop. This way if someone updates twice we only read once.
		<<7/16/08; 8:07:40 PM by DW
			<<Created.
	local (adrdata = realtime.init (), fldebug = true, adrdebugtable, username, password, server, randomstring);
	adrserver^.idthread = thread.getcurrentid ();
	adrserver^.stats.whenThreadStarted = clock.now ();
	adrserver^.stats.ctThreadStarts++;
	username = adrserver^.username;
	password = string (adrserver^.password);
	server = string (adrserver^.server);
	randomstring = adrdata^.client.prefs.randomString;
	<<bundle //set up debug table
		<<if fldebug
			<<adrdebugtable = @adrserver^.updates //primarily for debugging
			<<if not defined (adrdebugtable^)
				<<new (tabletype, adrdebugtable)
	loop {
		try {
			local (updates = [server].realtime.getupdates (username, password, randomstring), adrupdate);
			thread.callscript (@realtime.client.processIncomingUpdates, {adrserver, updates});
			<<for adrupdate in @updates
				<<bundle //call the callbacks
					<<local (adrscript)
					<<for adrscript in @adrserver^.callbacks
						<<while typeof (adrscript^) == addresstype
							<<adrscript = adrscript^
						<<try {adrscript^ (adrupdate)}
					<<adrserver^.stats.ctUpdates++
				<<if fldebug
					<<adrdebugtable^.[nameof (adrupdate^)] = adrupdate^
			adrserver^.stats.ctConsecutiveErrors = 0}
		else {
			if not (string.lower (tryerror) contains "timed out") {
				adrserver^.stats.lastError = tryerror;
				adrserver^.stats.ctConsecutiveErrors++;
				adrserver^.stats.whenLastError = clock.now ();
				adrserver^.stats.ctErrors++;
				thread.sleepfor (adrdata^.server.prefs.ctSecsDelayOnError)}}; //8/8/10 by DW
		adrserver^.stats.ctLoops++;
		adrserver^.stats.whenLastRealtimeLoop = clock.now ()}};
bundle { //test code
	getUpdates (@system.temp.realtime.client.servers.io)}

---

This listing is for code that runs in the OPML Editor environment. I created these listings because I wanted the search engines to index it, so that when I want to look up something in my codebase I don't have to use the much slower search functionality in my object database. Dave Winer.