kits/media/MediaRoster.cpp

114 static BLocker sInitLocker("BMediaRoster::Roster locker");
132 		if (BMediaRoster::CurrentRoster() != NULL) {
140 						ERROR("BMediaRoster: Node with ID %" B_PRId32
147 				be_app->UnregisterLooper(BMediaRoster::CurrentRoster());
150 			thread_id roster = BMediaRoster::CurrentRoster()->Thread();
152 			BMediaRoster::CurrentRoster()->PostMessage(B_QUIT_REQUESTED);
156 				ERROR("BMediaRoster: wait_for_thread returned error");
175 	BMediaRoster(),
190 	sServerIsUp = BMediaRoster::IsRunning();
203 	BMediaRoster::Quit();
356 	TRACE("BMediaRoster::ReleaseNodeAll, node %" B_PRId32 ", port %" B_PRId32
363 		ERROR("BMediaRoster::ReleaseNodeAll failed to query media_server, "
371 			ERROR("BMediaRoster::ReleaseNodeAll FAILED, node %" B_PRId32 ", port %"
721 //	#pragma mark - public BMediaRoster
725 BMediaRoster::GetVideoInput(media_node* _node)
733 BMediaRoster::GetAudioInput(media_node* _node)
741 BMediaRoster::GetVideoOutput(media_node* _node)
749 BMediaRoster::GetAudioMixer(media_node* _node)
757 BMediaRoster::GetAudioOutput(media_node* _node)
765 BMediaRoster::GetAudioOutput(media_node* _node, int32* _inputID,
775 BMediaRoster::GetTimeSource(media_node* _node)
797 BMediaRoster::SetVideoInput(const media_node& producer)
805 BMediaRoster::SetVideoInput(const dormant_node_info& producer)
813 BMediaRoster::SetAudioInput(const media_node& producer)
821 BMediaRoster::SetAudioInput(const dormant_node_info& producer)
829 BMediaRoster::SetVideoOutput(const media_node& consumer)
837 BMediaRoster::SetVideoOutput(const dormant_node_info& consumer)
845 BMediaRoster::SetAudioOutput(const media_node& consumer)
853 BMediaRoster::SetAudioOutput(const media_input& input)
861 BMediaRoster::SetAudioOutput(const dormant_node_info& consumer)
869 BMediaRoster::GetNodeFor(media_node_id node, media_node* clone)
895 BMediaRoster::GetSystemTimeSource(media_node* clone)
919 BMediaRoster::ReleaseNode(const media_node& node)
926 		TRACE("BMediaRoster::ReleaseNode, trying to release reference "
940 	TRACE("BMediaRoster::ReleaseNode, node %" B_PRId32 ", port %" B_PRId32
947 		ERROR("BMediaRoster::ReleaseNode FAILED, node %" B_PRId32 ", port %"
956 BMediaRoster::MakeTimeSourceFor(const media_node& forNode)
965 		TRACE("BMediaRoster::MakeTimeSourceFor, asked for system time "
972 		ERROR("BMediaRoster::MakeTimeSourceFor: for_node invalid, node %"
978 	TRACE("BMediaRoster::MakeTimeSourceFor: node %" B_PRId32 " enter\n",
990 		ERROR("BMediaRoster::MakeTimeSourceFor: request failed\n");
996 	TRACE("BMediaRoster::MakeTimeSourceFor: node %" B_PRId32 " leave\n",
1004 BMediaRoster::Connect(const media_source& from, const media_destination& to,
1007 	return BMediaRoster::Connect(from, to, _format, _output, _input, 0);
1012 BMediaRoster::Connect(const media_source& from, const media_destination& to,
1020 		ERROR("BMediaRoster::Connect: media_source invalid\n");
1024 		ERROR("BMediaRoster::Connect: media_destination invalid\n");
1036 		ERROR("BMediaRoster::Connect: Can't find source node for port %"
1043 		ERROR("BMediaRoster::Connect: Can't find destination node for port "
1050 		ERROR("BMediaRoster::Connect: source node %" B_PRId32 " is not a "
1055 		ERROR("BMediaRoster::Connect: destination node %" B_PRId32 " is not a "
1063 	PRINT_FORMAT("BMediaRoster::Connect calling "
1072 		ERROR("BMediaRoster::Connect: aborted after "
1081 	PRINT_FORMAT("BMediaRoster::Connect calling "
1090 		ERROR("BMediaRoster::Connect: aborted after "
1100 	PRINT_FORMAT("BMediaRoster::Connect calling "
1110 		ERROR("BMediaRoster::Connect: aborted after "
1124 	PRINT_FORMAT("BMediaRoster::Connect calling BBufferConsumer::Connected() "
1136 		ERROR("BMediaRoster::Connect: aborting after "
1150 	PRINT_FORMAT("BMediaRoster::Connect calling BBufferProducer::Connect with "
1161 		ERROR("BMediaRoster::Connect: aborted\n");
1165 		ERROR("BMediaRoster::Connect: aborted after BBufferProducer::Connect()"
1208 BMediaRoster::Disconnect(media_node_id source_nodeid,
1214 		ERROR("BMediaRoster::Disconnect: source media_node_id invalid\n");
1218 		ERROR("BMediaRoster::Disconnect: destination media_node_id invalid\n");
1222 		ERROR("BMediaRoster::Disconnect: media_source invalid\n");
1226 		ERROR("BMediaRoster::Disconnect: media_destination invalid\n");
1257 			ERROR("BMediaRoster::Disconnect: source_nodeid %" B_PRId32
1264 		ERROR("BMediaRoster::Disconnect: GetNodeFor source_nodeid %" B_PRId32
1269 			ERROR("BMediaRoster::Disconnect: destination_nodeid %" B_PRId32
1276 		ERROR("BMediaRoster::Disconnect: GetNodeFor destination_nodeid %"
1288 BMediaRoster::Disconnect(const media_output& output, const media_input& input)
1291 		printf("BMediaRoster::Disconnect: output.node.node %" B_PRId32
1296 		printf("BMediaRoster::Disconnect: input.node.node %" B_PRId32
1301 		printf("BMediaRoster::Disconnect: output.node.kind 0x%" B_PRIx32
1306 		printf("BMediaRoster::Disconnect: input.node.kind 0x%" B_PRIx32
1311 		printf("BMediaRoster::Disconnect: input.source.port %" B_PRId32
1317 		printf("BMediaRoster::Disconnect: input.source.id %" B_PRId32
1323 		printf("BMediaRoster::Disconnect: input.destination.port %" B_PRId32
1329 		printf("BMediaRoster::Disconnect: input.destination.id %" B_PRId32
1341 BMediaRoster::StartNode(const media_node& node, bigtime_t atPerformanceTime)
1347 	TRACE("BMediaRoster::StartNode, node %" B_PRId32 ", at perf %" B_PRId64
1358 BMediaRoster::StopNode(const media_node& node, bigtime_t atPerformanceTime,
1365 	TRACE("BMediaRoster::StopNode, node %" B_PRId32 ", at perf %" B_PRId64
1377 BMediaRoster::SeekNode(const media_node& node, bigtime_t toMediaTime,
1384 	TRACE("BMediaRoster::SeekNode, node %" B_PRId32 ", at perf %" B_PRId64
1396 BMediaRoster::StartTimeSource(const media_node& node, bigtime_t atRealTime)
1401 		//ERROR("BMediaRoster::StartTimeSource node %" B_PRId32 " is system timesource\n", node.node);
1406 //		ERROR("BMediaRoster::StartTimeSource node %" B_PRId32 " is shadow timesource\n", node.node);
1410 		ERROR("BMediaRoster::StartTimeSource node %" B_PRId32 " invalid\n",
1415 		ERROR("BMediaRoster::StartTimeSource node %" B_PRId32
1420 	TRACE("BMediaRoster::StartTimeSource, node %" B_PRId32 ", at real %"
1432 BMediaRoster::StopTimeSource(const media_node& node, bigtime_t atRealTime,
1438 		//ERROR("BMediaRoster::StopTimeSource node %ld is system timesource\n", node.node);
1443 //		ERROR("BMediaRoster::StopTimeSource node %ld is shadow timesource\n", node.node);
1447 		ERROR("BMediaRoster::StopTimeSource node %" B_PRId32 " invalid\n",
1452 		ERROR("BMediaRoster::StopTimeSource node %" B_PRId32 " is no "
1457 	TRACE("BMediaRoster::StopTimeSource, node %" B_PRId32 ", at real %" B_PRId64
1470 BMediaRoster::SeekTimeSource(const media_node& node,
1476 		// ERROR("BMediaRoster::SeekTimeSource node %ld is system timesource\n", node.node);
1483 //		ERROR("BMediaRoster::SeekTimeSource node %ld is shadow timesource\n", node.node);
1487 		ERROR("BMediaRoster::SeekTimeSource node %" B_PRId32 " invalid\n",
1492 		ERROR("BMediaRoster::SeekTimeSource node %" B_PRId32
1497 	TRACE("BMediaRoster::SeekTimeSource, node %" B_PRId32 ", at real %" B_PRId64
1510 BMediaRoster::SyncToNode(const media_node& node, bigtime_t atTime,
1513 	TRACE("BMediaRoster::SyncToNode, node %" B_PRId32 ", at real %" B_PRId64
1543 BMediaRoster::SetRunModeNode(const media_node& node, BMediaNode::run_mode mode)
1545 	TRACE("BMediaRoster::SetRunModeNode, node %" B_PRId32 ", mode %d\n",
1558 BMediaRoster::PrerollNode(const media_node& node)
1570 BMediaRoster::RollNode(const media_node& node, bigtime_t startPerformance,
1577 	TRACE("BMediaRoster::RollNode, node %" B_PRId32 ", at start perf %"
1592 BMediaRoster::SetProducerRunModeDelay(const media_node& node,
1595 	TRACE("BMediaRoster::SetProducerRunModeDelay, node %" B_PRId32 ", delay %"
1612 BMediaRoster::SetProducerRate(const media_node& producer, int32 numer,
1642 BMediaRoster::GetLiveNodeInfo(const media_node& node,
1668 BMediaRoster::GetLiveNodes(live_node_info* liveNodes, int32* _totalCount,
1702 		ERROR("BMediaRoster::GetLiveNodes failed querying server: %s\n",
1726 BMediaRoster::GetFreeInputsFor(const media_node& node,
1732 		ERROR("BMediaRoster::GetFreeInputsFor: node %" B_PRId32 ", port %"
1737 		ERROR("BMediaRoster::GetFreeInputsFor: node %" B_PRId32 ", port %"
1754 	PRINT(4, "BMediaRoster::GetFreeInputsFor node %" B_PRId32 ", max %" B_PRId32
1787 BMediaRoster::GetConnectedInputsFor(const media_node& node,
1807 	PRINT(4, "BMediaRoster::GetConnectedInputsFor node %" B_PRId32 ", max %"
1831 BMediaRoster::GetAllInputsFor(const media_node& node, media_input* out_inputs,
1850 	PRINT(4, "BMediaRoster::GetAllInputsFor node %" B_PRId32 ", max %" B_PRId32
1871 BMediaRoster::GetFreeOutputsFor(const media_node& node,
1891 	PRINT(4, "BMediaRoster::GetFreeOutputsFor node %" B_PRId32 ", max %"
1924 BMediaRoster::GetConnectedOutputsFor(const media_node& node,
1944 	PRINT(4, "BMediaRoster::GetConnectedOutputsFor node %" B_PRId32 ", max %"
1970 BMediaRoster::GetAllOutputsFor(const media_node& node,
1989 	PRINT(4, "BMediaRoster::GetAllOutputsFor node %" B_PRId32 ", max %" B_PRId32
2010 BMediaRoster::StartWatching(const BMessenger& where)
2014 		ERROR("BMediaRoster::StartWatching: messenger invalid!\n");
2023 BMediaRoster::StartWatching(const BMessenger & where, int32 notificationType)
2027 		ERROR("BMediaRoster::StartWatching: messenger invalid!\n");
2032 		ERROR("BMediaRoster::StartWatching: notificationType invalid!\n");
2045 BMediaRoster::StartWatching(const BMessenger& where, const media_node& node,
2050 		ERROR("BMediaRoster::StartWatching: messenger invalid!\n");
2054 		ERROR("BMediaRoster::StartWatching: node invalid!\n");
2059 		ERROR("BMediaRoster::StartWatching: notificationType invalid!\n");
2068 BMediaRoster::StopWatching(const BMessenger& where)
2078 BMediaRoster::StopWatching(const BMessenger& where, int32 notificationType)
2084 		ERROR("BMediaRoster::StopWatching: notificationType invalid!\n");
2093 BMediaRoster::StopWatching(const BMessenger& where, const media_node& node,
2099 		ERROR("BMediaRoster::StopWatching: node invalid!\n");
2104 		ERROR("BMediaRoster::StopWatching: notificationType invalid!\n");
2113 BMediaRoster::RegisterNode(BMediaNode* node)
2151 	TRACE("BMediaRoster::RegisterNode: sending SERVER_REGISTER_NODE: port "
2158 		ERROR("BMediaRoster::RegisterNode: failed to register node %s: %s\n",
2163 	TRACE("BMediaRoster::RegisterNode: QueryServer SERVER_REGISTER_NODE "
2181 	TRACE("BMediaRoster::RegisterNode: NodeRegistered callback finished\n");
2183 	TRACE("BMediaRoster::RegisterNode: publishing inputs/outputs\n");
2207 	TRACE("BMediaRoster::RegisterNode: sending NodesCreated\n");
2211 	TRACE("BMediaRoster::RegisterNode: finished\n");
2214 	TRACE("BMediaRoster::RegisterNode: registered node name '%s', id %ld,
2216 	TRACE("BMediaRoster::RegisterNode: node this               %p\n", node);
2217 	TRACE("BMediaRoster::RegisterNode: node fConsumerThis      %p\n",
2219 	TRACE("BMediaRoster::RegisterNode: node fProducerThis      %p\n",
2221 	TRACE("BMediaRoster::RegisterNode: node fFileInterfaceThis %p\n",
2223 	TRACE("BMediaRoster::RegisterNode: node fControllableThis  %p\n",
2225 	TRACE("BMediaRoster::RegisterNode: node fTimeSourceThis    %p\n",
2233 BMediaRoster::UnregisterNode(BMediaNode* node)
2239 	TRACE("BMediaRoster::UnregisterNode %"
2243 		TRACE("BMediaRoster::UnregisterNode, trying to unregister reference "
2250 		PRINT(1, "Warning: BMediaRoster::UnregisterNode: node id %" B_PRId32
2255 		PRINT(1, "Warning: BMediaRoster::UnregisterNode: node id %" B_PRId32
2279 		ERROR("BMediaRoster::UnregisterNode: failed to unregister node id %"
2300 			ERROR("BMediaRoster::UnregisterNode: "
2314 /*static*/ BMediaRoster*
2315 BMediaRoster::Roster(status_t* out_error)
2350 /*static*/ BMediaRoster*
2351 BMediaRoster::CurrentRoster()
2358 BMediaRoster::SetTimeSourceFor(media_node_id node, media_node_id time_source)
2377 			ERROR("BMediaRoster::SetTimeSourceFor"
2384 			ERROR("BMediaRoster::SetTimeSourceFor, ReleaseNode failed,"
2388 		ERROR("BMediaRoster::SetTimeSourceFor GetCloneForID failed, "
2403 			ERROR("BMediaRoster::SetTimeSourceFor, sending NODE_SET_TIMESOURCE "
2406 			TRACE("BMediaRoster::SetTimeSourceFor: node %" B_PRId32 " time source %"
2415 BMediaRoster::GetParameterWebFor(const media_node& node, BParameterWeb** _web)
2440 			ERROR("BMediaRoster::GetParameterWebFor couldn't create area of "
2449 			ERROR("BMediaRoster::GetParameterWebFor "
2457 			ERROR("BMediaRoster::GetParameterWebFor node %" B_PRId32
2471 					ERROR("BMediaRoster::GetParameterWebFor Unflatten failed, "
2486 	ERROR("BMediaRoster::GetParameterWebFor node %" B_PRId32 " has no "
2493 BMediaRoster::StartControlPanel(const media_node& node, BMessenger* _messenger)
2516 BMediaRoster::GetDormantNodes(dormant_node_info* _info, int32* _count,
2566 	or it gets called from BMediaRoster::InstantiateDormantNode() to create a
2707 BMediaRoster::InstantiateDormantNode(const dormant_node_info& info,
2714 		ERROR("BMediaRoster::InstantiateDormantNode error: addon-id %" B_PRId32
2719 	printf("BMediaRoster::InstantiateDormantNode: addon-id %" B_PRId32
2732 		ERROR("BMediaRoster::InstantiateDormantNode: failed to get "
2741 	printf("BMediaRoster::InstantiateDormantNode: name \"%s\", info \"%s\", "
2748 		printf("BMediaRoster::InstantiateDormantNode: caller requested "
2752 		printf("BMediaRoster::InstantiateDormantNode: caller requested "
2756 		printf("BMediaRoster::InstantiateDormantNode: node requires "
2760 		printf("BMediaRoster::InstantiateDormantNode: node requires "
2769 		ERROR("BMediaRoster::InstantiateDormantNode: requested "
2775 		ERROR("BMediaRoster::InstantiateDormantNode: requested "
2786 		TRACE("BMediaRoster::InstantiateDormantNode: creating global object "
2813 BMediaRoster::InstantiateDormantNode(const dormant_node_info& info,
2821 BMediaRoster::GetDormantNodeFor(const media_node& node,
2884 BMediaRoster::GetDormantFlavorInfoFor(const dormant_node_info& dormant,
2895 BMediaRoster::GetLatencyFor(const media_node& producer, bigtime_t* _latency)
2915 //	printf("BMediaRoster::GetLatencyFor producer %ld has maximum latency %lld\n", producer.node, *out_latency);
2921 BMediaRoster::GetInitialLatencyFor(const media_node& producer,
2944 	TRACE("BMediaRoster::GetInitialLatencyFor producer %" B_PRId32 " has "
2951 BMediaRoster::GetStartLatencyFor(const media_node& timeSource,
2972 	TRACE("BMediaRoster::GetStartLatencyFor timesource %" B_PRId32 " has "
2979 BMediaRoster::GetFileFormatsFor(const media_node& fileInterface,
3022 BMediaRoster::SetRefFor(const media_node& file_interface, const entry_ref& file,
3055 BMediaRoster::GetRefFor(const media_node& node, entry_ref* _file,
3086 BMediaRoster::SniffRefFor(const media_node& file_interface,
3122 BMediaRoster::SniffRef(const entry_ref& file, uint64 requireNodeKinds,
3127 	TRACE("BMediaRoster::SniffRef looking for a node to handle %s: 0x%" B_PRIx64
3163 			TRACE("BMediaRoster::SniffRef: found a node %s addon-id %" B_PRId32
3182 BMediaRoster::GetDormantNodeForType(const BMimeType& type,
3191 BMediaRoster::GetReadFileFormatsFor(const dormant_node_info& node,
3200 BMediaRoster::GetWriteFileFormatsFor(const dormant_node_info& node,
3209 BMediaRoster::GetFormatFor(const media_output& output, media_format* _format,
3238 BMediaRoster::GetFormatFor(const media_input& input, media_format* _format,
3267 BMediaRoster::GetFormatFor(const media_node& node, media_format* _format,
3283 BMediaRoster::GetNodeAttributesFor(const media_node& node,
3325 BMediaRoster::NodeIDFor(port_id port)
3338 		ERROR("BMediaRoster::NodeIDFor: failed (error %#" B_PRIx32 ")\n", rv);
3347 BMediaRoster::GetInstancesFor(media_addon_id addon, int32 flavor,
3367 		ERROR("BMediaRoster::GetLiveNodes failed\n");
3381 BMediaRoster::IsRunning()
3389 BMediaRoster::AudioBufferSizeFor(int32 channelCount, uint32 sampleFormat,
3415 BMediaRoster::MediaFlags(media_flags cap, void* buffer, size_t maxSize)
3426 BMediaRoster::MessageReceived(BMessage* message)
3434 				TRACE("BMediaRoster MEDIA_ROSTER_REQUEST_NOTIFICATIONS can't"
3440 				TRACE("BMediaRoster MEDIA_ROSTER_REQUEST_NOTIFICATIONS can't"
3453 				TRACE("BMediaRoster MEDIA_ROSTER_CANCEL_NOTIFICATIONS can't"
3459 				TRACE("BMediaRoster MEDIA_ROSTER_CANCEL_NOTIFICATIONS can't"
3485 			TRACE("BMediaRoster::MessageReceived media services are going up.");
3487 			if (BMediaRoster::IsRunning()) {
3490 					TRACE("BMediaRoster::MessageReceived can't reconnect"
3506 			TRACE("BMediaRoster::MessageReceived media services are down.");
3509 			if (!BMediaRoster::IsRunning() && sServerIsUp == true) {
3529 			if (!BMediaRoster::IsRunning())
3534 			TRACE("BMediaRoster::MessageReceived media services are"
3571 				TRACE("BMediaRoster::MessageReceived: CRITICAL! received"
3585 BMediaRoster::QuitRequested()
3593 BMediaRoster::ResolveSpecifier(BMessage* msg, int32 index, BMessage* specifier,
3601 BMediaRoster::GetSupportedSuites(BMessage* data)
3607 BMediaRoster::~BMediaRoster()
3616 //	#pragma mark - private BMediaRoster
3619 status_t BMediaRoster::_Reserved_MediaRoster_0(void*) { return B_ERROR; }
3620 status_t BMediaRoster::_Reserved_MediaRoster_1(void*) { return B_ERROR; }
3621 status_t BMediaRoster::_Reserved_MediaRoster_2(void*) { return B_ERROR; }
3622 status_t BMediaRoster::_Reserved_MediaRoster_3(void*) { return B_ERROR; }
3623 status_t BMediaRoster::_Reserved_MediaRoster_4(void*) { return B_ERROR; }
3624 status_t BMediaRoster::_Reserved_MediaRoster_5(void*) { return B_ERROR; }
3625 status_t BMediaRoster::_Reserved_MediaRoster_6(void*) { return B_ERROR; }
3626 status_t BMediaRoster::_Reserved_MediaRoster_7(void*) { return B_ERROR; }
3629 BMediaRoster::BMediaRoster()
3642 BMediaRoster* BMediaRoster::sDefaultInstance = NULL;