kits/media/BufferProducer.cpp

140 			const producer_set_run_mode_delay_command* command
143 			fDelay = command->delay;
144 			fRunMode = command->mode;
269 			const producer_set_buffer_group_command* command
273 			group = command->buffer_count != 0
274 				? new BBufferGroup(command->buffer_count, command->buffers)
283 			status_t status = SetBufferGroup(command->source, group);
284 			if (command->destination == media_destination::null)
288 			replycommand.info.change_tag = command->change_tag;
291 			replycommand.info.user_data = command->user_data;
292 			replycommand.info.source = command->source;
293 			replycommand.info.destination = command->destination;
294 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
301 			const producer_format_change_requested_command* command
305 			replycommand.info.format = command->format;
306 			status_t status = FormatChangeRequested(command->source,
307 				command->destination, &replycommand.info.format, NULL);
308 			if (command->destination == media_destination::null)
312 			replycommand.info.change_tag = command->change_tag;
315 			replycommand.info.user_data = command->user_data;
316 			replycommand.info.source = command->source;
317 			replycommand.info.destination = command->destination;
318 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
325 			const producer_video_clipping_changed_command* command
329 			status_t status = VideoClippingChanged(command->source,
330 				command->short_count, (int16 *)command->shorts,
331 				command->display, NULL);
332 			if (command->destination == media_destination::null)
336 			replycommand.info.change_tag = command->change_tag;
339 			replycommand.info.user_data = command->user_data;
340 			replycommand.info.source = command->source;
341 			replycommand.info.destination = command->destination;
343 			replycommand.info.format.u.raw_video.display = command->display;
344 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
351 			const producer_additional_buffer_requested_command* command
354 			AdditionalBufferRequested(command->source, command->prev_buffer,
355 				command->prev_time, command->has_seek_tag
356 					? &command->prev_tag : NULL);
362 			const producer_latency_changed_command* command
364 			LatencyChanged(command->source, command->destination,
365 				command->latency, command->flags);
371 			const producer_late_notice_received_command* command
374 			LateNoticeReceived(command->source, command->how_much,
375 				command->performance_time);
381 			const producer_enable_output_command* command
384 			EnableOutput(command->source, command->enabled, NULL);
385 			if (command->destination == media_destination::null)
389 			replycommand.info.change_tag = command->change_tag;
392 			replycommand.info.user_data = command->user_data;
393 			replycommand.info.source = command->source;
394 			replycommand.info.destination = command->destination;
396 			SendToPort(command->destination.port, NODE_REQUEST_COMPLETED,
437 	consumer_buffer_received_command command;
438 	command.buffer = buffer->ID();
439 	command.header = *buffer->Header();
440 	command.header.buffer = command.buffer;
441 	command.header.source_port = source.port;
442 	command.header.source = source.id;
443 	command.header.destination = destination.id;
444 	command.header.owner = 0; // XXX fill with "buffer owner info area"
445 	command.header.start_time += fDelay;
448 	//printf("BBufferProducer::SendBuffer     node %2ld, buffer %2ld, start_time %12Ld with lateness %6Ld\n", ID(), buffer->Header()->buffer, command.header.start_time, TimeSource()->Now() - command.header.start_time);
450 	return SendToPort(destination.port, CONSUMER_BUFFER_RECEIVED, &command,
451 		sizeof(command));
463 	consumer_producer_data_status_command command;
464 	command.for_whom = destination;
465 	command.status = status;
466 	command.at_performance_time = atTime;
468 	return SendToPort(destination.port, CONSUMER_PRODUCER_DATA_STATUS, &command,
469 		sizeof(command));