kits/media/MediaRoster.cpp

212 	server_register_app_request request;
214 	request.team = BPrivate::current_team();
215 	request.messenger = BMessenger(NULL, this);
216 	status_t status = QueryServer(SERVER_REGISTER_APP, &request,
217 		sizeof(request), &reply, sizeof(reply));
233 	server_unregister_app_request request;
235 	request.team = BPrivate::current_team();
236 	QueryServer(SERVER_UNREGISTER_APP, &request, sizeof(request), &reply,
263 	// request, but we are using it just in launch/shutdown_media_server,
311 	server_change_flavor_instances_count_request request;
314 	request.add_on_id = addonID;
315 	request.flavor_id = flavorID;
316 	request.delta = 1;
317 	request.team = BPrivate::current_team();
318 	return QueryServer(SERVER_CHANGE_FLAVOR_INSTANCES_COUNT, &request,
319 		sizeof(request), &reply, sizeof(reply));
327 	server_change_flavor_instances_count_request request;
330 	request.add_on_id = addonID;
331 	request.flavor_id = flavorID;
332 	request.delta = -1;
333 	request.team = BPrivate::current_team();
334 	return QueryServer(SERVER_CHANGE_FLAVOR_INSTANCES_COUNT, &request,
335 		sizeof(request), &reply, sizeof(reply));
349 	server_release_node_request request;
353 	request.node = node;
354 	request.team = BPrivate::current_team();
360 	rv = QueryServer(SERVER_RELEASE_NODE_ALL, &request, sizeof(request), &reply,
383 	server_set_node_creator_request request;
386 	request.node = node;
387 	request.creator = creator;
388 	return QueryServer(SERVER_SET_NODE_CREATOR, &request, sizeof(request),
400 	server_get_node_request request;
404 	request.type = type;
405 	request.team = BPrivate::current_team();
406 	rv = QueryServer(SERVER_GET_NODE, &request, sizeof(request), &reply,
424 	server_set_node_request request;
427 	request.type = type;
428 	request.use_node = node != NULL;
430 		request.node = *node;
431 	request.use_dni = info != NULL;
433 		request.dni = *info;
434 	request.use_input = input != NULL;
436 		request.input = *input;
438 	return QueryServer(SERVER_SET_NODE, &request, sizeof(request), &reply,
463 		producer_get_next_output_request request;
465 		request.cookie = cookie;
466 		rv = QueryPort(node.port, PRODUCER_GET_NEXT_OUTPUT, &request,
467 			sizeof(request), &reply, sizeof(reply));
481 	producer_dispose_output_cookie_request request;
483 	QueryPort(node.port, PRODUCER_DISPOSE_OUTPUT_COOKIE, &request,
484 		sizeof(request), &reply, sizeof(reply));
540 		consumer_get_next_input_request request;
542 		request.cookie = cookie;
543 		rv = QueryPort(node.port, CONSUMER_GET_NEXT_INPUT, &request,
544 			sizeof(request), &reply, sizeof(reply));
558 	consumer_dispose_input_cookie_request request;
560 	QueryPort(node.port, CONSUMER_DISPOSE_INPUT_COOKIE, &request,
561 		sizeof(request), &reply, sizeof(reply));
600 	server_publish_outputs_request request;
610 	request.node = node;
611 	request.count = count;
616 		request.area = create_area("publish outputs", &start_addr,
619 		if (request.area < B_OK) {
621 				request.area);
622 			return (status_t)request.area;
626 		request.area = -1;
627 		outputs = request.outputs;
629 	TRACE("PublishOutputs: area %" B_PRId32 "\n", request.area);
637 	rv = QueryServer(SERVER_PUBLISH_OUTPUTS, &request, sizeof(request),
640 	if (request.area != -1)
641 		delete_area(request.area);
650 	server_publish_inputs_request request;
660 	request.node = node;
661 	request.count = count;
666 		request.area = create_area("publish inputs", &start_addr,
669 		if (request.area < B_OK) {
671 				request.area);
672 			return (status_t)request.area;
676 		request.area = -1;
677 		inputs = request.inputs;
679 	TRACE("PublishInputs: area %" B_PRId32 "\n", request.area);
687 	rv = QueryServer(SERVER_PUBLISH_INPUTS, &request, sizeof(request),
690 	if (request.area != -1)
691 		delete_area(request.area);
877 	server_get_node_for_request request;
881 	request.node_id = node;
882 	request.team = BPrivate::current_team();
884 	rv = QueryServer(SERVER_GET_NODE_FOR, &request, sizeof(request), &reply,
933 	server_release_node_request request;
937 	request.node = node;
938 	request.team = BPrivate::current_team();
944 	rv = QueryServer(SERVER_RELEASE_NODE, &request, sizeof(request), &reply,
981 	node_get_timesource_request request;
987 	rv = QueryPort(forNode.port, NODE_GET_TIMESOURCE, &request,
988 		sizeof(request), &reply, sizeof(reply));
990 		ERROR("BMediaRoster::MakeTimeSourceFor: request failed\n");
1522 	node_sync_to_request request;
1524 	request.performance_time = atTime;
1525 	request.port = waitPort;
1527 	status_t status = QueryPort(node.port, NODE_SYNC_TO, &request,
1528 		sizeof(request), &reply, sizeof(reply));
1621 	producer_set_play_rate_request request;
1622 	request.numer = numer;
1623 	request.denom = denom;
1625 		&request, sizeof(request));
1631 	status = read_port(request.reply_port, &code, &reply, sizeof(reply));
1651 	server_get_live_node_info_request request;
1655 	request.node = node;
1657 	rv = QueryServer(SERVER_GET_LIVE_NODE_INFO, &request, sizeof(request),
1679 	server_get_live_nodes_request request;
1680 	request.team = BPrivate::current_team();
1682 	request.max_count = *_totalCount;
1683 	request.has_input = hasInput != NULL;
1686 		request.input_format = *hasInput;
1688 	request.has_output = hasOutput != NULL;
1691 		request.output_format = *hasOutput;
1693 	request.has_name = name != NULL;
1695 		strlcpy(request.name, name, sizeof(request.name));
1696 	request.require_kinds = nodeKinds;
1699 	status_t status = QueryServer(SERVER_GET_LIVE_NODES, &request,
1700 		sizeof(request), &reply, sizeof(reply));
2140 	server_register_node_request request;
2143 	request.add_on_id = addOnID;
2144 	request.flavor_id = flavorID;
2145 	strcpy(request.name, node->Name());
2146 	request.kinds = node->Kinds();
2147 	request.port = node->ControlPort();
2148 	request.team = BPrivate::current_team();
2149 	request.timesource_id = node->fTimeSourceID;
2153 		request.port, request.kinds, request.team, request.name);
2155 	status_t status = QueryServer(SERVER_REGISTER_NODE, &request,
2156 		sizeof(request), &reply, sizeof(reply));
2267 	server_unregister_node_request request;
2268 	request.node_id = node->ID();
2269 	request.team = BPrivate::current_team();
2272 	BPrivate::media::notifications::NodesDeleted(&request.node_id, 1);
2276 	status_t status = QueryServer(SERVER_UNREGISTER_NODE, &request,
2277 		sizeof(request), &reply, sizeof(reply));
2368 		// We just send the request to set time_source-id as
2394 		server_set_node_timesource_request request;
2397 		request.node_id = node;
2398 		request.timesource_id = time_source;
2400 		result = QueryServer(SERVER_SET_NODE_TIMESOURCE, &request,
2401 			sizeof(request), &reply, sizeof(reply));
2425 	controllable_get_parameter_web_request request;
2444 		request.max_size = size;
2445 		request.area = area;
2446 		rv = QueryPort(node.port, CONTROLLABLE_GET_PARAMETER_WEB, &request,
2447 			sizeof(request), &reply, sizeof(reply));
2497 	controllable_start_control_panel_request request;
2500 	request.node = node;
2503 	rv = QueryPort(node.port, CONTROLLABLE_START_CONTROL_PANEL, &request,
2504 		sizeof(request), &reply, sizeof(reply));
2524 	server_get_dormant_nodes_request request;
2525 	request.max_count = *_count;
2526 	request.has_input = hasInput != NULL;
2529 		request.input_format = *hasInput;
2531 	request.has_output = hasOutput != NULL;
2534 		request.output_format = *hasOutput;
2537 	request.has_name = name != NULL;
2539 		strlcpy(request.name, name, sizeof(request.name));
2541 	request.require_kinds = requireKinds;
2542 	request.deny_kinds = denyKinds;
2545 	status_t status = QueryServer(SERVER_GET_DORMANT_NODES, &request,
2546 		sizeof(request), &reply, sizeof(reply));
2554 		status = read_port(request.reply_port, &code, _info,
2781 	// we will do it by forwarding this request into the media_addon_server,
2789 		add_on_server_instantiate_dormant_node_request request;
2791 		request.add_on_id = info.addon;
2792 		request.flavor_id = info.flavor_id;
2793 		request.creator_team = BPrivate::current_team();
2795 		rv = QueryAddOnServer(ADD_ON_SERVER_INSTANTIATE_DORMANT_NODE, &request,
2796 			sizeof(request), &reply, sizeof(reply));
2830 	server_get_dormant_node_for_request request;
2834 	request.node = node;
2836 	rv = QueryServer(SERVER_GET_DORMANT_NODE_FOR, &request, sizeof(request),
2861 	server_get_dormant_flavor_info_request request;
2862 	request.add_on_id = addonID;
2863 	request.flavor_id = flavorID;
2865 	status_t status = QueryServer(SERVER_GET_DORMANT_FLAVOR_INFO, &request,
2866 		sizeof(request), reply, 16300);
2904 	producer_get_latency_request request;
2908 	rv = QueryPort(producer.port, PRODUCER_GET_LATENCY, &request,
2909 		sizeof(request), &reply, sizeof(reply));
2931 	producer_get_initial_latency_request request;
2935 	rv = QueryPort(producer.port, PRODUCER_GET_INITIAL_LATENCY, &request,
2936 		sizeof(request), &reply, sizeof(reply));
2961 	timesource_get_start_latency_request request;
2965 	rv = QueryPort(timeSource.port, TIMESOURCE_GET_START_LATENCY, &request,
2966 		sizeof(request), &reply, sizeof(reply));
2991 	fileinterface_get_formats_request request;
3005 	request.num_formats = *_numFormats;
3006 	request.data_area = area;
3009 		FILEINTERFACE_GET_FORMATS, &request,
3010 		sizeof(request), &reply, sizeof(reply));
3031 	fileinterface_set_ref_request request;
3035 	request.device = file.device;
3036 	request.directory = file.directory;
3037 	strcpy(request.name, file.name);
3038 	request.create = createAndTruncate;
3040 		request.duration = *_length;
3042 	rv = QueryPort(file_interface.port, FILEINTERFACE_SET_REF, &request,
3043 		sizeof(request), &reply, sizeof(reply));
3067 	fileinterface_get_ref_request request;
3071 	rv = QueryPort(node.port, FILEINTERFACE_GET_REF, &request, sizeof(request),
3098 	fileinterface_sniff_ref_request request;
3102 	request.device = file.device;
3103 	request.directory = file.directory;
3104 	strcpy(request.name, file.name);
3106 	rv = QueryPort(file_interface.port, FILEINTERFACE_SNIFF_REF, &request,
3107 		sizeof(request), &reply, sizeof(reply));
3220 	producer_format_suggestion_requested_request request;
3224 	request.type = B_MEDIA_UNKNOWN_TYPE;
3225 	request.quality = 0; // TODO: what should this be?
3228 		&request, sizeof(request), &reply, sizeof(reply));
3249 	consumer_accept_format_request request;
3253 	request.dest = input.destination;
3254 	request.format.Clear(); // wildcard
3256 	rv = QueryPort(input.destination.port, CONSUMER_ACCEPT_FORMAT, &request,
3257 		sizeof(request), &reply, sizeof(reply));
3291 	node_get_attributes_for_request request;
3308 	request.count = maxCount;
3309 	request.area = dataArea;
3311 	status = QueryPort(node.port, NODE_GET_ATTRIBUTES_FOR, &request,
3312 		sizeof(request), &reply, sizeof(reply));
3329 	server_node_id_for_request request;
3333 	request.port = port;
3335 	rv = QueryServer(SERVER_NODE_ID_FOR, &request, sizeof(request), &reply,
3356 	server_get_instances_for_request request;
3360 	request.max_count = (_count ? *_count : 1);
3361 	request.add_on_id = addon;
3362 	request.flavor_id = flavor;
3364 	rv = QueryServer(SERVER_GET_INSTANCES_FOR, &request, sizeof(request),
3572 					"a release request but the node can't be found.");