cortex/NodeManager/NodeManager.cpp

93 	Connection*										connection) {}
96 	const Connection*							connection) {}
259 	Connection*										connection) {
260 	ASSERT(connection);
263 		"NodeManager::_freeConnection(%ld)\n", connection->id()));
268 		connection->isValid() &&
269 		connection->flags() & Connection::INTERNAL &&
270 		!(connection->flags() & Connection::LOCKED)) {
273 			"! breaking connection:\n"
280 			connection->sourceNode(),
281 			connection->source().id, connection->source().port,
282 			connection->destinationNode(),
283 			connection->destination().id, connection->destination().port));
288 			connection->sourceNode(),
289 			connection->source(),
290 			connection->destinationNode(),
291 			connection->destination());
297 				connection->outputName(), connection->inputName(),
303 	delete connection;
441 	// initialize connection to the media roster
476 // on a given node.  Returns an invalid connection and B_BAD_VALUE
477 // if no matching connection was found.
493 			// copy connection
516 			// copy connection
527 // nodes.  Returns an invalid connection and B_BAD_VALUE if
528 // no matching connection was found
664 // destination; Returns an invalid connection and B_BAD_VALUE if
667 //   connection.  Since the low-level source/destination
672 //   connection corresponds to.
686 			// copy connection
708 			// copy connection
1195 		"! creating connection:\n"
1244 	// copy connection
1252 // a common format between output & input before connection;
1300 // disconnects the connection represented by the provided
1304 	const Connection&								connection) {
1311 	// don't bother trying to disconnect an invalid connection
1312 	if(!connection.isValid())
1315 	// make sure connection can be released
1316 	if(connection.flags() & Connection::LOCKED) {
1318 			"NodeManager::disconnect(): connection locked:\n"
1320 			connection.sourceNode(),
1321 			connection.outputName(),
1322 			connection.destinationNode(),
1323 			connection.inputName()));
1328 		"! breaking connection:\n"
1335 		connection.sourceNode(),
1336 		connection.source().id, connection.source().port,
1337 		connection.destinationNode(),
1338 		connection.destination().id, connection.destination().port));
1343 		connection.sourceNode(),
1344 		connection.source(),
1345 		connection.destinationNode(),
1346 		connection.destination());
1350 		con_map::iterator it = m_conSourceMap.lower_bound(connection.sourceNode());
1351 		con_map::iterator itEnd = m_conSourceMap.upper_bound(connection.sourceNode());
1353 			if((*it).second->id() == connection.id()) {
1366 		if(getNodeRef(connection.sourceNode(), &ref) == B_OK)
1368 		if(getNodeRef(connection.destinationNode(), &ref) == B_OK)
1398 // *** node/connection iteration
1446 	Connection*										connection,
1464 	*connection = *((*(*pit)).second);
1564 	// tear down media roster connection
1767 	Connection*										connection) {
1769 	ASSERT(connection);
1778 	for(con_map::iterator it = m_conSourceMap.lower_bound(connection->sourceNode());
1779 		it != m_conSourceMap.upper_bound(connection->sourceNode()); ++it) {
1780 		ASSERT((*it).second->id() != connection->id());
1782 	for(con_map::iterator it = m_conDestinationMap.lower_bound(connection->destinationNode());
1783 		it != m_conDestinationMap.upper_bound(connection->destinationNode()); ++it) {
1784 		ASSERT((*it).second->id() != connection->id());
1792 			connection->sourceNode(),
1793 			connection));
1796 			connection->destinationNode(),
1797 			connection));
1800 	connectionMade(connection);
1804 	const Connection&							connection) {
1813 	connectionBroken(&connection);
1819 		itSource = m_conSourceMap.lower_bound(connection.sourceNode());
1820 		itSource != m_conSourceMap.upper_bound(connection.sourceNode());
1822 		if((*itSource).second->id() == connection.id())
1828 		itDestination = m_conDestinationMap.lower_bound(connection.destinationNode());
1829 		itDestination != m_conDestinationMap.upper_bound(connection.destinationNode());
1831 		if((*itDestination).second->id() == connection.id())
1928 	//   no connection info will be received for these nodes; store them
2085 						"    input/output mismatch for connection\n"
2100 				// instantiate & add connection
2119 //					"* NodeManager::_handleNodesCreated(): Found initial connection:\n"
2281 				"  - existing connection for %s -> %s found\n",
2333 		// look up the connection +++++ SLOW +++++
2338 				"* NodeManager::_handleConnectionBroken(): connection not found:\n"
2357 		// home free; delete the connection
2399 	// find matching connection
2404 				// connection defunct