Av1an/Encoders/rav1e.py
2020-09-14 20:45:21 +03:00

65 lines
2.1 KiB
Python

import os
import re
from Av1an.arg_parse import Args
from Chunks.chunk import Chunk
from Av1an.commandtypes import MPCommands, CommandPair, Command
from Encoders.encoder import Encoder
from Av1an.utils import list_index_of_regex, terminate
class Rav1e(Encoder):
def __init__(self):
super().__init__(
encoder_bin='rav1e',
default_args=['--tiles', '8', '--speed', '6', '--quantizer', '100'],
default_passes=1,
default_q_range=(70, 150),
output_extension='ivf'
)
def compose_1_pass(self, a: Args, c: Chunk, output: str) -> MPCommands:
return [
CommandPair(
Encoder.compose_ffmpeg_pipe(a),
['rav1e', '-', *a.video_params, '--output', output]
)
]
def compose_2_pass(self, a: Args, c: Chunk, output: str) -> MPCommands:
return [
CommandPair(
Encoder.compose_ffmpeg_pipe(a),
['rav1e', '-', '-q', '--first-pass', f'{c.fpf}.stat', *a.video_params, '--output', os.devnull]
),
CommandPair(
Encoder.compose_ffmpeg_pipe(a),
['rav1e', '-', '--second-pass', f'{c.fpf}.stat', *a.video_params, '--output', output]
)
]
def man_q(self, command: Command, q: int) -> Command:
"""Return command with new cq value
:param command: old command
:param q: new cq value
:return: command with new cq value"""
adjusted_command = command.copy()
i = list_index_of_regex(adjusted_command, r"--quantizer")
adjusted_command[i + 1] = f'{q}'
return adjusted_command
def match_line(self, line: str):
"""Extract number of encoded frames from line.
:param line: one line of text output from the encoder
:return: match object from re.search matching the number of encoded frames"""
if 'error' in line.lower():
print('\n\nERROR IN ENCODING PROCESS\n\n', line)
terminate()
return re.search(r"encoded.*? ([^ ]+?) ", line)