Moved functionality of PortLink into LinkMsg* to avoid serious code duplication in the app_server
git-svn-id: file:///srv/svn/repos/haiku/trunk/current@9335 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
DarkWyrm
@@ -0,0 +1,857 @@
|
||||
//------------------------------------------------------------------------------
|
||||
// Copyright (c) 2001-2002, Haiku, Inc.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person obtaining a
|
||||
// copy of this software and associated documentation files (the "Software"),
|
||||
// to deal in the Software without restriction, including without limitation
|
||||
// the rights to use, copy, modify, merge, publish, distribute, sublicense,
|
||||
// and/or sell copies of the Software, and to permit persons to whom the
|
||||
// Software is furnished to do so, subject to the following conditions:
|
||||
//
|
||||
// The above copyright notice and this permission notice shall be included in
|
||||
// all copies or substantial portions of the Software.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
||||
// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
// File Name: LinkMsgReader.cpp
|
||||
// Author: Pahtz <[email protected]>
|
||||
// Description: Class for receiving low-overhead port-based messages
|
||||
//
|
||||
//------------------------------------------------------------------------------
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#include <new>
|
||||
|
||||
#include <ServerProtocol.h>
|
||||
#include <LinkMsgReader.h>
|
||||
|
||||
//#define DEBUG_LINKMSGREADER
|
||||
#ifdef DEBUG_LINKMSGREADER
|
||||
# include <stdio.h>
|
||||
# define STRACE(x) printf x
|
||||
const char *strcode(int32 code);
|
||||
const char *bstrcode(int32 code);
|
||||
#else
|
||||
# define STRACE(x) ;
|
||||
#endif
|
||||
|
||||
static const int32 kInitialReceiveBufferSize = 2048;
|
||||
static const int32 kMaxReceiveBufferSize = 2048;
|
||||
//make the max receive buffer at least as large as max send
|
||||
|
||||
static const int32 kHeaderSize = sizeof(int32) * 3; //size + code + flags
|
||||
|
||||
LinkMsgReader::LinkMsgReader(port_id port) :
|
||||
fReceivePort(port), fRecvBuffer(NULL), fRecvPosition(0), fRecvStart(0),
|
||||
fRecvBufferSize(0), fDataSize(0),
|
||||
fReplySize(0), fReadError(B_OK)
|
||||
{
|
||||
/* */
|
||||
}
|
||||
|
||||
LinkMsgReader::~LinkMsgReader()
|
||||
{
|
||||
if (fRecvBuffer)
|
||||
free(fRecvBuffer);
|
||||
}
|
||||
|
||||
void LinkMsgReader::SetPort( port_id port )
|
||||
{
|
||||
fReceivePort=port;
|
||||
}
|
||||
|
||||
port_id LinkMsgReader::GetPort()
|
||||
{
|
||||
return fReceivePort;
|
||||
}
|
||||
|
||||
status_t LinkMsgReader::GetNextMessage(int32 *code, bigtime_t timeout)
|
||||
{
|
||||
int32 remaining;
|
||||
|
||||
fReadError = B_OK;
|
||||
|
||||
remaining = fDataSize - (fRecvStart + fReplySize);
|
||||
STRACE(("info: LinkMsgReader GetNextReply() reports %ld bytes remaining in buffer.\n", remaining));
|
||||
|
||||
//find the position of the next message header in the buffer
|
||||
int32 *header;
|
||||
if (remaining <= 0)
|
||||
{
|
||||
status_t err = ReadFromPort(timeout);
|
||||
if (err < B_OK)
|
||||
return err;
|
||||
remaining = fDataSize;
|
||||
header = (int32 *)fRecvBuffer;
|
||||
}
|
||||
else
|
||||
{
|
||||
fRecvStart += fReplySize; //start of the next message
|
||||
fRecvPosition = fRecvStart;
|
||||
header = (int32 *)(fRecvBuffer + fRecvStart);
|
||||
}
|
||||
|
||||
//check we have a well-formed message
|
||||
if (remaining < kHeaderSize)
|
||||
//we don't have enough data for a complete header
|
||||
{
|
||||
STRACE(("error info: LinkMsgReader remaining %ld bytes is less than header size.\n", remaining));
|
||||
ResetBuffer();
|
||||
return B_ERROR;
|
||||
}
|
||||
|
||||
fReplySize = *header; //size of the first message
|
||||
if (fReplySize > remaining || fReplySize < kHeaderSize)
|
||||
//the header info declares more data than we have OR
|
||||
//the header info declares less data than kHeaderSize
|
||||
{
|
||||
STRACE(("error info: LinkMsgReader message size of %ld bytes smaller than header size.\n", fReplySize));
|
||||
ResetBuffer();
|
||||
return B_ERROR;
|
||||
}
|
||||
|
||||
*code = *(++header);
|
||||
fRecvPosition += kHeaderSize; //size + code + flags
|
||||
|
||||
STRACE(("info: LinkMsgReader got header %s [%ld %ld %ld] from port %ld.\n", strcode(*code), fReplySize, *code, *(header + 1), fReceivePort));
|
||||
|
||||
return B_OK;
|
||||
}
|
||||
|
||||
void LinkMsgReader::ResetBuffer()
|
||||
{
|
||||
fRecvPosition = 0;
|
||||
fRecvStart = 0;
|
||||
fDataSize = 0;
|
||||
fReplySize = 0;
|
||||
}
|
||||
|
||||
status_t LinkMsgReader::AdjustReplyBuffer(bigtime_t timeout)
|
||||
{
|
||||
//Here we take advantage of the compiler's dead-code elimination
|
||||
if (kInitialReceiveBufferSize == kMaxReceiveBufferSize) //fixed buffer size
|
||||
{
|
||||
if (fRecvBuffer != NULL)
|
||||
return B_OK;
|
||||
|
||||
fRecvBuffer = (char *)malloc(kInitialReceiveBufferSize);
|
||||
if (fRecvBuffer == NULL)
|
||||
return B_NO_MEMORY;
|
||||
fRecvBufferSize = kInitialReceiveBufferSize;
|
||||
}
|
||||
else //if (kInitialReceiveBufferSize < kMaxReceiveBufferSize)
|
||||
{
|
||||
STRACE(("info: LinkMsgReader getting port_buffer_size().\n"));
|
||||
ssize_t buffersize;
|
||||
if (timeout == B_INFINITE_TIMEOUT)
|
||||
buffersize = port_buffer_size(fReceivePort);
|
||||
else
|
||||
buffersize = port_buffer_size_etc(fReceivePort, B_TIMEOUT, timeout);
|
||||
STRACE(("info: LinkMsgReader got port_buffer_size() = %ld.\n", buffersize));
|
||||
|
||||
if (buffersize < 0)
|
||||
return (status_t)buffersize;
|
||||
|
||||
//make sure our receive buffer is large enough
|
||||
if (buffersize > fRecvBufferSize)
|
||||
{
|
||||
if (buffersize <= kInitialReceiveBufferSize)
|
||||
buffersize = kInitialReceiveBufferSize;
|
||||
else
|
||||
buffersize = (buffersize + B_PAGE_SIZE) - (buffersize % B_PAGE_SIZE);
|
||||
if (buffersize > kMaxReceiveBufferSize)
|
||||
return B_ERROR; //we can't continue
|
||||
|
||||
STRACE(("info: LinkMsgReader setting receive buffersize to %ld.\n", buffersize));
|
||||
char *buffer = (char *)malloc(buffersize);
|
||||
if (buffer == NULL)
|
||||
return B_NO_MEMORY;
|
||||
if (fRecvBuffer)
|
||||
free(fRecvBuffer);
|
||||
fRecvBuffer = buffer;
|
||||
fRecvBufferSize = buffersize;
|
||||
}
|
||||
}
|
||||
|
||||
return B_OK;
|
||||
}
|
||||
|
||||
status_t LinkMsgReader::ReadFromPort(bigtime_t timeout)
|
||||
{
|
||||
//we are here so it means we finished reading the buffer contents
|
||||
ResetBuffer();
|
||||
|
||||
status_t err = AdjustReplyBuffer(timeout);
|
||||
if (err < B_OK)
|
||||
return err;
|
||||
|
||||
int32 protocol;
|
||||
ssize_t bytesread;
|
||||
STRACE(("info: LinkMsgReader reading port %ld.\n", fReceivePort));
|
||||
if (timeout != B_INFINITE_TIMEOUT)
|
||||
{
|
||||
do {
|
||||
bytesread = read_port_etc(fReceivePort, &protocol, fRecvBuffer,
|
||||
fRecvBufferSize, B_TIMEOUT, timeout);
|
||||
} while(bytesread == B_INTERRUPTED);
|
||||
}
|
||||
else
|
||||
{
|
||||
do {
|
||||
bytesread = read_port(fReceivePort, &protocol, fRecvBuffer,
|
||||
fRecvBufferSize);
|
||||
} while(bytesread == B_INTERRUPTED);
|
||||
}
|
||||
|
||||
STRACE(("info: LinkMsgReader read %ld bytes.\n", bytesread));
|
||||
if (bytesread < B_OK)
|
||||
return bytesread;
|
||||
|
||||
//TODO: we only need AS_SERVER_PORTLINK when all OBOS uses Link messages
|
||||
if (protocol != AS_SERVER_PORTLINK && protocol != AS_SERVER_SESSION)
|
||||
return B_ERROR;
|
||||
if (protocol == AS_SERVER_PORTLINK && bytesread != *((int32 *)fRecvBuffer))
|
||||
//should only be one message for PORTLINK so the size declared in the header
|
||||
//(the first int32 in the header) should be the same as bytesread
|
||||
return B_ERROR;
|
||||
|
||||
fDataSize = bytesread;
|
||||
return B_OK;
|
||||
}
|
||||
|
||||
status_t LinkMsgReader::Read(void *data, ssize_t size)
|
||||
{
|
||||
// STRACE(("info: LinkMsgReader Read()ing %ld bytes...\n", size));
|
||||
if (fReadError < B_OK)
|
||||
return fReadError;
|
||||
|
||||
if (size < 1)
|
||||
{
|
||||
fReadError = B_BAD_VALUE;
|
||||
return B_BAD_VALUE;
|
||||
}
|
||||
|
||||
if (fDataSize == 0 || fReplySize == 0)
|
||||
return B_NO_INIT; //need to call GetNextReply() first
|
||||
|
||||
if (fRecvPosition + size > fRecvStart + fReplySize)
|
||||
{
|
||||
//reading past the end of current message
|
||||
fReadError = B_BAD_VALUE;
|
||||
return B_BAD_VALUE;
|
||||
}
|
||||
|
||||
memcpy(data, fRecvBuffer + fRecvPosition, size);
|
||||
fRecvPosition += size;
|
||||
return fReadError;
|
||||
}
|
||||
|
||||
status_t LinkMsgReader::ReadString(char **string)
|
||||
{
|
||||
status_t err;
|
||||
int32 len = 0;
|
||||
|
||||
err = Read<int32>(&len);
|
||||
if (err < B_OK)
|
||||
return err;
|
||||
|
||||
if (len)
|
||||
{
|
||||
*string = (char *)malloc(len);
|
||||
if (*string == NULL)
|
||||
{
|
||||
fRecvPosition -= sizeof(int32); //rewind the transaction
|
||||
return B_NO_MEMORY;
|
||||
}
|
||||
|
||||
err = Read(*string, len);
|
||||
if (err < B_OK)
|
||||
{
|
||||
free(*string);
|
||||
*string = NULL;
|
||||
fRecvPosition -= sizeof(int32); //rewind the transaction
|
||||
return err;
|
||||
}
|
||||
(*string)[len-1] = '\0';
|
||||
return B_OK;
|
||||
}
|
||||
else
|
||||
{
|
||||
fRecvPosition -= sizeof(int32); //rewind the transaction
|
||||
return B_ERROR;
|
||||
}
|
||||
}
|
||||
|
||||
#ifdef DEBUG_LINKMSGREADER
|
||||
#include <ServerProtocol.h>
|
||||
#include <AppDefs.h>
|
||||
|
||||
static const char *kASCodeNames[] =
|
||||
{
|
||||
"SERVER_TRUE",
|
||||
"SERVER_FALSE",
|
||||
"AS_SERVER_BMESSAGE",
|
||||
"AS_SERVER_AREALINK",
|
||||
"AS_SERVER_SESSION",
|
||||
"AS_SERVER_PORTLINK",
|
||||
"AS_CLIENT_DEAD",
|
||||
"AS_CREATE_APP",
|
||||
"AS_DELETE_APP",
|
||||
"AS_QUIT_APP",
|
||||
"AS_SET_SERVER_PORT",
|
||||
"AS_CREATE_WINDOW",
|
||||
"AS_DELETE_WINDOW",
|
||||
"AS_CREATE_BITMAP",
|
||||
"AS_DELETE_BITMAP",
|
||||
"AS_SET_CURSOR_DATA",
|
||||
"AS_SET_CURSOR_BCURSOR",
|
||||
"AS_SET_CURSOR_BBITMAP",
|
||||
"AS_SET_CURSOR_SYSTEM",
|
||||
"AS_SET_SYSCURSOR_DATA",
|
||||
"AS_SET_SYSCURSOR_BCURSOR",
|
||||
"AS_SET_SYSCURSOR_BBITMAP",
|
||||
"AS_SET_SYSCURSOR_DEFAULTS",
|
||||
"AS_GET_SYSCURSOR",
|
||||
"AS_SHOW_CURSOR",
|
||||
"AS_HIDE_CURSOR",
|
||||
"AS_OBSCURE_CURSOR",
|
||||
"AS_QUERY_CURSOR_HIDDEN",
|
||||
"AS_CREATE_BCURSOR",
|
||||
"AS_DELETE_BCURSOR",
|
||||
"AS_BEGIN_RECT_TRACKING",
|
||||
"AS_END_RECT_TRACKING",
|
||||
"AS_SHOW_WINDOW",
|
||||
"AS_HIDE_WINDOW",
|
||||
"AS_QUIT_WINDOW",
|
||||
"AS_SEND_BEHIND",
|
||||
"AS_SET_LOOK",
|
||||
"AS_SET_FEEL",
|
||||
"AS_SET_FLAGS",
|
||||
"AS_DISABLE_UPDATES",
|
||||
"AS_ENABLE_UPDATES",
|
||||
"AS_BEGIN_UPDATE",
|
||||
"AS_END_UPDATE",
|
||||
"AS_NEEDS_UPDATE",
|
||||
"AS_WINDOW_TITLE",
|
||||
"AS_ADD_TO_SUBSET",
|
||||
"AS_REM_FROM_SUBSET",
|
||||
"AS_SET_ALIGNMENT",
|
||||
"AS_GET_ALIGNMENT",
|
||||
"AS_GET_WORKSPACES",
|
||||
"AS_SET_WORKSPACES",
|
||||
"AS_WINDOW_RESIZE",
|
||||
"AS_WINDOW_MOVE",
|
||||
"AS_SET_SIZE_LIMITS",
|
||||
"AS_ACTIVATE_WINDOW",
|
||||
"AS_WINDOW_MINIMIZE",
|
||||
"AS_UPDATE_IF_NEEDED",
|
||||
"_ALL_UPDATED_",
|
||||
"AS_CREATE_PICTURE",
|
||||
"AS_DELETE_PICTURE",
|
||||
"AS_CLONE_PICTURE",
|
||||
"AS_DOWNLOAD_PICTURE",
|
||||
"AS_QUERY_FONTS_CHANGED",
|
||||
"AS_UPDATED_CLIENT_FONTLIST",
|
||||
"AS_GET_FAMILY_ID",
|
||||
"AS_GET_STYLE_ID",
|
||||
"AS_GET_STYLE_FOR_FACE",
|
||||
"AS_GET_SCREEN_MODE",
|
||||
"AS_SET_UI_COLORS",
|
||||
"AS_GET_UI_COLORS",
|
||||
"AS_GET_UI_COLOR",
|
||||
"AS_SET_DECORATOR",
|
||||
"AS_GET_DECORATOR",
|
||||
"AS_R5_SET_DECORATOR",
|
||||
"AS_COUNT_WORKSPACES",
|
||||
"AS_SET_WORKSPACE_COUNT",
|
||||
"AS_CURRENT_WORKSPACE",
|
||||
"AS_ACTIVATE_WORKSPACE",
|
||||
"AS_SET_SCREEN_MODE",
|
||||
"AS_GET_SCROLLBAR_INFO",
|
||||
"AS_SET_SCROLLBAR_INFO",
|
||||
"AS_IDLE_TIME",
|
||||
"AS_SELECT_PRINTER_PANEL",
|
||||
"AS_ADD_PRINTER_PANEL",
|
||||
"AS_RUN_BE_ABOUT",
|
||||
"AS_SET_FOCUS_FOLLOWS_MOUSE",
|
||||
"AS_FOCUS_FOLLOWS_MOUSE",
|
||||
"AS_SET_MOUSE_MODE",
|
||||
"AS_GET_MOUSE_MODE",
|
||||
"AS_WORKSPACE_ACTIVATED",
|
||||
"AS_WORKSPACES_CHANGED",
|
||||
"AS_WINDOW_ACTIVATED",
|
||||
"AS_SCREENMODE_CHANGED",
|
||||
"AS_BEGIN_TRANSACTION",
|
||||
"AS_END_TRANSACTION",
|
||||
"AS_SET_HIGH_COLOR",
|
||||
"AS_SET_LOW_COLOR",
|
||||
"AS_SET_VIEW_COLOR",
|
||||
"AS_STROKE_ARC",
|
||||
"AS_STROKE_BEZIER",
|
||||
"AS_STROKE_ELLIPSE",
|
||||
"AS_STROKE_LINE",
|
||||
"AS_STROKE_LINEARRAY",
|
||||
"AS_STROKE_POLYGON",
|
||||
"AS_STROKE_RECT",
|
||||
"AS_STROKE_ROUNDRECT",
|
||||
"AS_STROKE_SHAPE",
|
||||
"AS_STROKE_TRIANGLE",
|
||||
"AS_FILL_ARC",
|
||||
"AS_FILL_BEZIER",
|
||||
"AS_FILL_ELLIPSE",
|
||||
"AS_FILL_POLYGON",
|
||||
"AS_FILL_RECT",
|
||||
"AS_FILL_REGION",
|
||||
"AS_FILL_ROUNDRECT",
|
||||
"AS_FILL_SHAPE",
|
||||
"AS_FILL_TRIANGLE",
|
||||
"AS_MOVEPENBY",
|
||||
"AS_MOVEPENTO",
|
||||
"AS_SETPENSIZE",
|
||||
"AS_DRAW_STRING",
|
||||
"AS_SET_FONT",
|
||||
"AS_SET_FONT_SIZE",
|
||||
"AS_FLUSH",
|
||||
"AS_SYNC",
|
||||
"AS_LAYER_CREATE",
|
||||
"AS_LAYER_DELETE",
|
||||
"AS_LAYER_CREATE_ROOT",
|
||||
"AS_LAYER_DELETE_ROOT",
|
||||
"AS_LAYER_ADD_CHILD",
|
||||
"AS_LAYER_REMOVE_CHILD",
|
||||
"AS_LAYER_REMOVE_SELF",
|
||||
"AS_LAYER_SHOW",
|
||||
"AS_LAYER_HIDE",
|
||||
"AS_LAYER_MOVE",
|
||||
"AS_LAYER_RESIZE",
|
||||
"AS_LAYER_INVALIDATE",
|
||||
"AS_LAYER_DRAW",
|
||||
"AS_LAYER_GET_TOKEN",
|
||||
"AS_LAYER_ADD",
|
||||
"AS_LAYER_REMOVE",
|
||||
"AS_LAYER_GET_COORD",
|
||||
"AS_LAYER_SET_FLAGS",
|
||||
"AS_LAYER_SET_ORIGIN",
|
||||
"AS_LAYER_GET_ORIGIN",
|
||||
"AS_LAYER_RESIZE_MODE",
|
||||
"AS_LAYER_CURSOR",
|
||||
"AS_LAYER_BEGIN_RECT_TRACK",
|
||||
"AS_LAYER_END_RECT_TRACK",
|
||||
"AS_LAYER_DRAG_RECT",
|
||||
"AS_LAYER_DRAG_IMAGE",
|
||||
"AS_LAYER_GET_MOUSE_COORDS",
|
||||
"AS_LAYER_SCROLL",
|
||||
"AS_LAYER_SET_LINE_MODE",
|
||||
"AS_LAYER_GET_LINE_MODE",
|
||||
"AS_LAYER_PUSH_STATE",
|
||||
"AS_LAYER_POP_STATE",
|
||||
"AS_LAYER_SET_SCALE",
|
||||
"AS_LAYER_GET_SCALE",
|
||||
"AS_LAYER_SET_DRAW_MODE",
|
||||
"AS_LAYER_GET_DRAW_MODE",
|
||||
"AS_LAYER_SET_BLEND_MODE",
|
||||
"AS_LAYER_GET_BLEND_MODE",
|
||||
"AS_LAYER_SET_PEN_LOC",
|
||||
"AS_LAYER_GET_PEN_LOC",
|
||||
"AS_LAYER_SET_PEN_SIZE",
|
||||
"AS_LAYER_GET_PEN_SIZE",
|
||||
"AS_LAYER_SET_HIGH_COLOR",
|
||||
"AS_LAYER_SET_LOW_COLOR",
|
||||
"AS_LAYER_SET_VIEW_COLOR",
|
||||
"AS_LAYER_GET_COLORS",
|
||||
"AS_LAYER_PRINT_ALIASING",
|
||||
"AS_LAYER_CLIP_TO_PICTURE",
|
||||
"AS_LAYER_CLIP_TO_INVERSE_PICTURE",
|
||||
"AS_LAYER_GET_CLIP_REGION",
|
||||
"AS_LAYER_DRAW_BITMAP_ASYNC_IN_RECT",
|
||||
"AS_LAYER_DRAW_BITMAP_ASYNC_AT_POINT",
|
||||
"AS_LAYER_DRAW_BITMAP_SYNC_IN_RECT",
|
||||
"AS_LAYER_DRAW_BITMAP_SYNC_AT_POINT",
|
||||
"AS_LAYER_DRAW_STRING",
|
||||
"AS_LAYER_SET_CLIP_REGION",
|
||||
"AS_LAYER_LINE_ARRAY",
|
||||
"AS_LAYER_BEGIN_PICTURE",
|
||||
"AS_LAYER_APPEND_TO_PICTURE",
|
||||
"AS_LAYER_END_PICTURE",
|
||||
"AS_LAYER_COPY_BITS",
|
||||
"AS_LAYER_DRAW_PICTURE",
|
||||
"AS_LAYER_INVAL_RECT",
|
||||
"AS_LAYER_INVAL_REGION",
|
||||
"AS_LAYER_INVERT_RECT",
|
||||
"AS_LAYER_MOVETO",
|
||||
"AS_LAYER_RESIZETO",
|
||||
"AS_LAYER_SET_STATE",
|
||||
"AS_LAYER_SET_FONT_STATE",
|
||||
"AS_LAYER_GET_STATE",
|
||||
"AS_LAYER_SET_VIEW_IMAGE",
|
||||
"AS_LAYER_SET_PATTERN",
|
||||
"AS_SET_CURRENT_LAYER",
|
||||
};
|
||||
|
||||
const char *strcode(int32 code)
|
||||
{
|
||||
code = code - SERVER_TRUE;
|
||||
if (code >= 0 && code <= AS_SET_CURRENT_LAYER - SERVER_TRUE)
|
||||
return kASCodeNames[code];
|
||||
else
|
||||
return bstrcode(code);
|
||||
}
|
||||
|
||||
const char *bstrcode(int32 code)
|
||||
{
|
||||
switch(code)
|
||||
{
|
||||
case B_ABOUT_REQUESTED:
|
||||
{
|
||||
return "B_ABOUT_REQUESTED";
|
||||
}
|
||||
case B_APP_ACTIVATED:
|
||||
{
|
||||
return "B_APP_ACTIVATED/B_WINDOW_ACTIVATED";
|
||||
}
|
||||
case B_ARGV_RECEIVED :
|
||||
{
|
||||
return "B_ARGV_RECEIVED";
|
||||
}
|
||||
case B_QUIT_REQUESTED :
|
||||
{
|
||||
return "B_QUIT_REQUESTED";
|
||||
}
|
||||
case B_CANCEL:
|
||||
{
|
||||
return "B_CANCEL";
|
||||
}
|
||||
case B_KEY_DOWN :
|
||||
{
|
||||
return "B_KEY_DOWN";
|
||||
}
|
||||
case B_KEY_UP :
|
||||
{
|
||||
return "B_KEY_UP";
|
||||
}
|
||||
case B_UNMAPPED_KEY_DOWN :
|
||||
{
|
||||
return "B_UNMAPPED_KEY_DOWN";
|
||||
}
|
||||
case B_UNMAPPED_KEY_UP :
|
||||
{
|
||||
return "B_UNMAPPED_KEY_UP";
|
||||
}
|
||||
case B_MODIFIERS_CHANGED:
|
||||
{
|
||||
return "B_MODIFIERS_CHANGED";
|
||||
}
|
||||
case B_MINIMIZE:
|
||||
{
|
||||
return "B_MINIMIZE";
|
||||
}
|
||||
case B_MOUSE_DOWN :
|
||||
{
|
||||
return "B_MOUSE_DOWN";
|
||||
}
|
||||
case B_MOUSE_MOVED :
|
||||
{
|
||||
return "B_MOUSE_MOVED";
|
||||
}
|
||||
case B_MOUSE_ENTER_EXIT:
|
||||
{
|
||||
return "B_MOUSE_ENTER_EXIT";
|
||||
}
|
||||
case B_MOUSE_UP :
|
||||
{
|
||||
return "B_MOUSE_UP";
|
||||
}
|
||||
case B_MOUSE_WHEEL_CHANGED:
|
||||
{
|
||||
return "B_MOUSE_WHEEL_CHANGED";
|
||||
}
|
||||
case B_OPEN_IN_WORKSPACE:
|
||||
{
|
||||
return "B_OPEN_IN_WORKSPACE";
|
||||
}
|
||||
case B_PRINTER_CHANGED:
|
||||
{
|
||||
return "B_PRINTER_CHANGED";
|
||||
}
|
||||
case B_PULSE :
|
||||
{
|
||||
return "B_PULSE";
|
||||
}
|
||||
case B_READY_TO_RUN :
|
||||
{
|
||||
return "B_READY_TO_RUN";
|
||||
}
|
||||
case B_REFS_RECEIVED :
|
||||
{
|
||||
return "B_REFS_RECEIVED";
|
||||
}
|
||||
case B_RELEASE_OVERLAY_LOCK:
|
||||
{
|
||||
return "B_RELEASE_OVERLAY_LOCK";
|
||||
}
|
||||
case B_ACQUIRE_OVERLAY_LOCK:
|
||||
{
|
||||
return "B_ACQUIRE_OVERLAY_LOCK";
|
||||
}
|
||||
case B_SCREEN_CHANGED :
|
||||
{
|
||||
return "B_SCREEN_CHANGED";
|
||||
}
|
||||
case B_VALUE_CHANGED :
|
||||
{
|
||||
return "B_VALUE_CHANGED";
|
||||
}
|
||||
case B_VIEW_MOVED :
|
||||
{
|
||||
return "B_VIEW_MOVED";
|
||||
}
|
||||
case B_VIEW_RESIZED :
|
||||
{
|
||||
return "B_VIEW_RESIZED";
|
||||
}
|
||||
case B_WINDOW_MOVED :
|
||||
{
|
||||
return "B_WINDOW_MOVED";
|
||||
}
|
||||
case B_WINDOW_RESIZED :
|
||||
{
|
||||
return "B_WINDOW_RESIZED";
|
||||
}
|
||||
case B_WORKSPACES_CHANGED:
|
||||
{
|
||||
return "B_WORKSPACES_CHANGED";
|
||||
}
|
||||
case B_WORKSPACE_ACTIVATED:
|
||||
{
|
||||
return "B_WORKSPACE_ACTIVATED";
|
||||
}
|
||||
case B_ZOOM:
|
||||
{
|
||||
return "B_ZOOM";
|
||||
}
|
||||
case _APP_MENU_:
|
||||
{
|
||||
return "_APP_MENU";
|
||||
}
|
||||
case _BROWSER_MENUS_:
|
||||
{
|
||||
return "_BROWSER_MENUS_";
|
||||
}
|
||||
case _MENU_EVENT_ :
|
||||
{
|
||||
return "_MENU_EVENT";
|
||||
}
|
||||
case _PING_:
|
||||
{
|
||||
return "_PING_";
|
||||
}
|
||||
case _QUIT_ :
|
||||
{
|
||||
return "_QUIT_";
|
||||
}
|
||||
case _VOLUME_MOUNTED_ :
|
||||
{
|
||||
return "_VOLUME_MOUNTED";
|
||||
}
|
||||
case _VOLUME_UNMOUNTED_:
|
||||
{
|
||||
return "_VOLUME_UNMOUNTED";
|
||||
}
|
||||
case _MESSAGE_DROPPED_ :
|
||||
{
|
||||
return "_MESSAGE_DROPPED";
|
||||
}
|
||||
case _DISPOSE_DRAG_ :
|
||||
{
|
||||
return "_DISPOSE_DRAG";
|
||||
}
|
||||
case _MENUS_DONE_:
|
||||
{
|
||||
return "_MENUS_DONE_";
|
||||
}
|
||||
case _SHOW_DRAG_HANDLES_:
|
||||
{
|
||||
return "_SHOW_DRAG_HANDLES_";
|
||||
}
|
||||
case _EVENTS_PENDING_ :
|
||||
{
|
||||
return "_EVENTS_PENDING_";
|
||||
}
|
||||
case _UPDATE_ :
|
||||
{
|
||||
return "_UPDATE_";
|
||||
}
|
||||
case _UPDATE_IF_NEEDED_:
|
||||
{
|
||||
return "_UPDATE_IF_NEEDED_";
|
||||
}
|
||||
case _PRINTER_INFO_:
|
||||
{
|
||||
return "_PRINTER_INFO_";
|
||||
}
|
||||
case _SETUP_PRINTER_:
|
||||
{
|
||||
return "_SETUP_PRINTER_";
|
||||
}
|
||||
case _SELECT_PRINTER_:
|
||||
{
|
||||
return "_SELECT_PRINTER_";
|
||||
}
|
||||
case B_SET_PROPERTY:
|
||||
{
|
||||
return "B_SET_PROPERTY";
|
||||
}
|
||||
case B_GET_PROPERTY:
|
||||
{
|
||||
return "B_GET_PROERTY";
|
||||
}
|
||||
case B_CREATE_PROPERTY:
|
||||
{
|
||||
return "B_CREATE_PROPERTY";
|
||||
}
|
||||
case B_DELETE_PROPERTY:
|
||||
{
|
||||
return "B_DELETE_PROPERTY";
|
||||
}
|
||||
case B_COUNT_PROPERTIES:
|
||||
{
|
||||
return "B_COUNT_PROPERTIES";
|
||||
}
|
||||
case B_EXECUTE_PROPERTY:
|
||||
{
|
||||
return "B_EXECUTE_PROPERTY";
|
||||
}
|
||||
case B_GET_SUPPORTED_SUITES:
|
||||
{
|
||||
return "B_GET_SUPPORTED_SUITES";
|
||||
}
|
||||
case B_UNDO:
|
||||
{
|
||||
return "B_UNDO";
|
||||
}
|
||||
case B_CUT :
|
||||
{
|
||||
return "B_CUT";
|
||||
}
|
||||
case B_COPY :
|
||||
{
|
||||
return "B_COPY";
|
||||
}
|
||||
case B_PASTE :
|
||||
{
|
||||
return "B_PASTE";
|
||||
}
|
||||
case B_SELECT_ALL:
|
||||
{
|
||||
return "B_SELECT_ALL";
|
||||
}
|
||||
case B_SAVE_REQUESTED :
|
||||
{
|
||||
return "B_SAVE_REQUESTED";
|
||||
}
|
||||
case B_MESSAGE_NOT_UNDERSTOOD:
|
||||
{
|
||||
return "B_MESSAGE_NOT_UNDERSTOOD";
|
||||
}
|
||||
case B_NO_REPLY :
|
||||
{
|
||||
return "B_NO_REPLY";
|
||||
}
|
||||
case B_REPLY :
|
||||
{
|
||||
return "B_REPLY";
|
||||
}
|
||||
case B_SIMPLE_DATA:
|
||||
{
|
||||
return "B_SIMPLE_DATA";
|
||||
}
|
||||
case B_MIME_DATA:
|
||||
{
|
||||
return "B_MIME_DATA";
|
||||
}
|
||||
case B_ARCHIVED_OBJECT:
|
||||
{
|
||||
return "B_ARCHIVED_OBJECT";
|
||||
}
|
||||
case B_UPDATE_STATUS_BAR:
|
||||
{
|
||||
return "B_UPDATE_STATUS_BAR";
|
||||
}
|
||||
case B_RESET_STATUS_BAR:
|
||||
{
|
||||
return "B_RESET_STATUS_BAR";
|
||||
}
|
||||
case B_NODE_MONITOR:
|
||||
{
|
||||
return "B_NODE_MONITOR";
|
||||
}
|
||||
case B_QUERY_UPDATE:
|
||||
{
|
||||
return "B_QUERY_UPDATE";
|
||||
}
|
||||
case B_ENDORSABLE:
|
||||
{
|
||||
return "B_ENDORSABLE";
|
||||
}
|
||||
case B_COPY_TARGET:
|
||||
{
|
||||
return "B_COPY_TARGET";
|
||||
}
|
||||
case B_MOVE_TARGET:
|
||||
{
|
||||
return "B_MOVE_TARGET";
|
||||
}
|
||||
case B_TRASH_TARGET:
|
||||
{
|
||||
return "B_TRASH_TARGET";
|
||||
}
|
||||
case B_LINK_TARGET:
|
||||
{
|
||||
return "B_LINK_TARGET";
|
||||
}
|
||||
case B_INPUT_DEVICES_CHANGED:
|
||||
{
|
||||
return "B_INPUT_DEVICES_CHANGED";
|
||||
}
|
||||
case B_INPUT_METHOD_EVENT:
|
||||
{
|
||||
return "B_INPUT_METHOD_EVENT";
|
||||
}
|
||||
case B_WINDOW_MOVE_TO:
|
||||
{
|
||||
return "B_WINDOW_MOVE_TO";
|
||||
}
|
||||
case B_WINDOW_MOVE_BY:
|
||||
{
|
||||
return "B_WINDOW_MOVE_BY";
|
||||
}
|
||||
case B_SILENT_RELAUNCH:
|
||||
{
|
||||
return "B_SILENT_RELAUNCH";
|
||||
}
|
||||
case B_OBSERVER_NOTICE_CHANGE :
|
||||
{
|
||||
return "B_OBSERVER_NOTICE_CHANGE";
|
||||
}
|
||||
case B_CONTROL_INVOKED:
|
||||
{
|
||||
return "B_CONTROL_INVOKED";
|
||||
}
|
||||
case B_CONTROL_MODIFIED:
|
||||
{
|
||||
return "B_CONTROL_MODIFIED";
|
||||
}
|
||||
default:
|
||||
{
|
||||
return "Unknown";
|
||||
}
|
||||
}
|
||||
}
|
||||
#endif //DEBUG_BPORTLINK
|
||||
|
||||
@@ -0,0 +1,847 @@
|
||||
//------------------------------------------------------------------------------
|
||||
// Copyright (c) 2001-2002, Haiku, Inc.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person obtaining a
|
||||
// copy of this software and associated documentation files (the "Software"),
|
||||
// to deal in the Software without restriction, including without limitation
|
||||
// the rights to use, copy, modify, merge, publish, distribute, sublicense,
|
||||
// and/or sell copies of the Software, and to permit persons to whom the
|
||||
// Software is furnished to do so, subject to the following conditions:
|
||||
//
|
||||
// The above copyright notice and this permission notice shall be included in
|
||||
// all copies or substantial portions of the Software.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
||||
// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
// File Name: LinkMsgSender.cpp
|
||||
// Author: Pahtz <[email protected]>
|
||||
// Description: Class for low-overhead port-based messaging
|
||||
//
|
||||
//------------------------------------------------------------------------------
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#include <new>
|
||||
|
||||
#include <ServerProtocol.h>
|
||||
#include <LinkMsgSender.h>
|
||||
|
||||
//#define DEBUG_LINKMSGSENDER
|
||||
#ifdef DEBUG_LINKMSGSENDER
|
||||
# include <stdio.h>
|
||||
# define STRACE(x) printf x
|
||||
const char *strcode(int32 code);
|
||||
const char *bstrcode(int32 code);
|
||||
#else
|
||||
# define STRACE(x) ;
|
||||
#endif
|
||||
|
||||
//set Initial==Max for a fixed buffer size
|
||||
static const int32 kInitialSendBufferSize = 2048;
|
||||
static const int32 kMaxSendBufferSize = 2048;
|
||||
|
||||
static const int32 kHeaderSize = sizeof(int32) * 3; //size + code + flags
|
||||
|
||||
LinkMsgSender::LinkMsgSender(port_id send) :
|
||||
fSendPort(send), fSendBuffer(NULL), fSendPosition(0), fSendStart(0),
|
||||
fSendBufferSize(0), fSendCount(0), fDataSize(0),
|
||||
fReplySize(0), fWriteError(B_OK)
|
||||
{
|
||||
/* */
|
||||
}
|
||||
|
||||
LinkMsgSender::~LinkMsgSender()
|
||||
{
|
||||
if (fSendBuffer)
|
||||
free(fSendBuffer);
|
||||
}
|
||||
|
||||
status_t LinkMsgSender::StartMessage(int32 code)
|
||||
{
|
||||
if (EndMessage() < B_OK) //end previous message
|
||||
CancelMessage(); //abandon previous message
|
||||
|
||||
if (fSendBufferSize == 0)
|
||||
{
|
||||
fSendBuffer = (char *)malloc(kInitialSendBufferSize);
|
||||
if (fSendBuffer == NULL)
|
||||
{
|
||||
fWriteError = B_NO_MEMORY;
|
||||
return B_NO_MEMORY;
|
||||
}
|
||||
fSendBufferSize = kInitialSendBufferSize;
|
||||
}
|
||||
|
||||
status_t err;
|
||||
//must have space for at least size + code + flags
|
||||
if (fSendBufferSize - fSendPosition < kHeaderSize)
|
||||
{
|
||||
err = Flush(); //will set fSendPosition and fSendStart to 0
|
||||
if (err < B_OK)
|
||||
return err;
|
||||
}
|
||||
|
||||
int32 *p = (int32 *)(fSendBuffer + fSendStart); //start of current message
|
||||
*p = 0; //size
|
||||
*(++p) = code; //code
|
||||
*(++p) = 0; //flags
|
||||
fSendPosition += kHeaderSize; //size + code + flags
|
||||
|
||||
STRACE(("info: LinkMsgSender buffered header %s [%ld %ld %ld].\n", strcode(code), (int32)0, *(p-1), *p));
|
||||
|
||||
return B_OK;
|
||||
}
|
||||
|
||||
status_t LinkMsgSender::EndMessage()
|
||||
{
|
||||
if (fSendPosition == fSendStart || fWriteError < B_OK)
|
||||
return fWriteError;
|
||||
|
||||
int32 *p = (int32 *)(fSendBuffer + fSendStart); //start of the message
|
||||
*p = fSendPosition - fSendStart; //record the size of the message
|
||||
fSendCount++; //increase the number of completed messages
|
||||
|
||||
fSendStart = fSendPosition; //start of next new message
|
||||
|
||||
return B_OK;
|
||||
STRACE(("info: LinkMsgSender EndMessage() of size %ld.\n", *p));
|
||||
}
|
||||
|
||||
void LinkMsgSender::CancelMessage()
|
||||
{
|
||||
fSendPosition = fSendStart;
|
||||
fWriteError = B_OK;
|
||||
}
|
||||
|
||||
status_t LinkMsgSender::Attach(const void *data, ssize_t size)
|
||||
{
|
||||
if (fWriteError < B_OK)
|
||||
return fWriteError;
|
||||
|
||||
if (size <= 0)
|
||||
{
|
||||
fWriteError = B_BAD_VALUE;
|
||||
return B_BAD_VALUE;
|
||||
}
|
||||
|
||||
if (fSendPosition == fSendStart)
|
||||
return B_NO_INIT; //need to call StartMessage() first
|
||||
|
||||
int32 remaining = fSendBufferSize - fSendPosition;
|
||||
if (remaining < size) //we have to make space for the data
|
||||
{
|
||||
int32 total = size + (fSendPosition - fSendStart);
|
||||
//resulting size of current message
|
||||
|
||||
int32 newbuffersize;
|
||||
if (total <= fSendBufferSize)
|
||||
newbuffersize = fSendBufferSize; //no change
|
||||
else if (total > kMaxSendBufferSize)
|
||||
{
|
||||
fWriteError = B_BAD_VALUE;
|
||||
return B_BAD_VALUE;
|
||||
}
|
||||
else if (total <= kInitialSendBufferSize)
|
||||
newbuffersize = kInitialSendBufferSize;
|
||||
else
|
||||
newbuffersize = (total + B_PAGE_SIZE) - (total % B_PAGE_SIZE);
|
||||
|
||||
//FlushCompleted() to make space
|
||||
status_t err;
|
||||
err = FlushCompleted(newbuffersize);
|
||||
if (err < B_OK)
|
||||
{
|
||||
fWriteError = err;
|
||||
return err;
|
||||
}
|
||||
}
|
||||
|
||||
memcpy(fSendBuffer + fSendPosition, data, size);
|
||||
fSendPosition += size;
|
||||
return fWriteError;
|
||||
}
|
||||
|
||||
status_t LinkMsgSender::FlushCompleted(ssize_t newbuffersize)
|
||||
{
|
||||
char *buffer = NULL;
|
||||
if (newbuffersize == fSendBufferSize)
|
||||
buffer = fSendBuffer; //keep existing buffer
|
||||
else
|
||||
{
|
||||
//create new larger buffer
|
||||
buffer = (char *)malloc(newbuffersize);
|
||||
if (buffer == NULL)
|
||||
return B_NO_MEMORY;
|
||||
}
|
||||
|
||||
int32 position = fSendPosition;
|
||||
int32 start = fSendStart;
|
||||
fSendPosition = fSendStart; //trick to hide the incomplete message
|
||||
|
||||
status_t err;
|
||||
err = Flush();
|
||||
if (err < B_OK)
|
||||
{
|
||||
fSendPosition = position;
|
||||
if (buffer != fSendBuffer)
|
||||
free(buffer);
|
||||
return err;
|
||||
}
|
||||
|
||||
//move the incomplete message to the start of the buffer
|
||||
fSendPosition = min_c(position - start, newbuffersize);
|
||||
memcpy(buffer, fSendBuffer + start, fSendPosition);
|
||||
|
||||
if (fSendBuffer != buffer)
|
||||
{
|
||||
free(fSendBuffer);
|
||||
fSendBuffer = buffer;
|
||||
fSendBufferSize = newbuffersize;
|
||||
}
|
||||
|
||||
return B_OK;
|
||||
}
|
||||
|
||||
|
||||
void LinkMsgSender::SetPort( port_id port )
|
||||
{
|
||||
fSendPort=port;
|
||||
}
|
||||
|
||||
port_id LinkMsgSender::GetPort()
|
||||
{
|
||||
return fSendPort;
|
||||
}
|
||||
|
||||
status_t LinkMsgSender::Flush(bigtime_t timeout)
|
||||
{
|
||||
if (fWriteError < B_OK)
|
||||
return fWriteError;
|
||||
|
||||
EndMessage();
|
||||
if (fSendCount == 0)
|
||||
return B_OK;
|
||||
|
||||
STRACE(("info: LinkMsgSender Flush() waiting to send %ld messages of %ld bytes on port %ld.\n", fSendCount, fSendPosition, fSendPort));
|
||||
|
||||
//TODO: we only need AS_SERVER_PORTLINK when all OBOS uses LinkMsgSender
|
||||
int32 protocol = (fSendCount > 1 ? AS_SERVER_SESSION : AS_SERVER_PORTLINK);
|
||||
|
||||
status_t err;
|
||||
if(timeout != B_INFINITE_TIMEOUT)
|
||||
{
|
||||
do {
|
||||
err = write_port_etc(fSendPort, protocol, fSendBuffer,
|
||||
fSendPosition, B_RELATIVE_TIMEOUT, timeout);
|
||||
} while(err == B_INTERRUPTED);
|
||||
}
|
||||
else
|
||||
{
|
||||
do {
|
||||
err = write_port(fSendPort, protocol, fSendBuffer, fSendPosition);
|
||||
} while(err == B_INTERRUPTED);
|
||||
}
|
||||
|
||||
if (err == B_OK)
|
||||
{
|
||||
STRACE(("info: LinkMsgSender Flush() %ld messages total of %ld bytes on port %ld.\n", fSendCount, fSendPosition, fSendPort));
|
||||
fSendPosition = 0;
|
||||
fSendStart = 0;
|
||||
fSendCount = 0;
|
||||
return B_OK;
|
||||
}
|
||||
|
||||
STRACE(("error info: LinkMsgSender Flush() failed for %ld bytes (%s) on port %ld.\n", fSendPosition, strerror(err), fSendPort));
|
||||
return err;
|
||||
}
|
||||
|
||||
status_t LinkMsgSender::AttachString(const char *string)
|
||||
{
|
||||
status_t err;
|
||||
if (string == NULL)
|
||||
return B_BAD_VALUE;
|
||||
|
||||
int32 len = strlen(string)+1;
|
||||
err = Attach<int32>(len);
|
||||
if (err < B_OK)
|
||||
return err;
|
||||
|
||||
err = Attach(string, len);
|
||||
if (err < B_OK)
|
||||
fSendPosition -= sizeof(int32); //rewind the transaction
|
||||
|
||||
return err;
|
||||
}
|
||||
|
||||
#ifdef DEBUG_BPORTLINK
|
||||
#include <ServerProtocol.h>
|
||||
#include <AppDefs.h>
|
||||
|
||||
static const char *kASCodeNames[] =
|
||||
{
|
||||
"SERVER_TRUE",
|
||||
"SERVER_FALSE",
|
||||
"AS_SERVER_BMESSAGE",
|
||||
"AS_SERVER_AREALINK",
|
||||
"AS_SERVER_SESSION",
|
||||
"AS_SERVER_PORTLINK",
|
||||
"AS_CLIENT_DEAD",
|
||||
"AS_CREATE_APP",
|
||||
"AS_DELETE_APP",
|
||||
"AS_QUIT_APP",
|
||||
"AS_SET_SERVER_PORT",
|
||||
"AS_CREATE_WINDOW",
|
||||
"AS_DELETE_WINDOW",
|
||||
"AS_CREATE_BITMAP",
|
||||
"AS_DELETE_BITMAP",
|
||||
"AS_SET_CURSOR_DATA",
|
||||
"AS_SET_CURSOR_BCURSOR",
|
||||
"AS_SET_CURSOR_BBITMAP",
|
||||
"AS_SET_CURSOR_SYSTEM",
|
||||
"AS_SET_SYSCURSOR_DATA",
|
||||
"AS_SET_SYSCURSOR_BCURSOR",
|
||||
"AS_SET_SYSCURSOR_BBITMAP",
|
||||
"AS_SET_SYSCURSOR_DEFAULTS",
|
||||
"AS_GET_SYSCURSOR",
|
||||
"AS_SHOW_CURSOR",
|
||||
"AS_HIDE_CURSOR",
|
||||
"AS_OBSCURE_CURSOR",
|
||||
"AS_QUERY_CURSOR_HIDDEN",
|
||||
"AS_CREATE_BCURSOR",
|
||||
"AS_DELETE_BCURSOR",
|
||||
"AS_BEGIN_RECT_TRACKING",
|
||||
"AS_END_RECT_TRACKING",
|
||||
"AS_SHOW_WINDOW",
|
||||
"AS_HIDE_WINDOW",
|
||||
"AS_QUIT_WINDOW",
|
||||
"AS_SEND_BEHIND",
|
||||
"AS_SET_LOOK",
|
||||
"AS_SET_FEEL",
|
||||
"AS_SET_FLAGS",
|
||||
"AS_DISABLE_UPDATES",
|
||||
"AS_ENABLE_UPDATES",
|
||||
"AS_BEGIN_UPDATE",
|
||||
"AS_END_UPDATE",
|
||||
"AS_NEEDS_UPDATE",
|
||||
"AS_WINDOW_TITLE",
|
||||
"AS_ADD_TO_SUBSET",
|
||||
"AS_REM_FROM_SUBSET",
|
||||
"AS_SET_ALIGNMENT",
|
||||
"AS_GET_ALIGNMENT",
|
||||
"AS_GET_WORKSPACES",
|
||||
"AS_SET_WORKSPACES",
|
||||
"AS_WINDOW_RESIZE",
|
||||
"AS_WINDOW_MOVE",
|
||||
"AS_SET_SIZE_LIMITS",
|
||||
"AS_ACTIVATE_WINDOW",
|
||||
"AS_WINDOW_MINIMIZE",
|
||||
"AS_UPDATE_IF_NEEDED",
|
||||
"_ALL_UPDATED_",
|
||||
"AS_CREATE_PICTURE",
|
||||
"AS_DELETE_PICTURE",
|
||||
"AS_CLONE_PICTURE",
|
||||
"AS_DOWNLOAD_PICTURE",
|
||||
"AS_QUERY_FONTS_CHANGED",
|
||||
"AS_UPDATED_CLIENT_FONTLIST",
|
||||
"AS_GET_FAMILY_ID",
|
||||
"AS_GET_STYLE_ID",
|
||||
"AS_GET_STYLE_FOR_FACE",
|
||||
"AS_GET_SCREEN_MODE",
|
||||
"AS_SET_UI_COLORS",
|
||||
"AS_GET_UI_COLORS",
|
||||
"AS_GET_UI_COLOR",
|
||||
"AS_SET_DECORATOR",
|
||||
"AS_GET_DECORATOR",
|
||||
"AS_R5_SET_DECORATOR",
|
||||
"AS_COUNT_WORKSPACES",
|
||||
"AS_SET_WORKSPACE_COUNT",
|
||||
"AS_CURRENT_WORKSPACE",
|
||||
"AS_ACTIVATE_WORKSPACE",
|
||||
"AS_SET_SCREEN_MODE",
|
||||
"AS_GET_SCROLLBAR_INFO",
|
||||
"AS_SET_SCROLLBAR_INFO",
|
||||
"AS_IDLE_TIME",
|
||||
"AS_SELECT_PRINTER_PANEL",
|
||||
"AS_ADD_PRINTER_PANEL",
|
||||
"AS_RUN_BE_ABOUT",
|
||||
"AS_SET_FOCUS_FOLLOWS_MOUSE",
|
||||
"AS_FOCUS_FOLLOWS_MOUSE",
|
||||
"AS_SET_MOUSE_MODE",
|
||||
"AS_GET_MOUSE_MODE",
|
||||
"AS_WORKSPACE_ACTIVATED",
|
||||
"AS_WORKSPACES_CHANGED",
|
||||
"AS_WINDOW_ACTIVATED",
|
||||
"AS_SCREENMODE_CHANGED",
|
||||
"AS_BEGIN_TRANSACTION",
|
||||
"AS_END_TRANSACTION",
|
||||
"AS_SET_HIGH_COLOR",
|
||||
"AS_SET_LOW_COLOR",
|
||||
"AS_SET_VIEW_COLOR",
|
||||
"AS_STROKE_ARC",
|
||||
"AS_STROKE_BEZIER",
|
||||
"AS_STROKE_ELLIPSE",
|
||||
"AS_STROKE_LINE",
|
||||
"AS_STROKE_LINEARRAY",
|
||||
"AS_STROKE_POLYGON",
|
||||
"AS_STROKE_RECT",
|
||||
"AS_STROKE_ROUNDRECT",
|
||||
"AS_STROKE_SHAPE",
|
||||
"AS_STROKE_TRIANGLE",
|
||||
"AS_FILL_ARC",
|
||||
"AS_FILL_BEZIER",
|
||||
"AS_FILL_ELLIPSE",
|
||||
"AS_FILL_POLYGON",
|
||||
"AS_FILL_RECT",
|
||||
"AS_FILL_REGION",
|
||||
"AS_FILL_ROUNDRECT",
|
||||
"AS_FILL_SHAPE",
|
||||
"AS_FILL_TRIANGLE",
|
||||
"AS_MOVEPENBY",
|
||||
"AS_MOVEPENTO",
|
||||
"AS_SETPENSIZE",
|
||||
"AS_DRAW_STRING",
|
||||
"AS_SET_FONT",
|
||||
"AS_SET_FONT_SIZE",
|
||||
"AS_FLUSH",
|
||||
"AS_SYNC",
|
||||
"AS_LAYER_CREATE",
|
||||
"AS_LAYER_DELETE",
|
||||
"AS_LAYER_CREATE_ROOT",
|
||||
"AS_LAYER_DELETE_ROOT",
|
||||
"AS_LAYER_ADD_CHILD",
|
||||
"AS_LAYER_REMOVE_CHILD",
|
||||
"AS_LAYER_REMOVE_SELF",
|
||||
"AS_LAYER_SHOW",
|
||||
"AS_LAYER_HIDE",
|
||||
"AS_LAYER_MOVE",
|
||||
"AS_LAYER_RESIZE",
|
||||
"AS_LAYER_INVALIDATE",
|
||||
"AS_LAYER_DRAW",
|
||||
"AS_LAYER_GET_TOKEN",
|
||||
"AS_LAYER_ADD",
|
||||
"AS_LAYER_REMOVE",
|
||||
"AS_LAYER_GET_COORD",
|
||||
"AS_LAYER_SET_FLAGS",
|
||||
"AS_LAYER_SET_ORIGIN",
|
||||
"AS_LAYER_GET_ORIGIN",
|
||||
"AS_LAYER_RESIZE_MODE",
|
||||
"AS_LAYER_CURSOR",
|
||||
"AS_LAYER_BEGIN_RECT_TRACK",
|
||||
"AS_LAYER_END_RECT_TRACK",
|
||||
"AS_LAYER_DRAG_RECT",
|
||||
"AS_LAYER_DRAG_IMAGE",
|
||||
"AS_LAYER_GET_MOUSE_COORDS",
|
||||
"AS_LAYER_SCROLL",
|
||||
"AS_LAYER_SET_LINE_MODE",
|
||||
"AS_LAYER_GET_LINE_MODE",
|
||||
"AS_LAYER_PUSH_STATE",
|
||||
"AS_LAYER_POP_STATE",
|
||||
"AS_LAYER_SET_SCALE",
|
||||
"AS_LAYER_GET_SCALE",
|
||||
"AS_LAYER_SET_DRAW_MODE",
|
||||
"AS_LAYER_GET_DRAW_MODE",
|
||||
"AS_LAYER_SET_BLEND_MODE",
|
||||
"AS_LAYER_GET_BLEND_MODE",
|
||||
"AS_LAYER_SET_PEN_LOC",
|
||||
"AS_LAYER_GET_PEN_LOC",
|
||||
"AS_LAYER_SET_PEN_SIZE",
|
||||
"AS_LAYER_GET_PEN_SIZE",
|
||||
"AS_LAYER_SET_HIGH_COLOR",
|
||||
"AS_LAYER_SET_LOW_COLOR",
|
||||
"AS_LAYER_SET_VIEW_COLOR",
|
||||
"AS_LAYER_GET_COLORS",
|
||||
"AS_LAYER_PRINT_ALIASING",
|
||||
"AS_LAYER_CLIP_TO_PICTURE",
|
||||
"AS_LAYER_CLIP_TO_INVERSE_PICTURE",
|
||||
"AS_LAYER_GET_CLIP_REGION",
|
||||
"AS_LAYER_DRAW_BITMAP_ASYNC_IN_RECT",
|
||||
"AS_LAYER_DRAW_BITMAP_ASYNC_AT_POINT",
|
||||
"AS_LAYER_DRAW_BITMAP_SYNC_IN_RECT",
|
||||
"AS_LAYER_DRAW_BITMAP_SYNC_AT_POINT",
|
||||
"AS_LAYER_DRAW_STRING",
|
||||
"AS_LAYER_SET_CLIP_REGION",
|
||||
"AS_LAYER_LINE_ARRAY",
|
||||
"AS_LAYER_BEGIN_PICTURE",
|
||||
"AS_LAYER_APPEND_TO_PICTURE",
|
||||
"AS_LAYER_END_PICTURE",
|
||||
"AS_LAYER_COPY_BITS",
|
||||
"AS_LAYER_DRAW_PICTURE",
|
||||
"AS_LAYER_INVAL_RECT",
|
||||
"AS_LAYER_INVAL_REGION",
|
||||
"AS_LAYER_INVERT_RECT",
|
||||
"AS_LAYER_MOVETO",
|
||||
"AS_LAYER_RESIZETO",
|
||||
"AS_LAYER_SET_STATE",
|
||||
"AS_LAYER_SET_FONT_STATE",
|
||||
"AS_LAYER_GET_STATE",
|
||||
"AS_LAYER_SET_VIEW_IMAGE",
|
||||
"AS_LAYER_SET_PATTERN",
|
||||
"AS_SET_CURRENT_LAYER",
|
||||
};
|
||||
|
||||
const char *strcode(int32 code)
|
||||
{
|
||||
code = code - SERVER_TRUE;
|
||||
if (code >= 0 && code <= AS_SET_CURRENT_LAYER - SERVER_TRUE)
|
||||
return kASCodeNames[code];
|
||||
else
|
||||
return bstrcode(code);
|
||||
}
|
||||
|
||||
const char *bstrcode(int32 code)
|
||||
{
|
||||
switch(code)
|
||||
{
|
||||
case B_ABOUT_REQUESTED:
|
||||
{
|
||||
return "B_ABOUT_REQUESTED";
|
||||
}
|
||||
case B_APP_ACTIVATED:
|
||||
{
|
||||
return "B_APP_ACTIVATED/B_WINDOW_ACTIVATED";
|
||||
}
|
||||
case B_ARGV_RECEIVED :
|
||||
{
|
||||
return "B_ARGV_RECEIVED";
|
||||
}
|
||||
case B_QUIT_REQUESTED :
|
||||
{
|
||||
return "B_QUIT_REQUESTED";
|
||||
}
|
||||
case B_CANCEL:
|
||||
{
|
||||
return "B_CANCEL";
|
||||
}
|
||||
case B_KEY_DOWN :
|
||||
{
|
||||
return "B_KEY_DOWN";
|
||||
}
|
||||
case B_KEY_UP :
|
||||
{
|
||||
return "B_KEY_UP";
|
||||
}
|
||||
case B_UNMAPPED_KEY_DOWN :
|
||||
{
|
||||
return "B_UNMAPPED_KEY_DOWN";
|
||||
}
|
||||
case B_UNMAPPED_KEY_UP :
|
||||
{
|
||||
return "B_UNMAPPED_KEY_UP";
|
||||
}
|
||||
case B_MODIFIERS_CHANGED:
|
||||
{
|
||||
return "B_MODIFIERS_CHANGED";
|
||||
}
|
||||
case B_MINIMIZE:
|
||||
{
|
||||
return "B_MINIMIZE";
|
||||
}
|
||||
case B_MOUSE_DOWN :
|
||||
{
|
||||
return "B_MOUSE_DOWN";
|
||||
}
|
||||
case B_MOUSE_MOVED :
|
||||
{
|
||||
return "B_MOUSE_MOVED";
|
||||
}
|
||||
case B_MOUSE_ENTER_EXIT:
|
||||
{
|
||||
return "B_MOUSE_ENTER_EXIT";
|
||||
}
|
||||
case B_MOUSE_UP :
|
||||
{
|
||||
return "B_MOUSE_UP";
|
||||
}
|
||||
case B_MOUSE_WHEEL_CHANGED:
|
||||
{
|
||||
return "B_MOUSE_WHEEL_CHANGED";
|
||||
}
|
||||
case B_OPEN_IN_WORKSPACE:
|
||||
{
|
||||
return "B_OPEN_IN_WORKSPACE";
|
||||
}
|
||||
case B_PRINTER_CHANGED:
|
||||
{
|
||||
return "B_PRINTER_CHANGED";
|
||||
}
|
||||
case B_PULSE :
|
||||
{
|
||||
return "B_PULSE";
|
||||
}
|
||||
case B_READY_TO_RUN :
|
||||
{
|
||||
return "B_READY_TO_RUN";
|
||||
}
|
||||
case B_REFS_RECEIVED :
|
||||
{
|
||||
return "B_REFS_RECEIVED";
|
||||
}
|
||||
case B_RELEASE_OVERLAY_LOCK:
|
||||
{
|
||||
return "B_RELEASE_OVERLAY_LOCK";
|
||||
}
|
||||
case B_ACQUIRE_OVERLAY_LOCK:
|
||||
{
|
||||
return "B_ACQUIRE_OVERLAY_LOCK";
|
||||
}
|
||||
case B_SCREEN_CHANGED :
|
||||
{
|
||||
return "B_SCREEN_CHANGED";
|
||||
}
|
||||
case B_VALUE_CHANGED :
|
||||
{
|
||||
return "B_VALUE_CHANGED";
|
||||
}
|
||||
case B_VIEW_MOVED :
|
||||
{
|
||||
return "B_VIEW_MOVED";
|
||||
}
|
||||
case B_VIEW_RESIZED :
|
||||
{
|
||||
return "B_VIEW_RESIZED";
|
||||
}
|
||||
case B_WINDOW_MOVED :
|
||||
{
|
||||
return "B_WINDOW_MOVED";
|
||||
}
|
||||
case B_WINDOW_RESIZED :
|
||||
{
|
||||
return "B_WINDOW_RESIZED";
|
||||
}
|
||||
case B_WORKSPACES_CHANGED:
|
||||
{
|
||||
return "B_WORKSPACES_CHANGED";
|
||||
}
|
||||
case B_WORKSPACE_ACTIVATED:
|
||||
{
|
||||
return "B_WORKSPACE_ACTIVATED";
|
||||
}
|
||||
case B_ZOOM:
|
||||
{
|
||||
return "B_ZOOM";
|
||||
}
|
||||
case _APP_MENU_:
|
||||
{
|
||||
return "_APP_MENU";
|
||||
}
|
||||
case _BROWSER_MENUS_:
|
||||
{
|
||||
return "_BROWSER_MENUS_";
|
||||
}
|
||||
case _MENU_EVENT_ :
|
||||
{
|
||||
return "_MENU_EVENT";
|
||||
}
|
||||
case _PING_:
|
||||
{
|
||||
return "_PING_";
|
||||
}
|
||||
case _QUIT_ :
|
||||
{
|
||||
return "_QUIT_";
|
||||
}
|
||||
case _VOLUME_MOUNTED_ :
|
||||
{
|
||||
return "_VOLUME_MOUNTED";
|
||||
}
|
||||
case _VOLUME_UNMOUNTED_:
|
||||
{
|
||||
return "_VOLUME_UNMOUNTED";
|
||||
}
|
||||
case _MESSAGE_DROPPED_ :
|
||||
{
|
||||
return "_MESSAGE_DROPPED";
|
||||
}
|
||||
case _DISPOSE_DRAG_ :
|
||||
{
|
||||
return "_DISPOSE_DRAG";
|
||||
}
|
||||
case _MENUS_DONE_:
|
||||
{
|
||||
return "_MENUS_DONE_";
|
||||
}
|
||||
case _SHOW_DRAG_HANDLES_:
|
||||
{
|
||||
return "_SHOW_DRAG_HANDLES_";
|
||||
}
|
||||
case _EVENTS_PENDING_ :
|
||||
{
|
||||
return "_EVENTS_PENDING_";
|
||||
}
|
||||
case _UPDATE_ :
|
||||
{
|
||||
return "_UPDATE_";
|
||||
}
|
||||
case _UPDATE_IF_NEEDED_:
|
||||
{
|
||||
return "_UPDATE_IF_NEEDED_";
|
||||
}
|
||||
case _PRINTER_INFO_:
|
||||
{
|
||||
return "_PRINTER_INFO_";
|
||||
}
|
||||
case _SETUP_PRINTER_:
|
||||
{
|
||||
return "_SETUP_PRINTER_";
|
||||
}
|
||||
case _SELECT_PRINTER_:
|
||||
{
|
||||
return "_SELECT_PRINTER_";
|
||||
}
|
||||
case B_SET_PROPERTY:
|
||||
{
|
||||
return "B_SET_PROPERTY";
|
||||
}
|
||||
case B_GET_PROPERTY:
|
||||
{
|
||||
return "B_GET_PROERTY";
|
||||
}
|
||||
case B_CREATE_PROPERTY:
|
||||
{
|
||||
return "B_CREATE_PROPERTY";
|
||||
}
|
||||
case B_DELETE_PROPERTY:
|
||||
{
|
||||
return "B_DELETE_PROPERTY";
|
||||
}
|
||||
case B_COUNT_PROPERTIES:
|
||||
{
|
||||
return "B_COUNT_PROPERTIES";
|
||||
}
|
||||
case B_EXECUTE_PROPERTY:
|
||||
{
|
||||
return "B_EXECUTE_PROPERTY";
|
||||
}
|
||||
case B_GET_SUPPORTED_SUITES:
|
||||
{
|
||||
return "B_GET_SUPPORTED_SUITES";
|
||||
}
|
||||
case B_UNDO:
|
||||
{
|
||||
return "B_UNDO";
|
||||
}
|
||||
case B_CUT :
|
||||
{
|
||||
return "B_CUT";
|
||||
}
|
||||
case B_COPY :
|
||||
{
|
||||
return "B_COPY";
|
||||
}
|
||||
case B_PASTE :
|
||||
{
|
||||
return "B_PASTE";
|
||||
}
|
||||
case B_SELECT_ALL:
|
||||
{
|
||||
return "B_SELECT_ALL";
|
||||
}
|
||||
case B_SAVE_REQUESTED :
|
||||
{
|
||||
return "B_SAVE_REQUESTED";
|
||||
}
|
||||
case B_MESSAGE_NOT_UNDERSTOOD:
|
||||
{
|
||||
return "B_MESSAGE_NOT_UNDERSTOOD";
|
||||
}
|
||||
case B_NO_REPLY :
|
||||
{
|
||||
return "B_NO_REPLY";
|
||||
}
|
||||
case B_REPLY :
|
||||
{
|
||||
return "B_REPLY";
|
||||
}
|
||||
case B_SIMPLE_DATA:
|
||||
{
|
||||
return "B_SIMPLE_DATA";
|
||||
}
|
||||
case B_MIME_DATA:
|
||||
{
|
||||
return "B_MIME_DATA";
|
||||
}
|
||||
case B_ARCHIVED_OBJECT:
|
||||
{
|
||||
return "B_ARCHIVED_OBJECT";
|
||||
}
|
||||
case B_UPDATE_STATUS_BAR:
|
||||
{
|
||||
return "B_UPDATE_STATUS_BAR";
|
||||
}
|
||||
case B_RESET_STATUS_BAR:
|
||||
{
|
||||
return "B_RESET_STATUS_BAR";
|
||||
}
|
||||
case B_NODE_MONITOR:
|
||||
{
|
||||
return "B_NODE_MONITOR";
|
||||
}
|
||||
case B_QUERY_UPDATE:
|
||||
{
|
||||
return "B_QUERY_UPDATE";
|
||||
}
|
||||
case B_ENDORSABLE:
|
||||
{
|
||||
return "B_ENDORSABLE";
|
||||
}
|
||||
case B_COPY_TARGET:
|
||||
{
|
||||
return "B_COPY_TARGET";
|
||||
}
|
||||
case B_MOVE_TARGET:
|
||||
{
|
||||
return "B_MOVE_TARGET";
|
||||
}
|
||||
case B_TRASH_TARGET:
|
||||
{
|
||||
return "B_TRASH_TARGET";
|
||||
}
|
||||
case B_LINK_TARGET:
|
||||
{
|
||||
return "B_LINK_TARGET";
|
||||
}
|
||||
case B_INPUT_DEVICES_CHANGED:
|
||||
{
|
||||
return "B_INPUT_DEVICES_CHANGED";
|
||||
}
|
||||
case B_INPUT_METHOD_EVENT:
|
||||
{
|
||||
return "B_INPUT_METHOD_EVENT";
|
||||
}
|
||||
case B_WINDOW_MOVE_TO:
|
||||
{
|
||||
return "B_WINDOW_MOVE_TO";
|
||||
}
|
||||
case B_WINDOW_MOVE_BY:
|
||||
{
|
||||
return "B_WINDOW_MOVE_BY";
|
||||
}
|
||||
case B_SILENT_RELAUNCH:
|
||||
{
|
||||
return "B_SILENT_RELAUNCH";
|
||||
}
|
||||
case B_OBSERVER_NOTICE_CHANGE :
|
||||
{
|
||||
return "B_OBSERVER_NOTICE_CHANGE";
|
||||
}
|
||||
case B_CONTROL_INVOKED:
|
||||
{
|
||||
return "B_CONTROL_INVOKED";
|
||||
}
|
||||
case B_CONTROL_MODIFIED:
|
||||
{
|
||||
return "B_CONTROL_MODIFIED";
|
||||
}
|
||||
default:
|
||||
{
|
||||
return "Unknown";
|
||||
}
|
||||
}
|
||||
}
|
||||
#endif //DEBUG_BPORTLINK
|
||||
|
||||
+18
-991
File diff suppressed because it is too large
Load Diff
@@ -10,6 +10,8 @@ APP_KIT_SOURCE =
|
||||
Handler.cpp
|
||||
InitTerminateLibBe.cpp
|
||||
Invoker.cpp
|
||||
LinkMsgReader.cpp
|
||||
LinkMsgSender.cpp
|
||||
Looper.cpp
|
||||
LooperList.cpp
|
||||
Message.cpp
|
||||
|
||||
Reference in New Issue
Block a user