kits/media/BufferProducer.cpp

96 		if (output.destination == media_destination::null)
107 			if (fConsumerThis->GetLatencyFor(output.destination, &latency,
111 		} else if (FindLatencyFor(output.destination, &latency, &unused)
185 				request->destination, &reply.format, &reply.out_source,
197 			Connect(request->error, request->source, request->destination,
208 			Disconnect(request->source, request->destination);
284 			if (command->destination == media_destination::null)
293 			replycommand.info.destination = command->destination;
294 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
307 				command->destination, &replycommand.info.format, NULL);
308 			if (command->destination == media_destination::null)
317 			replycommand.info.destination = command->destination;
318 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
332 			if (command->destination == media_destination::null)
341 			replycommand.info.destination = command->destination;
344 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
364 			LatencyChanged(command->source, command->destination,
385 			if (command->destination == media_destination::null)
394 			replycommand.info.destination = command->destination;
396 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
418 	const media_destination& destination, bigtime_t newLatency, uint32 flags)
427 	const media_destination& destination)
430 	if (destination == media_destination::null)
443 	command.header.destination = destination.id;
450 	return SendToPort(destination.port, CONSUMER_BUFFER_RECEIVED, &command,
457 	const media_destination& destination, bigtime_t atTime)
460 	if (IS_INVALID_DESTINATION(destination))
464 	command.for_whom = destination;
468 	return SendToPort(destination.port, CONSUMER_PRODUCER_DATA_STATUS, &command,
475 	const media_destination& destination)
478 	if (IS_INVALID_DESTINATION(destination))
484 	request.dest = destination;
486 	status_t status = QueryPort(destination.port, CONSUMER_ACCEPT_FORMAT,
498 	const media_destination& destination, media_format* format)
503 	if (IS_INVALID_DESTINATION(destination))
510 	request.consumer = destination;
514 	return QueryPort(destination.port, CONSUMER_FORMAT_CHANGED, &request,
520 BBufferProducer::FindLatencyFor(const media_destination& destination,
524 	if (IS_INVALID_DESTINATION(destination))
530 	request.for_whom = destination;
532 	status_t status = QueryPort(destination.port, CONSUMER_GET_LATENCY_FOR,
544 BBufferProducer::FindSeekTag(const media_destination& destination,
549 	if (IS_INVALID_DESTINATION(destination))
555 	request.destination = destination;
559 	status_t status = QueryPort(destination.port, CONSUMER_SEEK_TAG_REQUESTED,
610 	const media_destination& destination)
621 	return SendBuffer(buffer, output.source, destination);