beveloper
353b9f6bce
be rewritten soon. Changed debugging macros and use of them, too. Also replaced the linked lists in the BufferManager (which were complicated, but working ok) with template based ones. git-svn-id: file:///srv/svn/repos/haiku/trunk/current@2133 a95241bf-73f2-0310-859d-f6bbb57e9c96
254 lines
7.1 KiB
C++
254 lines
7.1 KiB
C++
/*
|
|
* Copyright 2002, Marcus Overhagen. All rights reserved.
|
|
* Distributed under the terms of the MIT License.
|
|
*/
|
|
#include <OS.h>
|
|
#include <Locker.h>
|
|
#include <Message.h>
|
|
#include <Messenger.h>
|
|
#include <MediaNode.h>
|
|
#include "debug.h"
|
|
#include "NodeManager.h"
|
|
#include "DataExchange.h"
|
|
#include "Notifications.h"
|
|
#include "NotificationManager.h"
|
|
#include "media_server.h"
|
|
#include "Queue.h"
|
|
|
|
|
|
#define NOTIFICATION_THREAD_PRIORITY 19
|
|
#define TIMEOUT 100000
|
|
|
|
NotificationManager::NotificationManager()
|
|
: fNotificationQueue(new Queue),
|
|
fNotificationThreadId(-1),
|
|
fLocker(new BLocker("notification manager locker")),
|
|
fNotificationList(new List<Notification>)
|
|
{
|
|
fNotificationThreadId = spawn_thread(NotificationManager::worker_thread, "notification broadcast", NOTIFICATION_THREAD_PRIORITY, this);
|
|
resume_thread(fNotificationThreadId);
|
|
}
|
|
|
|
NotificationManager::~NotificationManager()
|
|
{
|
|
// properly terminate the queue and wait until the worker thread has finished
|
|
status_t dummy;
|
|
fNotificationQueue->Terminate();
|
|
wait_for_thread(fNotificationThreadId, &dummy);
|
|
delete fNotificationQueue;
|
|
delete fLocker;
|
|
delete fNotificationList;
|
|
}
|
|
|
|
void
|
|
NotificationManager::EnqueueMessage(BMessage *msg)
|
|
{
|
|
// queue a copy of the message to be processed later
|
|
fNotificationQueue->AddItem(new BMessage(*msg));
|
|
}
|
|
|
|
void
|
|
NotificationManager::RequestNotifications(BMessage *msg)
|
|
{
|
|
BMessenger messenger;
|
|
const media_node *node;
|
|
ssize_t nodesize;
|
|
team_id team;
|
|
int32 what;
|
|
|
|
msg->FindMessenger(NOTIFICATION_PARAM_MESSENGER, &messenger);
|
|
msg->FindInt32(NOTIFICATION_PARAM_TEAM, &team);
|
|
msg->FindInt32(NOTIFICATION_PARAM_WHAT, &what);
|
|
msg->FindData("node", B_RAW_TYPE, reinterpret_cast<const void **>(&node), &nodesize);
|
|
ASSERT(nodesize == sizeof(media_node));
|
|
|
|
Notification n;
|
|
n.messenger = messenger;
|
|
n.node = *node;
|
|
n.what = what;
|
|
n.team = team;
|
|
|
|
TRACE("NotificationManager::RequestNotifications node %ld, team %ld, what %#lx\n",node->node, team, what);
|
|
|
|
fLocker->Lock();
|
|
fNotificationList->Insert(n);
|
|
fLocker->Unlock();
|
|
|
|
// send the initial B_MEDIA_NODE_CREATED containing all existing live nodes
|
|
BMessage initmsg(B_MEDIA_NODE_CREATED);
|
|
if (B_OK == gNodeManager->GetLiveNodes(&initmsg)) {
|
|
messenger.SendMessage(&initmsg, static_cast<BHandler *>(NULL), TIMEOUT);
|
|
}
|
|
}
|
|
|
|
void
|
|
NotificationManager::CancelNotifications(BMessage *msg)
|
|
{
|
|
BMessenger messenger;
|
|
const media_node *node;
|
|
ssize_t nodesize;
|
|
team_id team;
|
|
int32 what;
|
|
|
|
msg->FindMessenger(NOTIFICATION_PARAM_MESSENGER, &messenger);
|
|
msg->FindInt32(NOTIFICATION_PARAM_TEAM, &team);
|
|
msg->FindInt32(NOTIFICATION_PARAM_WHAT, &what);
|
|
msg->FindData("node", B_RAW_TYPE, reinterpret_cast<const void **>(&node), &nodesize);
|
|
ASSERT(nodesize == sizeof(media_node));
|
|
|
|
TRACE("NotificationManager::CancelNotifications node %ld, team %ld, what %#lx\n",node->node, team, what);
|
|
|
|
/* if what == B_MEDIA_WILDCARD && node == media_node::null
|
|
* => delete all notifications for the matching team & messenger
|
|
* else if what != B_MEDIA_WILDCARD && node == media_node::null
|
|
* => delete all notifications for the matching what & team & messenger
|
|
* else if what == B_MEDIA_WILDCARD && node != media_node::null
|
|
* => delete all notifications for the matching team & messenger & node
|
|
* else if what != B_MEDIA_WILDCARD && node != media_node::null
|
|
* => delete all notifications for the matching what & team & messenger & node
|
|
*/
|
|
|
|
fLocker->Lock();
|
|
|
|
Notification n;
|
|
for (int32 index = 0; fNotificationList->GetAt(index, &n); index++) {
|
|
bool remove;
|
|
if (what == B_MEDIA_WILDCARD && *node == media_node::null && team == n.team && messenger == n.messenger)
|
|
remove = true;
|
|
else if (what != B_MEDIA_WILDCARD && *node == media_node::null && what == n.what && team == n.team && messenger == n.messenger)
|
|
remove = true;
|
|
else if (what == B_MEDIA_WILDCARD && *node != media_node::null && team == n.team && messenger == n.messenger && n.node == *node)
|
|
remove = true;
|
|
else if (what != B_MEDIA_WILDCARD && *node != media_node::null && what == n.what && team == n.team && messenger == n.messenger && n.node == *node)
|
|
remove = true;
|
|
else
|
|
remove = false;
|
|
if (remove) {
|
|
if (fNotificationList->Remove(index)) {
|
|
index--;
|
|
} else {
|
|
ASSERT(false);
|
|
}
|
|
}
|
|
}
|
|
|
|
fLocker->Unlock();
|
|
}
|
|
|
|
void
|
|
NotificationManager::SendNotifications(BMessage *msg)
|
|
{
|
|
const media_source *source;
|
|
const media_destination *destination;
|
|
const media_node *node;
|
|
ssize_t size;
|
|
int32 what;
|
|
|
|
msg->FindInt32(NOTIFICATION_PARAM_WHAT, &what);
|
|
msg->RemoveName(NOTIFICATION_PARAM_WHAT);
|
|
msg->what = what;
|
|
|
|
TRACE("NotificationManager::SendNotifications what %#lx\n", what);
|
|
|
|
fLocker->Lock();
|
|
|
|
Notification n;
|
|
for (int32 index = 0; fNotificationList->GetAt(index, &n); index++) {
|
|
if (n.what != B_MEDIA_WILDCARD && n.what != what)
|
|
continue;
|
|
|
|
switch (what) {
|
|
case B_MEDIA_NODE_CREATED:
|
|
case B_MEDIA_NODE_DELETED:
|
|
case B_MEDIA_CONNECTION_MADE:
|
|
case B_MEDIA_CONNECTION_BROKEN:
|
|
case B_MEDIA_BUFFER_CREATED:
|
|
case B_MEDIA_BUFFER_DELETED:
|
|
case B_MEDIA_TRANSPORT_STATE:
|
|
case B_MEDIA_DEFAULT_CHANGED:
|
|
case B_MEDIA_FLAVORS_CHANGED:
|
|
if (n.node != media_node::null)
|
|
continue;
|
|
break;
|
|
|
|
case B_MEDIA_NEW_PARAMETER_VALUE:
|
|
case B_MEDIA_PARAMETER_CHANGED:
|
|
case B_MEDIA_NODE_STOPPED:
|
|
case B_MEDIA_WEB_CHANGED:
|
|
msg->FindData("node", B_RAW_TYPE, reinterpret_cast<const void **>(&node), &size);
|
|
ASSERT(size == sizeof(media_node));
|
|
if (n.node != *node)
|
|
continue;
|
|
break;
|
|
|
|
case B_MEDIA_FORMAT_CHANGED:
|
|
msg->FindData("source", B_RAW_TYPE, reinterpret_cast<const void **>(&source), &size);
|
|
ASSERT(size == sizeof(media_source));
|
|
msg->FindData("destination", B_RAW_TYPE, reinterpret_cast<const void **>(&destination), &size);
|
|
ASSERT(size == sizeof(media_destination));
|
|
if (n.node.port != source->port && n.node.port != destination->port)
|
|
continue;
|
|
break;
|
|
}
|
|
|
|
TRACE("NotificationManager::SendNotifications sending\n");
|
|
n.messenger.SendMessage(msg, static_cast<BHandler *>(NULL), TIMEOUT);
|
|
}
|
|
|
|
fLocker->Unlock();
|
|
}
|
|
|
|
void
|
|
NotificationManager::CleanupTeam(team_id team)
|
|
{
|
|
TRACE("NotificationManager::CleanupTeam team %ld\n", team);
|
|
fLocker->Lock();
|
|
|
|
int debugcount = 0;
|
|
Notification n;
|
|
for (int32 index = 0; fNotificationList->GetAt(index, &n); index++) {
|
|
if (n.team == team) {
|
|
if (fNotificationList->Remove(index)) {
|
|
debugcount++;
|
|
index--;
|
|
} else {
|
|
ASSERT(false);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (debugcount != 0)
|
|
FATAL("NotificationManager::CleanupTeam: removed %d notifications for team %ld\n", debugcount, team);
|
|
|
|
fLocker->Unlock();
|
|
}
|
|
|
|
void
|
|
NotificationManager::WorkerThread()
|
|
{
|
|
BMessage *msg;
|
|
while (NULL != (msg = static_cast<BMessage *>(fNotificationQueue->RemoveItem()))) {
|
|
switch (msg->what) {
|
|
case MEDIA_SERVER_REQUEST_NOTIFICATIONS:
|
|
RequestNotifications(msg);
|
|
break;
|
|
case MEDIA_SERVER_CANCEL_NOTIFICATIONS:
|
|
CancelNotifications(msg);
|
|
break;
|
|
case MEDIA_SERVER_SEND_NOTIFICATIONS:
|
|
SendNotifications(msg);
|
|
break;
|
|
default:
|
|
debugger("bad notification message\n");
|
|
}
|
|
delete msg;
|
|
}
|
|
}
|
|
|
|
int32
|
|
NotificationManager::worker_thread(void *arg)
|
|
{
|
|
static_cast<NotificationManager *>(arg)->WorkerThread();
|
|
return 0;
|
|
}
|