kits/media/BufferConsumer.cpp

348 			const consumer_accept_format_request* request
352 			reply.format = request->format;
353 			status_t status = AcceptFormat(request->dest, &reply.format);
354 			request->SendReply(status, &reply, sizeof(reply));
360 			const consumer_get_next_input_request *request = static_cast<const consumer_get_next_input_request *>(data);
362 			reply.cookie = request->cookie;
364 			request->SendReply(rv, &reply, sizeof(reply));
370 			const consumer_dispose_input_cookie_request *request = static_cast<const consumer_dispose_input_cookie_request *>(data);
372 			DisposeInputCookie(request->cookie);
373 			request->SendReply(B_OK, &reply, sizeof(reply));
409 			const consumer_get_latency_for_request *request = static_cast<const consumer_get_latency_for_request *>(data);
411 			rv = GetLatencyFor(request->for_whom, &reply.latency, &reply.timesource);
412 			request->SendReply(rv, &reply, sizeof(reply));
418 			const consumer_connected_request *request = static_cast<const consumer_connected_request *>(data);
420 			reply.input = request->input;
421 			rv = Connected(request->input.source, request->input.destination, request->input.format, &reply.input);
422 			request->SendReply(rv, &reply, sizeof(reply));
428 			const consumer_disconnected_request *request = static_cast<const consumer_disconnected_request *>(data);
431 			fBufferCache->FlushCacheForPort(request->source.port);
434 			Disconnected(request->source, request->destination);
435 			request->SendReply(B_OK, &reply, sizeof(reply));
441 			const consumer_format_changed_request *request = static_cast<const consumer_format_changed_request *>(data);
443 			rv = FormatChanged(request->producer, request->consumer, request->change_tag, request->format);
444 			request->SendReply(rv, &reply, sizeof(reply));
449 			completedcommand.info.change_tag = request->change_tag;
453 			completedcommand.info.source = request->producer;
454 			completedcommand.info.destination = request->consumer;
455 			completedcommand.info.format = request->format;
456 			SendToPort(request->consumer.port, NODE_REQUEST_COMPLETED, &completedcommand, sizeof(completedcommand));
462 			const consumer_seek_tag_requested_request *request = static_cast<const consumer_seek_tag_requested_request *>(data);
464 			rv = SeekTagRequested(request->destination, request->target_time, request->flags, &reply.seek_tag, &reply.tagged_time, &reply.flags);
465 			request->SendReply(rv, &reply, sizeof(reply));