Function cellRecClose

ps3fw/cellRec.cpp:1318–1413

}

error_code cellRecClose(s32 isDiscard)
{
	cellRec.todo("cellRecClose(isDiscard=0x%x)", isDiscard);

	auto& rec = g_fxo->get<rec_info>();

	if (rec.state == rec_state::closed)
	{
		return CELL_REC_ERROR_INVALID_STATE;
	}

	sysutil_register_cb([=, &rec](ppu_thread& ppu) -> s32
		{
			bool is_valid_range = true;

			if (isDiscard)
			{
				// No need to flush the encoder
				rec.stop_video_provider(false);
				rec.encoder->stop(false);

				if (rec.sink)
				{
					rec.sink->stop(true);
				}

				if (fs::is_file(rec.param.filename))
				{
					cellRec.warning("cellRecClose: removing discarded recording '%s'", rec.param.filename);

					if (!fs::remove_file(rec.param.filename))
					{
						cellRec.error("cellRecClose: failed to remove recording '%s'", rec.param.filename);
					}
				}
			}
			else
			{
				// Flush to make sure we encode all remaining frames
				rec.stop_video_provider(true);
				rec.encoder->stop(true);
				rec.recording_time_total = rec.encoder->get_timestamp_ms(rec.encoder->last_video_pts());

				if (rec.sink)
				{
					rec.sink->stop(true);
				}

				const s64 start_pts = rec.encoder->get_pts(rec.param.scene_metadata.start_time);
				const s64 end_pts = rec.encoder->get_pts(rec.param.scene_metadata.end_time);
				const s64 last_pts = rec.encoder->last_video_pts();

				is_valid_range = start_pts >= 0 && end_pts <= last_pts;
			}

			vm::dealloc(rec.video_input_buffer.addr(), vm::main);
			vm::dealloc(rec.audio_input_buffer.addr(), vm::main);