Aren/haiku
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added debug output. No functional change. Surprisingly things seem to work.

Browse Source 
git-svn-id: file:///srv/svn/repos/haiku/trunk/current@11164 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
Ingo Weinhold 2005-01-30 23:28:49 +00:00
parent aa44f14baa
commit 576ca13ddb
1 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/kernel/core/messaging/MessagingService.cpp
View File

@ -15,11 +15,19 @@
#include "MessagingService.h" #include "MessagingService.h"
//#define TRACE_MESSAGING_SERVICE
#ifdef TRACE_MESSAGING_SERVICE
# define PRINT(x) dprintf x
#else
# define PRINT(x) ;
#endif
using namespace std; using namespace std;
static MessagingService *sMessagingService = NULL; static MessagingService *sMessagingService = NULL;
static const int32 kMessagingAreaSize = B_PAGE_SIZE * 4; //static const int32 kMessagingAreaSize = B_PAGE_SIZE * 4;
static const int32 kMessagingAreaSize = B_PAGE_SIZE;
// init_messaging_service // init_messaging_service
status_t status_t
@ -463,6 +471,8 @@ status_t
MessagingService::SendMessage(const void *message, int32 messageSize, MessagingService::SendMessage(const void *message, int32 messageSize,
const messaging_target *targets, int32 targetCount) const messaging_target *targets, int32 targetCount)
{ {
PRINT(("MessagingService::SendMessage(%p, %ld, %p, %ld)\n", message,
messageSize, targets, targetCount));
if (!message || messageSize <= 0 || !targets || targetCount <= 0) if (!message || messageSize <= 0 || !targets || targetCount <= 0)
return B_BAD_VALUE; return B_BAD_VALUE;
@ -475,8 +485,13 @@ MessagingService::SendMessage(const void *message, int32 messageSize,
bool wasEmpty; bool wasEmpty;
status_t error = _AllocateCommand(MESSAGING_COMMAND_SEND_MESSAGE, dataSize, status_t error = _AllocateCommand(MESSAGING_COMMAND_SEND_MESSAGE, dataSize,
area, data, wasEmpty); area, data, wasEmpty);
if (error != B_OK) if (error != B_OK) {
PRINT(("MessagingService::SendMessage(): Failed to allocate space for "
"send message command.\n"));
return error; return error;
}
PRINT((" Allocated space for send message command: area: %p, data: %p, "
"wasEmpty: %d\n", area, data, wasEmpty));
// prepare the command // prepare the command
messaging_command_send_message *command messaging_command_send_message *command
@ -516,6 +531,9 @@ MessagingService::_AllocateCommand(int32 commandWhat, int32 size,
break; break;
} }
PRINT(("MessagingService::_AllocateCommand(): Discarding area: %p\n",
area));
fFirstArea = area->NextArea(); fFirstArea = area->NextArea();
area->SetNextArea(NULL); area->SetNextArea(NULL);
discardedArea = area; discardedArea = area;
@ -533,8 +551,13 @@ MessagingService::_AllocateCommand(int32 commandWhat, int32 size,
if (discardedArea) { if (discardedArea) {
area = discardedAreaDeleter.Detach(); area = discardedAreaDeleter.Detach();
area->InitHeader(); area->InitHeader();
} else PRINT(("MessagingService::_AllocateCommand(): Not enough space "
"left in current area. Recycling discarded one: %p\n", area));
} else {
area = MessagingArea::Create(fLockSem, fCounterSem); area = MessagingArea::Create(fLockSem, fCounterSem);
PRINT(("MessagingService::_AllocateCommand(): Not enough space "
"left in current area. Allocated new one: %p\n", area));
}
if (!area) { if (!area) {
fLastArea->Unlock(); fLastArea->Unlock();
return B_NO_MEMORY; return B_NO_MEMORY;