haiku/src/servers/app/ServerApp.cpp

/*
 * Copyright 2001-2005, Haiku.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *		DarkWyrm <bpmagic@columbus.rr.com>
 *		Adrian Oanca <adioanca@cotty.iren.ro>
 *		Stephan Aßmus <superstippi@gmx.de>
 *		Stefano Ceccherini (burton666@libero.it)
 *		Axel Dörfler, axeld@pinc-software.de
 */


#include <stdio.h>
#include <string.h>

#include <AppDefs.h>
#include <Autolock.h>
#include <ColorSet.h>
#include <List.h>
#include <ScrollBar.h>
#include <ServerProtocol.h>
#include <Shape.h>
#include <String.h>

#include "AppServer.h"
#include "BGet++.h"
#include "BitmapManager.h"
#include "CursorManager.h"
#include "Desktop.h"
#include "DecorManager.h"
#include "DisplayDriver.h"
#include "FontServer.h"
#include "HWInterface.h"
#include "LayerData.h"
#include "OffscreenServerWindow.h"
#include "RAMLinkMsgReader.h"
#include "RootLayer.h"
#include "ServerBitmap.h"
#include "ServerConfig.h"
#include "ServerCursor.h"
#include "ServerPicture.h"
#include "ServerScreen.h"
#include "ServerWindow.h"
#include "SysCursor.h"
#include "SystemPalette.h"
#include "Utils.h"
#include "WinBorder.h"

#include "ServerApp.h"
#include <syslog.h>

//#define DEBUG_SERVERAPP

#ifdef DEBUG_SERVERAPP
#	define STRACE(x) printf x
#else
#	define STRACE(x) ;
#endif

//#define DEBUG_SERVERAPP_FONT

#ifdef DEBUG_SERVERAPP_FONT
#	define FTRACE(x) printf x
#else
#	define FTRACE(x) ;
#endif


static const uint32 kMsgAppQuit = 'appQ';


/*!
	\brief Constructor
	\param sendport port ID for the BApplication which will receive the ServerApp's messages
	\param rcvport port by which the ServerApp will receive messages from its BApplication.
	\param fSignature NULL-terminated string which contains the BApplication's
	MIME fSignature.
*/
ServerApp::ServerApp(port_id clientReplyPort, port_id clientLooperPort,
	team_id clientTeam, int32 handlerID, const char* signature)
	:
	fClientReplyPort(clientReplyPort),
	fMessagePort(-1),
	fClientLooperPort(clientLooperPort),
	fSignature(signature),
	fThread(-1),
	fClientTeam(clientTeam),
	fWindowListLock("window list"),
	fAppCursor(NULL),
	fCursorHidden(false),
	fIsActive(false),
	//fHandlerToken(handlerID),
	fSharedMem("shared memory"),
	fQuitting(false)
{
	if (fSignature == "")
		fSignature = "application/no-signature";

	char name[B_OS_NAME_LENGTH];
	snprintf(name, sizeof(name), "a<%s", Signature());

	fMessagePort = create_port(DEFAULT_MONITOR_PORT_SIZE, name);
	if (fMessagePort < B_OK)
		return;

	fLink.SetSenderPort(fClientReplyPort);
	fLink.SetReceiverPort(fMessagePort);

	// we let the application own the port, so that we get aware when it's gone
	if (set_port_owner(fMessagePort, clientTeam) < B_OK) {
		delete_port(fMessagePort);
		fMessagePort = -1;
		return;
	}

	// although this isn't pretty, ATM we have only one RootLayer.
	// there should be a way that this ServerApp be attached to a particular
	// RootLayer to know which RootLayer's cursor to modify.
	ServerCursor *defaultCursor = 
		gDesktop->ActiveRootLayer()->GetCursorManager().GetCursor(B_CURSOR_DEFAULT);

	if (defaultCursor) {
		fAppCursor = new ServerCursor(defaultCursor);
		fAppCursor->SetOwningTeam(fClientTeam);
	}

	STRACE(("ServerApp %s:\n", Signature()));
	STRACE(("\tBApp port: %ld\n", fClientReplyPort));
	STRACE(("\tReceiver port: %ld\n", fMessagePort));
}


//! Does all necessary teardown for application
ServerApp::~ServerApp(void)
{
	STRACE(("*ServerApp %s:~ServerApp()\n", Signature()));

	if (!fQuitting)
		CRITICAL("ServerApp: destructor called after Run()!\n");

	fWindowListLock.Lock();

	// quit all server windows

	for (int32 i = fWindowList.CountItems(); i-- > 0;) {
		ServerWindow* window = (ServerWindow*)fWindowList.ItemAt(i);
		window->Quit();
	}
	int32 tries = fWindowList.CountItems() + 1;

	fWindowListLock.Unlock();

	// wait for the windows to quit
	while (tries-- > 0) {
		fWindowListLock.Lock();
		if (fWindowList.CountItems() == 0) {
			// we leave the list locked, doesn't matter anymore
			break;
		}

		fWindowListLock.Unlock();
		snooze(10000);
	}

	if (tries < 0) {
		// This really shouldn't happen, as it shows we're buggy
#if __HAIKU__
		syslog(LOG_ERR, "ServerApp %s needs to kill some server windows...\n", Signature());
#else
		fprintf(stderr, "ServerApp %s needs to kill some server windows...\n", Signature());
#endif

		// there still seem to be some windows left - kill them!
		fWindowListLock.Lock();

		for (int32 i = 0; i < fWindowList.CountItems(); i++) {
			ServerWindow* window = (ServerWindow*)fWindowList.ItemAt(i);
			printf("kill window \"%s\"\n", window->Title());

			kill_thread(window->Thread());
			window->Hide();
			delete window;
		}

		fWindowListLock.Unlock();
	}

	// first, make sure our monitor thread doesn't 
	for (int32 i = 0; i < fBitmapList.CountItems(); i++) {
		gBitmapManager->DeleteBitmap(static_cast<ServerBitmap *>(fBitmapList.ItemAt(i)));
	}

	for (int32 i = 0; i < fPictureList.CountItems(); i++) {
		delete (ServerPicture*)fPictureList.ItemAt(i);
	}

	// although this isn't pretty, ATM we have only one RootLayer.
	// there should be a way that this ServerApp be attached to a particular
	// RootLayer to know which RootLayer's cursor to modify.
	gDesktop->ActiveRootLayer()->GetCursorManager().RemoveAppCursors(fClientTeam);

	STRACE(("ServerApp %s::~ServerApp(): Exiting\n", Signature()));
}


/*!
	\brief Checks if the application was initialized correctly
*/
status_t
ServerApp::InitCheck()
{
	if (fMessagePort < B_OK)
		return fMessagePort;

	if (fClientReplyPort < B_OK)
		return fClientReplyPort;

	if (fWindowListLock.Sem() < B_OK)
		return fWindowListLock.Sem();

	return B_OK;
}


/*!
	\brief Starts the ServerApp monitoring for messages
	\return false if the application couldn't start, true if everything went OK.
*/
bool
ServerApp::Run()
{
	fQuitting = false;

	// Unlike a BApplication, a ServerApp is *supposed* to return immediately
	// when its Run() function is called.	
	fThread = spawn_thread(_message_thread, Signature(), B_NORMAL_PRIORITY, this);
	if (fThread < B_OK)
		return false;

	if (resume_thread(fThread) != B_OK) {
		fQuitting = true;
		kill_thread(fThread);
		fThread = -1;
		return false;
	}

	// Let's tell the client how to talk with us
	fLink.StartMessage(SERVER_TRUE);
	fLink.Attach<int32>(fMessagePort);
	fLink.Flush();

	return true;
}


/*!
	\brief This quits the application and deletes it. You're not supposed
		to call its destructor directly.

	At the point you're calling this method, the application should already
	be removed from the application list.
*/
void
ServerApp::Quit(sem_id shutdownSemaphore)
{
	if (fThread < B_OK) {
		delete this;
		return;
	}

	// execute application deletion in the message looper thread

	fQuitting = true;
	PostMessage(kMsgAppQuit);

	send_data(fThread, 'QUIT', &shutdownSemaphore, sizeof(sem_id));
}


