kits/media/MediaRoster.cpp

158 			// Only now delete the port pool
356 	TRACE("BMediaRoster::ReleaseNodeAll, node %" B_PRId32 ", port %" B_PRId32
358 		node.node, node.port, BPrivate::current_team());
364 			"retrying local, node %" B_PRId32 ", port %"
365 			B_PRId32 ", team %" B_PRId32 "!\n", node.node, node.port,
368 		rv = SendToPort(node.port, NODE_FINAL_RELEASE, &command,
371 			ERROR("BMediaRoster::ReleaseNodeAll FAILED, node %" B_PRId32 ", port %"
372 				B_PRId32 ", team %" B_PRId32 "!\n", node.node, node.port,
450 	PRINT(4, "BMediaRosterEx::GetAllOutputs() node %" B_PRId32 ", port %"
451 		B_PRId32 "\n", node.node, node.port);
466 		rv = QueryPort(node.port, PRODUCER_GET_NEXT_OUTPUT, &request,
483 	QueryPort(node.port, PRODUCER_DISPOSE_OUTPUT_COOKIE, &request,
497 		", port %" B_PRId32 "\n", node->ID(), node->ControlPort());
527 	PRINT(4, "BMediaRosterEx::GetAllInputs() node %" B_PRId32 ", port %"
528 		B_PRId32 "\n", node.node, node.port);
543 		rv = QueryPort(node.port, CONSUMER_GET_NEXT_INPUT, &request,
560 	QueryPort(node.port, CONSUMER_DISPOSE_INPUT_COOKIE, &request,
574 		", port %" B_PRId32 "\n", node->ID(), node->ControlPort());
927 			"counting disabled timesource, node %" B_PRId32 ", port %" B_PRId32
928 			", team %" B_PRId32 "\n", node.node, node.port,
940 	TRACE("BMediaRoster::ReleaseNode, node %" B_PRId32 ", port %" B_PRId32
941 		", team %" B_PRId32 "\n", node.node, node.port,
947 		ERROR("BMediaRoster::ReleaseNode FAILED, node %" B_PRId32 ", port %"
948 			B_PRId32 ", team %" B_PRId32 "!\n", node.node, node.port,
973 			B_PRId32 ", port %" B_PRId32 ", kinds 0x%" B_PRIx32 "\n",
974 			forNode.node, forNode.port, forNode.kind);
987 	rv = QueryPort(forNode.port, NODE_GET_TIMESOURCE, &request,
1034 	rv = GetNodeFor(NodeIDFor(from.port), &sourcenode);
1036 		ERROR("BMediaRoster::Connect: Can't find source node for port %"
1037 			B_PRId32 "\n", from.port);
1041 	rv = GetNodeFor(NodeIDFor(to.port), &destnode);
1043 		ERROR("BMediaRoster::Connect: Can't find destination node for port "
1044 			"%" B_PRId32 "\n", to.port);
1069 	rv = QueryPort(from.port, PRODUCER_FORMAT_PROPOSAL, &request1,
1087 	rv = QueryPort(to.port, CONSUMER_ACCEPT_FORMAT, &request2,
1107 	rv = QueryPort(from.port, PRODUCER_PREPARE_TO_CONNECT, &request3,
1133 	con_status = QueryPort(to.port, CONSUMER_CONNECTED, &request4,
1158 	rv = QueryPort(reply4.input.source.port, PRODUCER_CONNECT, &request5,
1243 	rv1 = QueryPort(source.port, PRODUCER_DISCONNECT, &request1,
1245 	rv2 = QueryPort(destination.port, CONSUMER_DISCONNECTED, &request2,
1310 	if (input.source.port != output.source.port) {
1311 		printf("BMediaRoster::Disconnect: input.source.port %" B_PRId32
1312 			" doesn't match output.source.port %" B_PRId32 "\n",
1313 			input.source.port, output.source.port);
1322 	if (input.destination.port != output.destination.port) {
1323 		printf("BMediaRoster::Disconnect: input.destination.port %" B_PRId32
1324 			" doesn't match output.destination.port %" B_PRId32 "\n",
1325 			input.destination.port, output.destination.port);
1353 	return SendToPort(node.port, NODE_START, &command, sizeof(command));
1372 	return SendToPort(node.port, NODE_STOP, &command, sizeof(command));
1391 	return SendToPort(node.port, NODE_SEEK, &command, sizeof(command));
1427 	return write_port(node.port, TIMESOURCE_OP, &msg, sizeof(msg));
1465 	return write_port(node.port, TIMESOURCE_OP, &msg, sizeof(msg));
1505 	return write_port(node.port, TIMESOURCE_OP, &msg, sizeof(msg));
1518 	port_id waitPort = create_port(1, "SyncToNode wait port");
1525 	request.port = waitPort;
1527 	status_t status = QueryPort(node.port, NODE_SYNC_TO, &request,
1553 	return write_port(node.port, NODE_SET_RUN_MODE, &msg, sizeof(msg));
1565 	return write_port(node.port, NODE_PREROLL, &dummy, sizeof(dummy));
1587 	return write_port(node.port, NODE_ROLL, &command, sizeof(command));
1606 	return SendToPort(node.port, PRODUCER_SET_RUN_MODE_DELAY, &command,
1732 		ERROR("BMediaRoster::GetFreeInputsFor: node %" B_PRId32 ", port %"
1733 			B_PRId32 " invalid\n", node.node, node.port);
1737 		ERROR("BMediaRoster::GetFreeInputsFor: node %" B_PRId32 ", port %"
1738 			B_PRId32 " is not a consumer\n", node.node, node.port);
2147 	request.port = node->ControlPort();
2151 	TRACE("BMediaRoster::RegisterNode: sending SERVER_REGISTER_NODE: port "
2153 		request.port, request.kinds, request.team, request.name);
2245 			B_PRId32 " , port %" B_PRId32 " , team %" B_PRId32 "\n",
2365 	// We need to get a clone of the node to have a port id
2374 		result = SendToPort(clone.port, NODE_SET_TIMESOURCE,
2446 		rv = QueryPort(node.port, CONTROLLABLE_GET_PARAMETER_WEB, &request,
2503 	rv = QueryPort(node.port, CONTROLLABLE_START_CONTROL_PANEL, &request,
2698 		", flavor_id %" B_PRId32 " instanciated as node %" B_PRId32 ", port %"
2700 		_node->port, BPrivate::current_team());
2908 	rv = QueryPort(producer.port, PRODUCER_GET_LATENCY, &request,
2935 	rv = QueryPort(producer.port, PRODUCER_GET_INITIAL_LATENCY, &request,
2965 	rv = QueryPort(timeSource.port, TIMESOURCE_GET_START_LATENCY, &request,
3008 	status_t status = QueryPort(fileInterface.port,
3042 	rv = QueryPort(file_interface.port, FILEINTERFACE_SET_REF, &request,
3071 	rv = QueryPort(node.port, FILEINTERFACE_GET_REF, &request, sizeof(request),
3106 	rv = QueryPort(file_interface.port, FILEINTERFACE_SNIFF_REF, &request,
3227 	rv = QueryPort(output.source.port, PRODUCER_FORMAT_SUGGESTION_REQUESTED,
3256 	rv = QueryPort(input.destination.port, CONSUMER_ACCEPT_FORMAT, &request,
3311 	status = QueryPort(node.port, NODE_GET_ATTRIBUTES_FOR, &request,
3325 BMediaRoster::NodeIDFor(port_id port)
3333 	request.port = port;