diff --git a/src/servers/media/Jamfile b/src/servers/media/Jamfile index 2114581b42..e13bed06aa 100644 --- a/src/servers/media/Jamfile +++ b/src/servers/media/Jamfile @@ -7,7 +7,7 @@ Server media_server : AppManager.cpp BufferManager.cpp NodeManager.cpp - NotificationProcessor.cpp + NotificationManager.cpp Queue.cpp ; LinkSharedOSLibs media_server : be libmedia.so root ; diff --git a/src/servers/media/NotificationProcessor.cpp b/src/servers/media/NotificationManager.cpp similarity index 68% rename from src/servers/media/NotificationProcessor.cpp rename to src/servers/media/NotificationManager.cpp index 35a3d53595..e2b7b321f8 100644 --- a/src/servers/media/NotificationProcessor.cpp +++ b/src/servers/media/NotificationManager.cpp @@ -4,10 +4,9 @@ #include #include #include -#include "NotificationManager.h" -#include "NotificationProcessor.h" -#include "ServerInterface.h" #include "DataExchange.h" +#include "Notifications.h" +#include "NotificationManager.h" #include "Queue.h" #define NOTIFICATION_THREAD_PRIORITY 19 @@ -20,16 +19,16 @@ struct RegisteredHandler team_id team; }; -NotificationProcessor::NotificationProcessor() +NotificationManager::NotificationManager() : fNotificationQueue(new Queue), fNotificationThreadId(-1), fLocker(new BLocker) { - fNotificationThreadId = spawn_thread(NotificationProcessor::worker_thread, "notification broadcast", NOTIFICATION_THREAD_PRIORITY, this); + fNotificationThreadId = spawn_thread(NotificationManager::worker_thread, "notification broadcast", NOTIFICATION_THREAD_PRIORITY, this); resume_thread(fNotificationThreadId); } -NotificationProcessor::~NotificationProcessor() +NotificationManager::~NotificationManager() { // properly terminate the queue and wait until the worker thread has finished status_t dummy; @@ -40,63 +39,63 @@ NotificationProcessor::~NotificationProcessor() } void -NotificationProcessor::EnqueueMessage(BMessage *msg) +NotificationManager::EnqueueMessage(BMessage *msg) { // queue a copy of the message to be processed later fNotificationQueue->AddItem(new BMessage(*msg)); } void -NotificationProcessor::RequestNotifications(BMessage *msg) +NotificationManager::RequestNotifications(BMessage *msg) { BMessenger messenger; const media_node *node; ssize_t nodesize; team_id team; - int32 mask; + int32 what; msg->FindMessenger(NOTIFICATION_PARAM_MESSENGER, &messenger); msg->FindInt32(NOTIFICATION_PARAM_TEAM, &team); - msg->FindInt32(NOTIFICATION_PARAM_MASK, &mask); + msg->FindInt32(NOTIFICATION_PARAM_WHAT, &what); msg->FindData("node", B_RAW_TYPE, reinterpret_cast(&node), &nodesize); ASSERT(nodesize == sizeof(node)); } void -NotificationProcessor::CancelNotifications(BMessage *msg) +NotificationManager::CancelNotifications(BMessage *msg) { BMessenger messenger; const media_node *node; ssize_t nodesize; team_id team; - int32 mask; + int32 what; msg->FindMessenger(NOTIFICATION_PARAM_MESSENGER, &messenger); msg->FindInt32(NOTIFICATION_PARAM_TEAM, &team); - msg->FindInt32(NOTIFICATION_PARAM_MASK, &mask); + msg->FindInt32(NOTIFICATION_PARAM_WHAT, &what); msg->FindData("node", B_RAW_TYPE, reinterpret_cast(&node), &nodesize); ASSERT(nodesize == sizeof(node)); } void -NotificationProcessor::SendNotifications(BMessage *msg) +NotificationManager::SendNotifications(BMessage *msg) { } void -NotificationProcessor::CleanupTeam(team_id team) +NotificationManager::CleanupTeam(team_id team) { } void -NotificationProcessor::BroadcastMessages(BMessage *msg) +NotificationManager::BroadcastMessages(BMessage *msg) { } void -NotificationProcessor::WorkerThread() +NotificationManager::WorkerThread() { BMessage *msg; while (NULL != (msg = static_cast(fNotificationQueue->RemoveItem()))) { @@ -118,8 +117,8 @@ NotificationProcessor::WorkerThread() } int32 -NotificationProcessor::worker_thread(void *arg) +NotificationManager::worker_thread(void *arg) { - static_cast(arg)->WorkerThread(); + static_cast(arg)->WorkerThread(); return 0; } diff --git a/src/servers/media/NotificationProcessor.h b/src/servers/media/NotificationManager.h similarity index 84% rename from src/servers/media/NotificationProcessor.h rename to src/servers/media/NotificationManager.h index 1df7a2988a..4fdb19e467 100644 --- a/src/servers/media/NotificationProcessor.h +++ b/src/servers/media/NotificationManager.h @@ -1,11 +1,11 @@ class Queue; -class NotificationProcessor +class NotificationManager { public: - NotificationProcessor(); - ~NotificationProcessor(); + NotificationManager(); + ~NotificationManager(); void EnqueueMessage(BMessage *msg); diff --git a/src/servers/media/media_server.cpp b/src/servers/media/media_server.cpp index d7cd2acbc9..ec166a1c3d 100644 --- a/src/servers/media/media_server.cpp +++ b/src/servers/media/media_server.cpp @@ -4,7 +4,7 @@ #include #include #include -#include "NotificationProcessor.h" +#include "NotificationManager.h" #include "ServerInterface.h" #include "DataExchange.h" #include "BufferManager.h" @@ -107,7 +107,7 @@ private: port_id control_port; thread_id control_thread; - NotificationProcessor *fNotificationProcessor; + NotificationManager *fNotificationManager; BufferManager *fBufferManager; AppManager *fAppManager; NodeManager *fNodeManager; @@ -122,7 +122,7 @@ private: ServerApp::ServerApp() : BApplication(NEW_MEDIA_SERVER_SIGNATURE), - fNotificationProcessor(new NotificationProcessor), + fNotificationManager(new NotificationManager), fBufferManager(new BufferManager), fAppManager(new AppManager), fNodeManager(new NodeManager), @@ -140,7 +140,7 @@ ServerApp::ServerApp() ServerApp::~ServerApp() { - delete fNotificationProcessor; + delete fNotificationManager; delete fBufferManager; delete fAppManager; delete fNodeManager; @@ -548,9 +548,9 @@ void ServerApp::MessageReceived(BMessage *msg) case MEDIA_SERVER_GET_SHARED_BUFFER_AREA: GetSharedBufferArea(msg); break; case MEDIA_SERVER_REGISTER_BUFFER: RegisterBuffer(msg); break; case MEDIA_SERVER_UNREGISTER_BUFFER: UnregisterBuffer(msg); break; - case MEDIA_SERVER_REQUEST_NOTIFICATIONS: fNotificationProcessor->EnqueueMessage(msg); break; - case MEDIA_SERVER_CANCEL_NOTIFICATIONS: fNotificationProcessor->EnqueueMessage(msg); break; - case MEDIA_SERVER_SEND_NOTIFICATIONS: fNotificationProcessor->EnqueueMessage(msg); break; + case MEDIA_SERVER_REQUEST_NOTIFICATIONS: fNotificationManager->EnqueueMessage(msg); break; + case MEDIA_SERVER_CANCEL_NOTIFICATIONS: fNotificationManager->EnqueueMessage(msg); break; + case MEDIA_SERVER_SEND_NOTIFICATIONS: fNotificationManager->EnqueueMessage(msg); break; case MEDIA_SERVER_GET_NODE_ID: GetNodeID(msg); break;