/*!
	\brief Pings the target app to make sure it's still working
	\return true if target is still "alive" and false if "He's dead, Jim." 
	"But that's impossible..."

	This function is called by the app_server thread to ensure that
	the target app still exists. We do this not by sending a message
	but by calling get_port_info. We don't want to send ping messages
	just because the app might simply be hung. If this is the case, it
	should be up to the user to kill it. If the app has been killed, its
	ports will be invalid. Thus, if get_port_info returns an error, we
	tell the app_server to delete the respective ServerApp.
*/
bool
ServerApp::PingTarget()
{
	// ToDo: this function doesn't make any sense; if the client dies we are
	//	aware of it anyway at this point. This would only make sense if we
	//	actually send the team a message to see if it's still responsive.
	team_info info;
	if (get_team_info(fClientTeam, &info) != B_OK) {
		BPrivate::LinkSender link(gAppServerPort);
		link.StartMessage(AS_DELETE_APP);
		link.Attach(&fThread, sizeof(thread_id));
		link.Flush();
		return false;
	}
	return true;
}

/*!
	\brief Send a message to the ServerApp with no attachments
	\param code ID code of the message to post
*/
void
ServerApp::PostMessage(int32 code)
{
	BPrivate::LinkSender link(fMessagePort);
	link.StartMessage(code);
	link.Flush();
}

/*!
	\brief Send a message to the ServerApp's BApplication
	\param msg The message to send
*/
void
ServerApp::SendMessageToClient(const BMessage *msg) const
{
	ssize_t size = msg->FlattenedSize();
	char *buffer = new char[size];

	if (msg->Flatten(buffer, size) == B_OK)
		write_port(fClientLooperPort, msg->what, buffer, size);
	else
		printf("PANIC: ServerApp: '%s': can't flatten message in 'SendMessageToClient()'\n", Signature());

	delete [] buffer;
}

/*!
	\brief Sets the ServerApp's active status
	\param value The new status of the ServerApp.
	
	This changes an internal flag and also sets the current cursor to the one specified by
	the application
*/
void
ServerApp::Activate(bool value)
{
	fIsActive = value;
	SetAppCursor();
}


//! Sets the cursor to the application cursor, if any.
void
ServerApp::SetAppCursor(void)
{
	// although this isn't pretty, ATM we have only one RootLayer.
	// there should be a way that this ServerApp be attached to a particular
	// RootLayer to know which RootLayer's cursor to modify.
	if (fAppCursor)
		gDesktop->GetHWInterface()->SetCursor(fAppCursor);
}


/*!
	\brief The thread function ServerApps use to monitor messages
	\param data Pointer to the thread's ServerApp object
*/
int32
ServerApp::_message_thread(void *_app)
{
	ServerApp *app = (ServerApp *)_app;

	app->_MessageLooper();
	return 0;
}


/*!
	\brief The thread function ServerApps use to monitor messages
*/
void
ServerApp::_MessageLooper()
{
	// Message-dispatching loop for the ServerApp

	BPrivate::LinkReceiver &receiver = fLink.Receiver();

	int32 code;
	status_t err = B_OK;

	while (!fQuitting) {
		STRACE(("info: ServerApp::_MessageLooper() listening on port %ld.\n", fMessagePort));
		err = receiver.GetNextMessage(code, B_INFINITE_TIMEOUT);
		if (err < B_OK || code == B_QUIT_REQUESTED) {
			STRACE(("ServerApp: application seems to be gone...\n"));

			// Tell the app_server to quit us
			BPrivate::LinkSender link(gAppServerPort);
			link.StartMessage(AS_DELETE_APP);
			link.Attach<thread_id>(Thread());
			link.Flush();
			break;
		}

		switch (code) {
			case kMsgAppQuit:
				// we receive this from our destructor on quit
				fQuitting = true;
				break;

			case AS_CREATE_WINDOW:
			{
				// Create a ServerWindow
				// NOTE/TODO: Code duplication in part to below case.
				// Watch out, if you make changes here, you might have to do them below.
				// Go ahead and fix if you have an idea for unification...

				// Attached data:
				// 2) BRect window frame
				// 3) uint32 window look
				// 4) uint32 window feel
				// 5) uint32 window flags
				// 6) uint32 workspace index
				// 7) int32 BHandler token of the window
				// 8) port_id window's message port
				// 9) const char * title

				BRect frame;
				uint32 look;
				uint32 feel;
				uint32 flags;
				uint32 workspaces;
				int32 token = B_NULL_TOKEN;
				port_id	clientReplyPort = -1;
				port_id looperPort = -1;
				char *title = NULL;

				receiver.Read<BRect>(&frame);
				receiver.Read<uint32>(&look);
				receiver.Read<uint32>(&feel);
				receiver.Read<uint32>(&flags);
				receiver.Read<uint32>(&workspaces);
				receiver.Read<int32>(&token);
				receiver.Read<port_id>(&clientReplyPort);
				receiver.Read<port_id>(&looperPort);
				if (receiver.ReadString(&title) != B_OK)
					break;

				if (!frame.IsValid()) {
					// make sure we pass a valid rectangle to ServerWindow
					frame.right = frame.left + 1;
					frame.bottom = frame.top + 1;
				}

				// ServerWindow constructor will reply with port_id of a newly created port
				ServerWindow *window = new ServerWindow(title, this, clientReplyPort,
					looperPort, token);

				STRACE(("\nServerApp %s: New Window %s (%.1f,%.1f,%.1f,%.1f)\n",
					fSignature(), title, frame.left, frame.top, frame.right, frame.bottom));

				// NOTE: the reply to the client is handled in window->Run()				
				if (window->Init(frame, look, feel, flags, workspaces) >= B_OK && window->Run()) {
					// add the window to the list
					if (fWindowListLock.Lock()) {
						fWindowList.AddItem(window);
						fWindowListLock.Unlock();
					}
				} else {
					delete window;

					// window creation failed, we need to notify the client
					BPrivate::LinkSender reply(clientReplyPort);
					reply.StartMessage(SERVER_FALSE);
					reply.Flush();
				}

				// We don't have to free the title, as it's owned by the ServerWindow now
				break;
			}
			case AS_CREATE_OFFSCREEN_WINDOW:
			{
				// Create an OffscreenServerWindow
				// NOTE/TODO: Code duplication in part to above case.

				// Attached data:
				// 2) BRect window frame
				// 3) uint32 window look
				// 4) uint32 window feel
				// 5) uint32 window flags
				// 6) uint32 workspace index
				// 7) int32 BHandler token of the window
				// 8) port_id window's message port
				// 9) const char * title

				BRect frame;
				int32 bitmapToken;
				uint32 look;
				uint32 feel;
				uint32 flags;
				uint32 workspaces;
				int32 token = B_NULL_TOKEN;
				port_id	clientReplyPort = -1;
				port_id looperPort = -1;
				char *title = NULL;

				receiver.Read<int32>(&bitmapToken);
				receiver.Read<BRect>(&frame);
				receiver.Read<uint32>(&look);
				receiver.Read<uint32>(&feel);
				receiver.Read<uint32>(&flags);
				receiver.Read<uint32>(&workspaces);
				receiver.Read<int32>(&token);
				receiver.Read<port_id>(&clientReplyPort);
				receiver.Read<port_id>(&looperPort);
				if (receiver.ReadString(&title) != B_OK)
					break;

				if (!frame.IsValid()) {
					// make sure we pass a valid rectangle to ServerWindow
					frame.right = frame.left + 1;
					frame.bottom = frame.top + 1;
				}
				ServerBitmap* bitmap = FindBitmap(bitmapToken);

				bool success = false;

				if (bitmap) {
					// ServerWindow constructor will reply with port_id of a newly created port
					OffscreenServerWindow *window = new OffscreenServerWindow(title, this, clientReplyPort,
																			  looperPort, token, bitmap);
					
					// NOTE: the reply to the client is handled in window->Run()				
					success = window->Init(frame, look, feel, flags, workspaces) >= B_OK && window->Run();

					// add the window to the list
					if (success && fWindowListLock.Lock()) {
						success = fWindowList.AddItem(window);
						fWindowListLock.Unlock();
					}

					if (!success)
						delete window;
				}
				if (!success) {
					// window creation failed, we need to notify the client
					BPrivate::LinkSender reply(clientReplyPort);
					reply.StartMessage(SERVER_FALSE);
					reply.Flush();
				}

				// We don't have to free the title, as it's owned by the ServerWindow now
				break;
			}

			case AS_QUIT_APP:
			{
				// This message is received only when the app_server is asked to shut down in
				// test/debug mode. Of course, if we are testing while using AccelerantDriver, we do
				// NOT want to shut down client applications. The server can be quit o in this fashion
				// through the driver's interface, such as closing the ViewDriver's window.

				STRACE(("ServerApp %s:Server shutdown notification received\n", Signature()));

				// If we are using the real, accelerated version of the
				// DisplayDriver, we do NOT want the user to be able shut down
				// the server. The results would NOT be pretty
#if TEST_MODE
				BMessage pleaseQuit(B_QUIT_REQUESTED);
				SendMessageToClient(&pleaseQuit);
#endif
				break;
			}

			default:
				STRACE(("ServerApp %s: Got a Message to dispatch\n", Signature()));
				_DispatchMessage(code, receiver);
				break;
		}
	}

	// Quit() will send us a message; we're handling the exiting procedure
	thread_id sender;
	sem_id shutdownSemaphore;
	receive_data(&sender, &shutdownSemaphore, sizeof(sem_id));

	delete this;

	if (shutdownSemaphore >= B_OK)
		release_sem(shutdownSemaphore);
}


/*!
	\brief Handler function for BApplication API messages
	\param code Identifier code for the message. Equivalent to BMessage::what
	\param buffer Any attachments
	
	Note that the buffer's exact format is determined by the particular message. 
	All attachments are placed in the buffer via a PortLink, so it will be a 
	matter of casting and incrementing an index variable to access them.
*/
void
ServerApp::_DispatchMessage(int32 code, BPrivate::LinkReceiver &link)
{
//	LayerData ld;

	switch (code) {
		case AS_GET_WINDOW_LIST:
			team_id team;
			link.Read<team_id>(&team);

			gDesktop->WriteWindowList(team, fLink.Sender());
			break;

		case AS_GET_WINDOW_INFO:
			int32 serverToken;
			link.Read<int32>(&serverToken);

			gDesktop->WriteWindowInfo(serverToken, fLink.Sender());
			break;

		case AS_UPDATE_COLORS:
		{
			// NOTE: R2: Eventually we will have windows which will notify their children of changes in 
			// system colors
			
/*			STRACE(("ServerApp %s: Received global UI color update notification\n", Signature()));
			ServerWindow *win;
			BMessage msg(_COLORS_UPDATED);
			
			for(int32 i = 0; i < fWindowList.CountItems(); i++) {
				win=(ServerWindow*)fWindowList.ItemAt(i);
				win->GetWinBorder()->UpdateColors();
				win->SendMessageToClient(AS_UPDATE_COLORS, msg);
			}
*/			break;
		}
		case AS_UPDATE_FONTS:
		{
			// NOTE: R2: Eventually we will have windows which will notify their children of changes in 
			// system fonts
			
/*			STRACE(("ServerApp %s: Received global font update notification\n", Signature()));
			ServerWindow *win;
			BMessage msg(_FONTS_UPDATED);
			
			for(int32 i=0; i<fSWindowList->CountItems(); i++)
			{
				win=(ServerWindow*)fSWindowList->ItemAt(i);
				win->GetWinBorder()->UpdateFont();
				win->SendMessageToClient(AS_UPDATE_FONTS, msg);
			}
*/			break;
		}
		case AS_AREA_MESSAGE:
		{
			// This occurs in only one kind of case: a message is too big to send over a port. This
			// is really an edge case, so this shouldn't happen *too* often
			
			// Attached Data:
			// 1) area_id id of an area already owned by the server containing the message
			// 2) size_t offset of the pointer in the area
			// 3) size_t size of the message
			
			area_id area;
			size_t offset;
			size_t msgsize;
			area_info ai;
			int8 *msgpointer;

			link.Read<area_id>(&area);
			link.Read<size_t>(&offset);
			link.Read<size_t>(&msgsize);

			// Part sanity check, part get base pointer :)
			if (get_area_info(area, &ai) < B_OK)
				break;

			msgpointer = (int8*)ai.address + offset;

			RAMLinkMsgReader mlink(msgpointer);
			_DispatchMessage(mlink.Code(), mlink);

			// This is a very special case in the sense that when ServerMemIO is used for this 
			// purpose, it will be set to NOT automatically free the memory which it had 
			// requested. This is the server's job once the message has been dispatched.
			fSharedMem.ReleaseBuffer(msgpointer);
			break;
		}
		case AS_ACQUIRE_SERVERMEM:
		{
			// This particular call is more than a bit of a pain in the neck. We are given a
			// size of a chunk of memory needed. We need to (1) allocate it, (2) get the area for
			// this particular chunk, (3) find the offset in the area for this chunk, and (4)
			// tell the client about it. Good thing this particular call isn't used much
			
			// Received from a ServerMemIO object requesting operating memory
			// Attached Data:
			// 1) size_t requested size
			// 2) port_id reply_port

			size_t memsize;
			link.Read<size_t>(&memsize);

			// TODO: I wonder if ACQUIRE_SERVERMEM should have a minimum size requirement?

			void *sharedmem = fSharedMem.GetBuffer(memsize);

			if (memsize < 1 || sharedmem == NULL) {
				fLink.StartMessage(SERVER_FALSE);
				fLink.Flush();
				break;
			}
			
			area_id owningArea = area_for(sharedmem);
			area_info info;

			if (owningArea == B_ERROR || get_area_info(owningArea, &info) < B_OK) {
				fLink.StartMessage(SERVER_FALSE);
				fLink.Flush();
				break;
			}

			int32 areaoffset = (addr_t)sharedmem - (addr_t)info.address;
			STRACE(("Successfully allocated shared memory of size %ld\n",memsize));

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<area_id>(owningArea);
			fLink.Attach<int32>(areaoffset);
			fLink.Flush();
			break;
		}
		case AS_RELEASE_SERVERMEM:
		{
			// Received when a ServerMemIO object on destruction
			// Attached Data:
			// 1) area_id owning area
			// 2) int32 area offset
			
			area_id owningArea;
			int32 areaoffset;
				
			link.Read<area_id>(&owningArea);
			link.Read<int32>(&areaoffset);
			
			area_info areaInfo;
			if (owningArea < 0 || get_area_info(owningArea, &areaInfo) != B_OK)
				break;
			
			STRACE(("Successfully freed shared memory\n"));
			void *sharedmem = ((int32*)areaInfo.address) + areaoffset;
			
			fSharedMem.ReleaseBuffer(sharedmem);
			
			break;
		}
		case AS_UPDATE_DECORATOR:
		{
			STRACE(("ServerApp %s: Received decorator update notification\n", Signature()));

			for (int32 i = 0; i < fWindowList.CountItems(); i++) {
				ServerWindow *window = (ServerWindow*)fWindowList.ItemAt(i);
				window->Lock();
				const_cast<WinBorder *>(window->GetWinBorder())->UpdateDecorator();
				window->Unlock();
			}
			break;
		}
		case AS_SET_DECORATOR:
		{
			// Received from an application when the user wants to set the window
			// decorator to a new one
			
			// Attached Data:
			// int32 the index of the decorator to use
			
			int32 index;
			link.Read<int32>(&index);
			if(gDecorManager.SetDecorator(index))
				BroadcastToAllApps(AS_UPDATE_DECORATOR);
			
			break;
		}
		case AS_COUNT_DECORATORS:
		{
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<int32>(gDecorManager.CountDecorators());
			fLink.Flush();
			break;
		}
		case AS_GET_DECORATOR:
		{
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<int32>(gDecorManager.GetDecorator());
			fLink.Flush();
			break;
		}
		case AS_GET_DECORATOR_NAME:
		{
			int32 index;
			link.Read<int32>(&index);
			
			BString str(gDecorManager.GetDecoratorName(index));
			if(str.CountChars() > 0)
			{
				fLink.StartMessage(SERVER_TRUE);
				fLink.AttachString(str.String());
			}
			else
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
			break;
		}
		case AS_R5_SET_DECORATOR:
		{
			// Sort of supports Tracker's nifty Easter Egg. It was easy to do and 
			// it's kind of neat, so why not?
			
			// Attached Data:
			// int32 value of the decorator to use
			// 0: BeOS
			// 1: Amiga
			// 2: Windows
			// 3: MacOS
			
			int32 decindex = 0;
			link.Read<int32>(&decindex);
			
			if(gDecorManager.SetR5Decorator(decindex))
				BroadcastToAllApps(AS_UPDATE_DECORATOR);
			
			break;
		}
		case AS_CREATE_BITMAP:
		{
			STRACE(("ServerApp %s: Received BBitmap creation request\n", Signature()));
			// Allocate a bitmap for an application
			
			// Attached Data: 
			// 1) BRect bounds
			// 2) color_space space
			// 3) int32 bitmap_flags
			// 4) int32 bytes_per_row
			// 5) int32 screen_id::id
			// 6) port_id reply port
			
			// Reply Code: SERVER_TRUE
			// Reply Data:
			//	1) int32 server token
			//	2) area_id id of the area in which the bitmap data resides
			//	3) int32 area pointer offset used to calculate fBasePtr
			
			// First, let's attempt to allocate the bitmap
			ServerBitmap *bitmap = NULL;
			BRect frame;
			color_space colorSpace;
			int32 flags, bytesPerRow;
			screen_id screenID;

			link.Read<BRect>(&frame);
			link.Read<color_space>(&colorSpace);
			link.Read<int32>(&flags);
			link.Read<int32>(&bytesPerRow);
			if (link.Read<screen_id>(&screenID) == B_OK) {
				bitmap = gBitmapManager->CreateBitmap(frame, colorSpace, flags,
													  bytesPerRow, screenID);
			}

			STRACE(("ServerApp %s: Create Bitmap (%.1fx%.1f)\n",
						Signature(), frame.Width(), frame.Height()));

			if (bitmap && fBitmapList.AddItem((void*)bitmap)) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<int32>(bitmap->Token());
				fLink.Attach<int32>(bitmap->Area());
				fLink.Attach<int32>(bitmap->AreaOffset());
			} else {
				// alternatively, if something went wrong, we reply with SERVER_FALSE
				fLink.StartMessage(SERVER_FALSE);
			}

			fLink.Flush();
			break;
		}
		case AS_DELETE_BITMAP:
		{
			STRACE(("ServerApp %s: received BBitmap delete request\n", Signature()));
			// Delete a bitmap's allocated memory

			// Attached Data:
			// 1) int32 token
			// 2) int32 reply port
		
			// Reply Code: SERVER_TRUE if successful, 
			//				SERVER_FALSE if the buffer was already deleted or was not found
			int32 id;
			link.Read<int32>(&id);

			ServerBitmap *bitmap = FindBitmap(id);
			if (bitmap && fBitmapList.RemoveItem((void*)bitmap)) {
				STRACE(("ServerApp %s: Deleting Bitmap %ld\n", Signature(), id));

				gBitmapManager->DeleteBitmap(bitmap);
				fLink.StartMessage(SERVER_TRUE);
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();	
			break;
		}
#if 0
		case AS_CREATE_PICTURE:
		{
			// TODO: Implement AS_CREATE_PICTURE
			STRACE(("ServerApp %s: Create Picture unimplemented\n", Signature()));
			break;
		}
		case AS_DELETE_PICTURE:
		{
			// TODO: Implement AS_DELETE_PICTURE
			STRACE(("ServerApp %s: Delete Picture unimplemented\n", Signature()));
			break;
		}
		case AS_CLONE_PICTURE:
		{
			// TODO: Implement AS_CLONE_PICTURE
			STRACE(("ServerApp %s: Clone Picture unimplemented\n", Signature()));
			break;
		}
		case AS_DOWNLOAD_PICTURE:
		{
			// TODO; Implement AS_DOWNLOAD_PICTURE
			STRACE(("ServerApp %s: Download Picture unimplemented\n", Signature()));
			
			// What is this particular function call for, anyway?
			
			// DW: I think originally it might have been to support 
			// the undocumented Flatten function.
			break;
		}
#endif
		case AS_CURRENT_WORKSPACE:
		{
			STRACE(("ServerApp %s: get current workspace\n", Signature()));

			// TODO: Locking this way is not nice
			RootLayer *root = gDesktop->ActiveRootLayer();
			root->Lock();
			
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<int32>(root->ActiveWorkspaceIndex());
			fLink.Flush();
			
			root->Unlock();
			break;
		}
		
		case AS_ACTIVATE_WORKSPACE:
		{
			STRACE(("ServerApp %s: activate workspace\n", Signature()));
			
			// TODO: See above
			int32 index;
			link.Read<int32>(&index);
			RootLayer *root = gDesktop->ActiveRootLayer();
			root->Lock();
			root->SetActiveWorkspace(index);
			root->Unlock();
			// no reply
		
			break;
		}
		
		// Theoretically, we could just call the driver directly, but we will
		// call the CursorManager's version to allow for future expansion
		case AS_SHOW_CURSOR:
		{
			STRACE(("ServerApp %s: Show Cursor\n", Signature()));
			// although this isn't pretty, ATM we have only one RootLayer.
			// there should be a way that this ServerApp be attached to a particular
			// RootLayer to know which RootLayer's cursor to modify.
// TODO: support nested showing/hiding
			gDesktop->GetHWInterface()->SetCursorVisible(true);
			fCursorHidden = false;
			break;
		}
		case AS_HIDE_CURSOR:
		{
			STRACE(("ServerApp %s: Hide Cursor\n", Signature()));
			// although this isn't pretty, ATM we have only one RootLayer.
			// there should be a way that this ServerApp be attached to a particular
			// RootLayer to know which RootLayer's cursor to modify.
// TODO: support nested showing/hiding
			gDesktop->GetHWInterface()->SetCursorVisible(false);
			fCursorHidden = true;
			break;
		}
		case AS_OBSCURE_CURSOR:
		{
			STRACE(("ServerApp %s: Obscure Cursor\n", Signature()));
			// although this isn't pretty, ATM we have only one RootLayer.
			// there should be a way that this ServerApp be attached to a particular
			// RootLayer to know which RootLayer's cursor to modify.
//			gDesktop->GetHWInterface()->ObscureCursor();
			break;
		}
		case AS_QUERY_CURSOR_HIDDEN:
		{
			STRACE(("ServerApp %s: Received IsCursorHidden request\n", Signature()));
			// Attached data
			// 1) int32 port to reply to
			fLink.StartMessage(fCursorHidden ? SERVER_TRUE : SERVER_FALSE);
			fLink.Flush();
			break;
		}
		case AS_SET_CURSOR_DATA:
		{
			STRACE(("ServerApp %s: SetCursor via cursor data\n", Signature()));
			// Attached data: 68 bytes of fAppCursor data
			
			int8 cdata[68];
			link.Read(cdata,68);
			
			// Because we don't want an overaccumulation of these particular
			// cursors, we will delete them if there is an existing one. It would
			// otherwise be easy to crash the server by calling SetCursor a
			// sufficient number of times
			if(fAppCursor)
				gDesktop->ActiveRootLayer()->GetCursorManager().DeleteCursor(fAppCursor->ID());

			fAppCursor = new ServerCursor(cdata);
			fAppCursor->SetOwningTeam(fClientTeam);
			fAppCursor->SetAppSignature(Signature());
			gDesktop->ActiveRootLayer()->GetCursorManager().AddCursor(fAppCursor);
			// although this isn't pretty, ATM we have only one RootLayer.
			// there should be a way that this ServerApp be attached to a particular
			// RootLayer to know which RootLayer's cursor to modify.
			gDesktop->GetHWInterface()->SetCursor(fAppCursor);
			break;
		}
		case AS_SET_CURSOR_BCURSOR:
		{
			STRACE(("ServerApp %s: SetCursor via BCursor\n", Signature()));
			// Attached data:
			// 1) bool flag to send a reply
			// 2) int32 token ID of the cursor to set
			// 3) port_id port to receive a reply. Only exists if the sync flag is true.
			bool sync;
			int32 ctoken = B_NULL_TOKEN;
			
			link.Read<bool>(&sync);
			link.Read<int32>(&ctoken);
			
			// although this isn't pretty, ATM we have only one RootLayer.
			// there should be a way that this ServerApp be attached to a particular
			// RootLayer to know which RootLayer's cursor to modify.
			ServerCursor	*cursor;
			if ((cursor = gDesktop->ActiveRootLayer()->GetCursorManager().FindCursor(ctoken)))
				gDesktop->GetHWInterface()->SetCursor(cursor);

			if (sync) {
				// the application is expecting a reply, but plans to do literally nothing
				// with the data, so we'll just reuse the cursor token variable
				fLink.StartMessage(SERVER_TRUE);
				fLink.Flush();
			}
			break;
		}
		case AS_CREATE_BCURSOR:
		{
			STRACE(("ServerApp %s: Create BCursor\n", Signature()));
			// Attached data:
			// 1) 68 bytes of fAppCursor data
			// 2) port_id reply port
			
			int8 cursorData[68];
			link.Read(cursorData, sizeof(cursorData));

			fAppCursor = new ServerCursor(cursorData);
			fAppCursor->SetOwningTeam(fClientTeam);
			fAppCursor->SetAppSignature(Signature());
			// although this isn't pretty, ATM we have only one RootLayer.
			// there should be a way that this ServerApp be attached to a particular
			// RootLayer to know which RootLayer's cursor to modify.
			gDesktop->ActiveRootLayer()->GetCursorManager().AddCursor(fAppCursor);

			// Synchronous message - BApplication is waiting on the cursor's ID
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<int32>(fAppCursor->ID());
			fLink.Flush();
			break;
		}
		case AS_DELETE_BCURSOR:
		{
			STRACE(("ServerApp %s: Delete BCursor\n", Signature()));
			// Attached data:
			// 1) int32 token ID of the cursor to delete
			int32 ctoken = B_NULL_TOKEN;
			link.Read<int32>(&ctoken);

			if (fAppCursor && fAppCursor->ID() == ctoken)
				fAppCursor = NULL;

			// although this isn't pretty, ATM we have only one RootLayer.
			// there should be a way that this ServerApp be attached to a particular
			// RootLayer to know which RootLayer's cursor to modify.
			gDesktop->ActiveRootLayer()->GetCursorManager().DeleteCursor(ctoken);
			break;
		}
		case AS_GET_SCROLLBAR_INFO:
		{
			STRACE(("ServerApp %s: Get ScrollBar info\n", Signature()));
			scroll_bar_info info = gDesktop->ScrollBarInfo();

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<scroll_bar_info>(info);
			fLink.Flush();
			break;
		}
		case AS_SET_SCROLLBAR_INFO:
		{
			STRACE(("ServerApp %s: Set ScrollBar info\n", Signature()));
			// Attached Data:
			// 1) scroll_bar_info scroll bar info structure
			scroll_bar_info info;
			if (link.Read<scroll_bar_info>(&info) == B_OK)
				gDesktop->SetScrollBarInfo(info);
			break;
		}
		case AS_FOCUS_FOLLOWS_MOUSE:
		{
			STRACE(("ServerApp %s: query Focus Follow Mouse in use\n", Signature()));

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<bool>(gDesktop->FFMouseInUse());
			fLink.Flush();
			break;
		}
		case AS_SET_FOCUS_FOLLOWS_MOUSE:
		{
			STRACE(("ServerApp %s: Set Focus Follows Mouse in use\n", Signature()));
			// ToDo: implement me!
			break;
		}
		case AS_SET_MOUSE_MODE:
		{
			STRACE(("ServerApp %s: Set Focus Follows Mouse mode\n", Signature()));
			// Attached Data:
			// 1) enum mode_mouse FFM mouse mode
			mode_mouse mmode;
			if (link.Read<mode_mouse>(&mmode) == B_OK)
				gDesktop->SetFFMouseMode(mmode);
			break;
		}
		case AS_GET_MOUSE_MODE:
		{
			STRACE(("ServerApp %s: Get Focus Follows Mouse mode\n", Signature()));
			mode_mouse mmode = gDesktop->FFMouseMode();

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<mode_mouse>(mmode);
			fLink.Flush();
			break;
		}
		case AS_GET_UI_COLORS:
		{
			// Client application is asking for all the system colors at once
			// using a ColorSet object
			
			
			gGUIColorSet.Lock();
			
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<ColorSet>(gGUIColorSet);
			fLink.Flush();
			
			gGUIColorSet.Unlock();
			
			break;
		}
		case AS_SET_UI_COLORS:
		{
			// Client application is asking to set all the system colors at once
			// using a ColorSet object

			// Attached data:
			// 1) ColorSet new colors to use

			gGUIColorSet.Lock();
			link.Read<ColorSet>(&gGUIColorSet);
			gGUIColorSet.Unlock();

			BroadcastToAllApps(AS_UPDATE_COLORS);
			break;
		}
		case AS_GET_UI_COLOR:
		{
			STRACE(("ServerApp %s: Get UI color\n", Signature()));

			RGBColor color;
			int32 whichColor;
			link.Read<int32>(&whichColor);

			gGUIColorSet.Lock();
			color = gGUIColorSet.AttributeToColor(whichColor);
			gGUIColorSet.Unlock();

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<rgb_color>(color.GetColor32());
			fLink.Flush();
			break;
		}

		case AS_UPDATED_CLIENT_FONTLIST:
		{
			STRACE(("ServerApp %s: Acknowledged update of client-side font list\n",
				Signature()));

			// received when the client-side global font list has been
			// refreshed
			gFontServer->Lock();
			gFontServer->FontsUpdated();
			gFontServer->Unlock();
			break;
		}
		case AS_QUERY_FONTS_CHANGED:
		{
			FTRACE(("ServerApp %s: AS_QUERY_FONTS_CHANGED unimplemented\n",
				Signature()));
			// Attached Data:
			// 1) bool check flag

			// if just checking, just give an answer,
			// if not and needs updated, 
			// sync the font list and return true else return false
			fLink.StartMessage(SERVER_FALSE);
			fLink.Flush();
			break;
		}
		case AS_GET_FAMILY_NAME:
		{
			FTRACE(("ServerApp %s: AS_GET_FAMILY_NAME\n", Signature()));
			// Attached Data:
			// 1) int32 the ID of the font family to get

			// Returns:
			// 1) font_family - name of family
			// 2) uint32 - flags of font family (B_IS_FIXED || B_HAS_TUNED_FONT)
			int32 id;
			link.Read<int32>(&id);

			gFontServer->Lock();
			FontFamily *ffamily = gFontServer->GetFamily(id);
			if (ffamily) {
				font_family fam;
				strcpy(fam, ffamily->Name());
				fLink.Attach(fam, sizeof(font_family));
				fLink.Attach<int32>(ffamily->GetFlags());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_GET_STYLE_NAME:
		{
			FTRACE(("ServerApp %s: AS_GET_STYLE_NAME\n", Signature()));
			// Attached Data:
			// 1) font_family The name of the font family
			// 2) int32 ID of the style to get

			// Returns:
			// 1) font_style - name of the style
			// 2) uint16 - appropriate face values
			// 3) uint32 - flags of font style (B_IS_FIXED || B_HAS_TUNED_FONT)

			int32 styid;
			font_family fam;

			link.Read(fam,sizeof(font_family));
			link.Read<int32>(&styid);

			gFontServer->Lock();
			FontStyle *fstyle = gFontServer->GetStyle(fam, styid);
			if (fstyle) {
				font_family sty;
				strcpy(sty, fstyle->Name());
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach(sty,sizeof(font_style));
				fLink.Attach<int32>(fstyle->GetFace());
				fLink.Attach<int32>(fstyle->GetFlags());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();			
			gFontServer->Unlock();
			break;
		}
		case AS_GET_FAMILY_AND_STYLE:
		{
			FTRACE(("ServerApp %s: AS_GET_FAMILY_AND_STYLE\n", Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID

			// Returns:
			// 1) font_family The name of the font family
			// 2) font_style - name of the style
			uint16 famid, styid;
			font_family fam;
			font_style sty;

			link.Read<uint16>(&famid);
			link.Read<uint16>(&styid);

			gFontServer->Lock();
			FontStyle *fstyle = gFontServer->GetStyle(famid, styid);
			if (fstyle) {
				strcpy(fam, fstyle->Family()->Name());
				strcpy(sty, fstyle->Name());

				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach(fam, sizeof(font_family));
				fLink.Attach(sty, sizeof(font_style));
			} else
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_GET_FONT_DIRECTION:
		{
			FTRACE(("ServerApp %s: AS_GET_FONT_DIRECTION unimplemented\n",
				Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID

			// Returns:
			// 1) font_direction direction of font

			// NOTE: While this may be unimplemented, we can safely return
			// SERVER_FALSE. This will force the BFont code to default to
			// B_LEFT_TO_RIGHT, which is what the vast majority of fonts will be.
			// This will be fixed later.
			int32 famid, styid;
			link.Read<int32>(&famid);
			link.Read<int32>(&styid);
			
/*			gFontServer->Lock();
			FontStyle *fstyle=gFontServer->GetStyle(famid,styid);
			if(fstyle)
			{
				font_direction dir=fstyle->GetDirection();
				
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<font_direction>(dir);
				fLink.Flush();
			}
			else
			{
*/				fLink.StartMessage(SERVER_FALSE);
				fLink.Flush();
//			}
			
//			gFontServer->Unlock();
			break;
		}
		case AS_GET_STRING_WIDTH:
		{
			FTRACE(("ServerApp %s: AS_GET_STRING_WIDTH\n", Signature()));
			// Attached Data:
			// 1) string String to measure
			// 2) int32 string length to measure
			// 3) uint16 ID of family
			// 4) uint16 ID of style
			// 5) float point size of font
			// 6) uint8 spacing to use

			// Returns:
			// 1) float - width of the string in pixels
			char *string = NULL;
			int32 length;
			uint16 family, style;
			float size, width = 0;
			uint8 spacing;

			link.ReadString(&string);
			link.Read<int32>(&length);
			link.Read<uint16>(&family);
			link.Read<uint16>(&style);
			link.Read<float>(&size);
			link.Read<uint8>(&spacing);

			ServerFont font;

			if (length > 0 && font.SetFamilyAndStyle(family, style) == B_OK
				&& size > 0 && string) {

				font.SetSize(size);
				font.SetSpacing(spacing);

				width = gDesktop->GetDisplayDriver()->StringWidth(string, length, font);
				// NOTE: The line below will return the exact same thing. However,
				// the line above uses the AGG rendering backend, for which glyph caching
				// actually works. It is about 20 times faster!
				//width = font.StringWidth(string, length);

				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<float>(width);
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			free(string);
			break;
		}
		case AS_GET_FONT_BOUNDING_BOX:
		{
			FTRACE(("ServerApp %s: AS_GET_BOUNDING_BOX unimplemented\n",
				Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID

			// Returns:
			// 1) BRect - box holding entire font

			// ToDo: implement me!
			fLink.StartMessage(SERVER_FALSE);
			fLink.Flush();
			break;
		}
		case AS_GET_TUNED_COUNT:
		{
			FTRACE(("ServerApp %s: AS_GET_TUNED_COUNT\n", Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID

			// Returns:
			// 1) int32 - number of font strikes available
			uint16 famid, styid;
			link.Read<uint16>(&famid);
			link.Read<uint16>(&styid);

			gFontServer->Lock();
			FontStyle *fstyle = gFontServer->GetStyle(famid, styid);
			if (fstyle) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<int32>(fstyle->TunedCount());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_GET_TUNED_INFO:
		{
			FTRACE(("ServerApp %s: AS_GET_TUNED_INFO unimplmemented\n",
				Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			// 3) uint32 - index of the particular font strike

			// Returns:
			// 1) tuned_font_info - info on the strike specified
			// ToDo: implement me!
			fLink.StartMessage(SERVER_FALSE);
			fLink.Flush();
			break;
		}
		case AS_QUERY_FONT_FIXED:
		{
			FTRACE(("ServerApp %s: AS_QUERY_FONT_FIXED unimplmemented\n",
				Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID

			// Returns:
			// 1) bool - font is/is not fixed
			uint16 famid, styid;
			link.Read<uint16>(&famid);
			link.Read<uint16>(&styid);

			gFontServer->Lock();
			FontStyle *fstyle = gFontServer->GetStyle(famid, styid);
			if (fstyle) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<bool>(fstyle->IsFixedWidth());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_SET_FAMILY_NAME:
		{
			FTRACE(("ServerApp %s: AS_SET_FAMILY_NAME\n", Signature()));
			// Attached Data:
			// 1) font_family - name of font family to use

			// Returns:
			// 1) uint16 - family ID

			font_family fam;
			link.Read(fam, sizeof(font_family));

			gFontServer->Lock();
			FontFamily *ffam = gFontServer->GetFamily(fam);
			if (ffam) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint16>(ffam->GetID());
			} else
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_SET_FAMILY_AND_STYLE:
		{
			FTRACE(("ServerApp %s: AS_SET_FAMILY_AND_STYLE\n",
				Signature()));
			// Attached Data:
			// 1) font_family - name of font family to use
			// 2) font_style - name of style in family

			// Returns:
			// 1) uint16 - family ID
			// 2) uint16 - style ID

			font_family fam;
			font_style sty;
			link.Read(fam, sizeof(font_family));
			link.Read(sty, sizeof(font_style));

			gFontServer->Lock();
			FontStyle *fstyle = gFontServer->GetStyle(fam, sty);
			if (fstyle) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint16>(fstyle->Family()->GetID());
				fLink.Attach<uint16>(fstyle->GetID());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_SET_FAMILY_AND_STYLE_FROM_ID:
		{
			FTRACE(("ServerApp %s: AS_SET_FAMILY_AND_STYLE_FROM_ID\n",
				Signature()));
			// Attached Data:
			// 1) uint16 - ID of font family to use
			// 2) uint16 - ID of style in family

			// Returns:
			// 1) uint16 - face of the font

			uint16 fam, sty;
			link.Read<uint16>(&fam);
			link.Read<uint16>(&sty);

			ServerFont font;
			if (font.SetFamilyAndStyle(fam, sty) == B_OK) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint16>(font.Face());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			break;
		}
		case AS_SET_FAMILY_AND_FACE:
		{
			FTRACE(("ServerApp %s: AS_SET_FAMILY_AND_FACE unimplmemented\n",
				Signature()));
			// Attached Data:
			// 1) font_family - name of font family to use
			// 2) uint16 - font face

			// Returns:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			
			// TODO: Check R5 for error condition behavior in SET_FAMILY_AND_FACE
			// ToDo: implement me!
			fLink.StartMessage(SERVER_FALSE);
			fLink.Flush();
			break;
		}
		case AS_COUNT_FONT_FAMILIES:
		{
			FTRACE(("ServerApp %s: AS_COUNT_FONT_FAMILIES\n", Signature()));
			// Returns:
			// 1) int32 - # of font families

			gFontServer->Lock();

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<int32>(gFontServer->CountFamilies());
			fLink.Flush();

			gFontServer->Unlock();
			break;
		}
		case AS_COUNT_FONT_STYLES:
		{
			FTRACE(("ServerApp %s: AS_COUNT_FONT_STYLES\n", Signature()));
			// Attached Data:
			// 1) font_family - name of font family

			// Returns:
			// 1) int32 - # of font styles
			font_family fam;
			link.Read(fam,sizeof(font_family));

			gFontServer->Lock();
			FontFamily *ffam = gFontServer->GetFamily(fam);
			if (ffam) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<int32>(ffam->CountStyles());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_SET_SYSFONT_PLAIN:
		{
			FTRACE(("ServerApp %s: AS_SET_SYSFONT_PLAIN\n", Signature()));
			// Returns:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			// 3) float - size in points
			// 4) uint16 - face flags
			// 5) uint32 - font flags

			gFontServer->Lock();
			ServerFont *sf = gFontServer->GetSystemPlain();
			if (sf) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint16>(sf->FamilyID());
				fLink.Attach<uint16>(sf->StyleID());
				fLink.Attach<float>(sf->Size());
				fLink.Attach<uint16>(sf->Face());
				fLink.Attach<uint32>(sf->Flags());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_GET_FONT_HEIGHT:
		{
			FTRACE(("ServerApp %s: AS_GET_FONT_HEIGHT\n", Signature()));
			// Attached Data:
			// 1) uint16 family ID
			// 2) uint16 style ID
			// 3) float size
			uint16 famid,styid;
			float ptsize;
			link.Read<uint16>(&famid);
			link.Read<uint16>(&styid);
			link.Read<float>(&ptsize);

			gFontServer->Lock();
			FontStyle *fstyle = gFontServer->GetStyle(famid, styid);
			if (fstyle) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<font_height>(fstyle->GetHeight(ptsize));
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_SET_SYSFONT_BOLD:
		{
			FTRACE(("ServerApp %s: AS_SET_SYSFONT_BOLD\n", Signature()));
			// Returns:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			// 3) float - size in points
			// 4) uint16 - face flags
			// 5) uint32 - font flags
			
			gFontServer->Lock();
			ServerFont *sf = gFontServer->GetSystemBold();
			if (sf) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint16>(sf->FamilyID());
				fLink.Attach<uint16>(sf->StyleID());
				fLink.Attach<float>(sf->Size());
				fLink.Attach<uint16>(sf->Face());
				fLink.Attach<uint32>(sf->Flags());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_SET_SYSFONT_FIXED:
		{
			FTRACE(("ServerApp %s: AS_SET_SYSFONT_FIXED\n", Signature()));
			// Returns:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			// 3) float - size in points
			// 4) uint16 - face flags
			// 5) uint32 - font flags

			gFontServer->Lock();
			ServerFont *sf = gFontServer->GetSystemFixed();
			if (sf) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint16>(sf->FamilyID());
				fLink.Attach<uint16>(sf->StyleID());
				fLink.Attach<float>(sf->Size());
				fLink.Attach<uint16>(sf->Face());
				fLink.Attach<uint32>(sf->Flags());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			gFontServer->Unlock();
			break;
		}
		case AS_GET_GLYPH_SHAPES:
		{
			FTRACE(("ServerApp %s: AS_GET_GLYPH_SHAPES\n", Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			// 3) float - point size
			// 4) float - shear
			// 5) float - rotation
			// 6) uint32 - flags
			// 7) int32 - numChars
			// 8) char - chars (numChars times)

			// Returns:
			// 1) BShape - glyph shape
			// numChars times

			uint16 famid, styid;
			uint32 flags;
			float ptsize, shear, rotation;
			
			link.Read<uint16>(&famid);
			link.Read<uint16>(&styid);
			link.Read<float>(&ptsize);
			link.Read<float>(&shear);
			link.Read<float>(&rotation);
			link.Read<uint32>(&flags);
			
			int32 numChars;
			link.Read<int32>(&numChars);
			
			char charArray[numChars];			
			for (int32 i = 0; i < numChars; i++)
				link.Read<char>(&charArray[i]);
			
			ServerFont font;
			if (font.SetFamilyAndStyle(famid, styid) == B_OK) {
				font.SetSize(ptsize);
				font.SetShear(shear);
				font.SetRotation(rotation);
				font.SetFlags(flags);
				
				BShape **shapes = font.GetGlyphShapes(charArray, numChars);
				if (shapes) {
					fLink.StartMessage(SERVER_TRUE);
					for (int32 i = 0; i < numChars; i++) {
						fLink.AttachShape(*shapes[i]);
						delete shapes[i];
					}

					delete shapes;
				} else
					fLink.StartMessage(SERVER_FALSE);
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			break;
		}
		case AS_GET_ESCAPEMENTS:
		{
			FTRACE(("ServerApp %s: AS_GET_ESCAPEMENTS\n", Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			// 3) float - point size
			// 4) float - rotation
			// 5) uint32 - flags
			// 6) int32 - numChars
			// 7) char - char     -\       both
			// 8) BPoint - offset -/ (numChars times)

			// Returns:
			// 1) BPoint - escapement
			// numChars times

			uint16 famid, styid;
			uint32 flags;
			float ptsize, rotation;

			link.Read<uint16>(&famid);
			link.Read<uint16>(&styid);
			link.Read<float>(&ptsize);
			link.Read<float>(&rotation);
			link.Read<uint32>(&flags);

			int32 numChars;
			link.Read<int32>(&numChars);

			char charArray[numChars];			
			BPoint offsetArray[numChars];
			for (int32 i = 0; i < numChars; i++) {
				link.Read<char>(&charArray[i]);
				link.Read<BPoint>(&offsetArray[i]);
			}

			ServerFont font;
			if (font.SetFamilyAndStyle(famid, styid) == B_OK) {
				font.SetSize(ptsize);
				font.SetRotation(rotation);
				font.SetFlags(flags);
				
				BPoint *esc = font.GetEscapements(charArray, numChars, offsetArray);
				if (esc) {
					fLink.StartMessage(SERVER_TRUE);
					for (int32 i = 0; i < numChars; i++) {
						fLink.Attach<BPoint>(esc[i]);
					}
					
					delete esc;
				} else
					fLink.StartMessage(SERVER_FALSE);
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			break;
		}
		case AS_GET_ESCAPEMENTS_AS_FLOATS:
		{
			FTRACE(("ServerApp %s: AS_GET_ESCAPEMENTS_AS_FLOATS\n", Signature()));
			// Attached Data:
			// 1) uint16 - family ID
			// 2) uint16 - style ID
			// 3) float - point size
			// 4) float - rotation
			// 5) uint32 - flags

			// 6) float - additional "nonspace" delta
			// 7) float - additional "space" delta

			// 8) int32 - numChars
			// 9) int32 - numBytes
			// 10) char - the char buffer with size numBytes

			// Returns:
			// 1) float - escapement buffer with numChar entries
			
			uint16 famid, styid;
			uint32 flags;
			float ptsize, rotation;
			
			link.Read<uint16>(&famid);
			link.Read<uint16>(&styid);
			link.Read<float>(&ptsize);
			link.Read<float>(&rotation);
			link.Read<uint32>(&flags);

			escapement_delta delta;
			link.Read<float>(&delta.nonspace);
			link.Read<float>(&delta.space);
			
			int32 numChars;
			link.Read<int32>(&numChars);

			uint32 numBytes;
			link.Read<uint32>(&numBytes);

			char* charArray = new char[numBytes];
			link.Read(charArray, numBytes);

			float* escapements = new float[numChars];
			// figure out escapements

			ServerFont font;
			bool success = false;
			if (font.SetFamilyAndStyle(famid, styid) == B_OK) {
				font.SetSize(ptsize);
				font.SetRotation(rotation);
				font.SetFlags(flags);

				if (font.GetEscapements(charArray, numChars, escapements, delta)) {
					fLink.StartMessage(SERVER_TRUE);
					fLink.Attach(escapements, numChars * sizeof(float));
					success = true;
				}
			}

			delete[] charArray;
			delete[] escapements;

			if (!success)
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			break;
		}
		case AS_SCREEN_GET_MODE:
		{
			STRACE(("ServerApp %s: AS_SCREEN_GET_MODE\n", Signature()));
			// Attached data
			// 1) int32 port to reply to
			// 2) screen_id
			// 3) workspace index
			screen_id id;
			link.Read<screen_id>(&id);
			uint32 workspace;
			link.Read<uint32>(&workspace);

			// TODO: the display_mode can be different between
			// the various screens.
			// We have the screen_id and the workspace number, with these
			// we need to find the corresponding "driver", and call getmode on it
			display_mode mode;
			gDesktop->ScreenAt(0)->GetMode(&mode);
			// actually this isn't still enough as different workspaces can
			// have different display_modes

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<display_mode>(mode);
			fLink.Attach<status_t>(B_OK);
			fLink.Flush();
			break;
		}
		case AS_SCREEN_SET_MODE:
		{
			STRACE(("ServerApp %s: AS_SCREEN_SET_MODE\n", Signature()));
			// Attached data
			// 1) int32 port to reply to
			// 2) screen_id
			// 3) workspace index
			// 4) display_mode to set
			// 5) 'makedefault' boolean
			// TODO: See above: workspaces support, etc.

			screen_id id;
			link.Read<screen_id>(&id);

			uint32 workspace;
			link.Read<uint32>(&workspace);

			display_mode mode;
			link.Read<display_mode>(&mode);

			bool makedefault = false;
			link.Read<bool>(&makedefault);

// TODO: lock RootLayer, set mode and tell it to update it's frame and all clipping
// optionally put this into a message and let the root layer thread handle it.
//			status_t ret = gDesktop->ScreenAt(0)->SetMode(mode);
status_t ret = B_ERROR;

			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<status_t>(ret);
			fLink.Flush();
			break;
		}

		case AS_PROPOSE_MODE:
		{
			STRACE(("ServerApp %s: AS_PROPOSE_MODE\n", Signature()));
			screen_id id;
			link.Read<screen_id>(&id);

			display_mode target, low, high;
			link.Read<display_mode>(&target);
			link.Read<display_mode>(&low);
			link.Read<display_mode>(&high);
			status_t status = gDesktop->GetHWInterface()->ProposeMode(&target, &low, &high);
			// TODO: We always return SERVER_TRUE and put the real
			// error code in the message. FIX this.
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<display_mode>(target);
			fLink.Attach<status_t>(status);
			fLink.Flush();
						
			break;
		}
		
		case AS_GET_MODE_LIST:
		{
			display_mode* modeList;
			uint32 count;
			if (gDesktop->GetHWInterface()->GetModeList(&modeList, &count) == B_OK) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint32>(count);
				fLink.Attach(modeList, sizeof(display_mode) * count);

				delete[] modeList;
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			break;
		}

		case AS_SCREEN_GET_COLORMAP:
		{
			STRACE(("ServerApp %s: AS_SCREEN_GET_COLORMAP\n", Signature()));

			screen_id id;
			link.Read<screen_id>(&id);
			
			const color_map *colorMap = SystemColorMap();
			if (colorMap != NULL) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<color_map>(*colorMap);
			} else 
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
			break;
		}

		case AS_GET_DESKTOP_COLOR:
		{
			STRACE(("ServerApp %s: get desktop color\n", Signature()));

			int32 workspaceIndex = 0;
			link.Read<int32>(&workspaceIndex);

			// ToDo: for some reason, we currently get "1" as no. of workspace
			workspaceIndex = 0;

			// ToDo: locking is probably wrong - why the hell is there no (safe)
			//		way to get to the workspace object directly?
			RootLayer *root = gDesktop->ActiveRootLayer();
			root->Lock();

			Workspace *workspace = root->WorkspaceAt(workspaceIndex);
			if (workspace != NULL) {
				fLink.StartMessage(SERVER_TRUE);
				//rgb_color color;
				fLink.Attach<rgb_color>(workspace->BGColor().GetColor32());
			} else
				fLink.StartMessage(SERVER_FALSE);

			fLink.Flush();
			root->Unlock();
			break;
		}
		
		case AS_GET_ACCELERANT_INFO:
		{
			STRACE(("ServerApp %s: get accelerant info\n", Signature()));
			
			// We aren't using the screen_id for now...
			screen_id id;
			link.Read<screen_id>(&id);
			
			accelerant_device_info accelerantInfo;
			// TODO: I wonder if there should be a "desktop" lock...
			if (gDesktop->GetHWInterface()->GetDeviceInfo(&accelerantInfo) == B_OK) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<accelerant_device_info>(accelerantInfo);
			} else
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
			
			break;
		}
		
		case AS_GET_RETRACE_SEMAPHORE:
		{
			STRACE(("ServerApp %s: get retrace semaphore\n", Signature()));
			
			// We aren't using the screen_id for now...
			screen_id id;
			link.Read<screen_id>(&id);
			
			sem_id semaphore = gDesktop->GetHWInterface()->RetraceSemaphore();
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<sem_id>(semaphore);
			fLink.Flush();
			
			break;
		}
		
		case AS_GET_TIMING_CONSTRAINTS:
		{
			STRACE(("ServerApp %s: get timing constraints\n", Signature()));
			// We aren't using the screen_id for now...
			screen_id id;
			link.Read<screen_id>(&id);
			display_timing_constraints constraints;
			if (gDesktop->GetHWInterface()->GetTimingConstraints(&constraints) == B_OK) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<display_timing_constraints>(constraints);
			} else
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
				
			break;
		}
		
		case AS_GET_PIXEL_CLOCK_LIMITS:
		{
			STRACE(("ServerApp %s: get pixel clock limits\n", Signature()));
			// We aren't using the screen_id for now...
			screen_id id;
			link.Read<screen_id>(&id);
			display_mode mode;
			link.Read<display_mode>(&mode);
			
			uint32 low, high;
			if (gDesktop->GetHWInterface()->GetPixelClockLimits(&mode, &low, &high) == B_OK) {
				fLink.StartMessage(SERVER_TRUE);
				fLink.Attach<uint32>(low);
				fLink.Attach<uint32>(high);
			} else
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
			
			break;
		}
		
		case AS_SET_DPMS:
		{
			STRACE(("ServerApp %s: AS_SET_DPMS\n", Signature()));
			screen_id id;
			link.Read<screen_id>(&id);
			
			uint32 mode;
			link.Read<uint32>(&mode);
			
			if (gDesktop->GetHWInterface()->SetDPMSMode(mode) == B_OK)
				fLink.StartMessage(SERVER_TRUE);
			else
				fLink.StartMessage(SERVER_FALSE);
			
			fLink.Flush();
			
			break;
		}
		
		case AS_GET_DPMS_STATE:
		{
			STRACE(("ServerApp %s: AS_GET_DPMS_STATE\n", Signature()));
			
			screen_id id;
			link.Read<screen_id>(&id);
			
			uint32 state = gDesktop->GetHWInterface()->DPMSMode();
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<uint32>(state);
			fLink.Flush();
			
			break;
		}
				
		case AS_GET_DPMS_CAPABILITIES:
		{
			STRACE(("ServerApp %s: AS_GET_DPMS_CAPABILITIES\n", Signature()));
			screen_id id;
			link.Read<screen_id>(&id);
			
			uint32 capabilities = gDesktop->GetHWInterface()->DPMSCapabilities();
			fLink.StartMessage(SERVER_TRUE);
			fLink.Attach<uint32>(capabilities);
			fLink.Flush();
			break;
		}
			
		default:
			printf("ServerApp %s received unhandled message code offset %s\n",
				Signature(), MsgCodeToBString(code).String());

			if (link.NeedsReply()) {
				// the client is now blocking and waiting for a reply!
				fLink.StartMessage(SERVER_FALSE);
				fLink.Flush();
			} else
				puts("message doesn't need a reply!");
			break;
	}
}


void
ServerApp::RemoveWindow(ServerWindow* window)
{
	BAutolock locker(fWindowListLock);

	fWindowList.RemoveItem(window);
}


int32
ServerApp::CountBitmaps() const
{
	return fBitmapList.CountItems();
}


/*!
	\brief Looks up a ServerApp's ServerBitmap in its list
	\param token ID token of the bitmap to find
	\return The bitmap having that ID or NULL if not found
*/
ServerBitmap*
ServerApp::FindBitmap(int32 token) const
{
	int32 count = fBitmapList.CountItems();
	for (int32 i = 0; i < count; i++) {
		ServerBitmap* bitmap = (ServerBitmap*)fBitmapList.ItemAt(i);
		if (bitmap && bitmap->Token() == token)
			return bitmap;
	}

	return NULL;
}


int32
ServerApp::CountPictures() const
{
	return fPictureList.CountItems();
}


ServerPicture *
ServerApp::FindPicture(int32 token) const
{
	for (int32 i = 0; i < fPictureList.CountItems(); i++) {
		ServerPicture *picture = static_cast<ServerPicture *>(fPictureList.ItemAt(i));
		if (picture && picture->GetToken() == token)
			return picture;
	}
	
	return NULL;
}

	
team_id
ServerApp::ClientTeam() const
{
	return fClientTeam;
}


thread_id
ServerApp::Thread() const
{
	return fThread;
}