* basic parser create

* adding data_stream

* buildable parser

* query output and required fucntions

* latest changes

* alloc buffer and other functions

* parses first frame

* parser finds all frames

* parser dump size correct - dump file included

* clean up

* merge conflicts and file restructure

* uses updated video demuxer

* undoing changes to sample app

* cleaning code

* cleaning code

* removing dwarf flag from compile

* formatting changes

* change variable names as per google standard

* struct naming convention

* struct name

* remove parser data class and combine into parser buffer

* remove context class and clean up

* remove log file and use commons

* move class to .h file

* removing unused functions

* removes platform.h

* removing datastream class

* formatting

* remove byte_array, rename enums

* clean up

* spacing

* rearrange to fit master

* removes bit_strea_parser class, combines common stuff to roc_video_parser file

[ROCm/rocdecode commit: 4ca0d02bb0]
Αυτή η υποβολή περιλαμβάνεται σε:
Lakshmi Kumar
2023-10-05 08:20:07 -07:00
υποβλήθηκε από GitHub
γονέας dcc6ee9f2a
υποβολή 04f3ecc0e9
6 αρχεία άλλαξαν με 1950 προσθήκες και 9 διαγραφές
@@ -1,3 +1,5 @@
build/
samples/*/build
.vscode/
.vscode/
samples/videoDecode/videodecode_test.cpp
samples/videoDecodeCMakeLists_test.txt
Το diff αρχείου καταστέλλεται επειδή είναι πολύ μεγάλο Φόρτωση Διαφορών
@@ -22,6 +22,90 @@ THE SOFTWARE.
#pragma once
#include "roc_video_parser.h"
#include "parser_buffer.h"
#include <map>
#include <vector>
#include <algorithm>
#define PARSER_SECOND 10000000L // 1 second in 100 nanoseconds
#define DATA_STREAM_SIZE 10*1024 // allocating buffer to hold video stream
#define INIT_ARRAY_SIZE 1024
#define ARRAY_MAX_SIZE (1LL << 60LL) // extremely large maximum size
class ByteArray {
protected:
uint8_t *m_pdata_;
size_t m_size_;
size_t m_max_size_;
public:
ByteArray() : m_pdata_(0), m_size_(0), m_max_size_(0) {}
ByteArray(const ByteArray &other) : m_pdata_(0), m_size_(0), m_max_size_(0) {
*this = other;
}
ByteArray(size_t num) : m_pdata_(0), m_size_(0), m_max_size_(0) {
SetSize(num);
}
virtual ~ByteArray() {
if (m_pdata_ != 0) {
delete[] m_pdata_;
}
}
void SetSize(size_t num) {
if (num == m_size_) {
return;
}
if (num < m_size_) {
memset(m_pdata_ + num, 0, m_max_size_ - num);
}
else if (num > m_max_size_) {
// This is done to prevent the following error from surfacing
// for the p_new_data allocation on some compilers:
// -Werror=alloc-size-larger-than=
size_t new_size = (num / INIT_ARRAY_SIZE) * INIT_ARRAY_SIZE + INIT_ARRAY_SIZE;
if (new_size > ARRAY_MAX_SIZE) {
return;
}
m_max_size_ = new_size;
uint8_t *p_new_data = new uint8_t[m_max_size_];
memset(p_new_data, 0, m_max_size_);
if (m_pdata_ != NULL) {
memcpy(p_new_data, m_pdata_, m_size_);
delete[] m_pdata_;
}
m_pdata_ = p_new_data;
}
m_size_ = num;
}
void Copy(const ByteArray &old) {
if (m_max_size_ < old.m_size_) {
m_max_size_ = old.m_max_size_;
if (m_pdata_ != NULL) {
delete[] m_pdata_;
}
m_pdata_ = new uint8_t[m_max_size_];
memset(m_pdata_, 0, m_max_size_);
}
memcpy(m_pdata_, old.m_pdata_, old.m_size_);
m_size_ = old.m_size_;
}
uint8_t operator[] (size_t iPos) const {
return m_pdata_[iPos];
}
uint8_t& operator[] (size_t iPos) {
return m_pdata_[iPos];
}
ByteArray& operator=(const ByteArray &other) {
SetSize(other.GetSize());
if (GetSize() > 0) {
memcpy(GetData(), other.GetData(), GetSize());
}
return *this;
}
uint8_t *GetData() const { return m_pdata_; }
size_t GetSize() const { return m_size_; }
};
class HEVCVideoParser : public RocVideoParser {
@@ -36,15 +120,497 @@ public:
*
* @return rocDecStatus
*/
virtual rocDecStatus Initialize(RocdecParserParams *pParams);
virtual rocDecStatus Initialize(RocdecParserParams *pParams);
/**
* @brief Function to Parse video data: Typically called from application when a demuxed picture is ready to be parsed
*
* @param pData: Pointer to picture data
* @return rocDecStatus: returns success on completion, else error_code for failure
*/
virtual rocDecStatus ParseVideoData(RocdecSourceDataPacket *pData); // pure virtual: implemented by derived class
virtual rocDecStatus ParseVideoData(RocdecSourceDataPacket *pData); // pure virtual: implemented by derived class
private:
/**
* @brief HEVCParser object destructor
*
*/
virtual ~HEVCVideoParser();
/**
* @brief Function to set the frames per second
*
* @param fps: Value of fps to set in <tt>double</tt>
* @return void: returns on completion
*/
void SetFrameRate(double fps);
/**
* @brief Function to get the frames per second
*
* @return double: returns fps in <tt>double</tt> on completion.
*/
double GetFrameRate() const;
/**
* @brief Function to reinitialize the HEVC parser. Resets the timestamp, packet count and pointer to beginning of stream.
*
* @return ParserResult: returns PARSER_OK on successful completion.
*/
ParserResult ReInit();
/**
* @brief Function to get the output buffer in type <tt>ParserBuffer</tt> after parsing the HEVC stream.
*
* @param pp_data: Pointer to pointer to the <tt>ParserBuffer</tt> data which is also the returned.
* @return ParserResult: returns PARSER_OK on successful completion.
*/
ParserResult QueryOutput(ParserBuffer** pp_data);
/**
* @brief Function to set the parser to beginning of frame and call the SPS and PPS funtions.
*
* @return void: returns on completion
*/
void FindFirstFrameSPSandPPS();
/**
* @brief Function to check if it's the last frame after dumuxing.
*
* @return bool: returns true if last frame, else false.
*/
bool CheckDataStreamEof(int n_video_bytes);
protected:
// ISO-IEC 14496-15-2004.pdf, page 14, table 1 " NAL unit types in elementary streams.
enum NalUnitType {
NAL_UNIT_CODED_SLICE_TRAIL_N = 0, // 0
NAL_UNIT_CODED_SLICE_TRAIL_R, // 1
NAL_UNIT_CODED_SLICE_TSA_N, // 2
NAL_UNIT_CODED_SLICE_TLA_R, // 3
NAL_UNIT_CODED_SLICE_STSA_N, // 4
NAL_UNIT_CODED_SLICE_STSA_R, // 5
NAL_UNIT_CODED_SLICE_RADL_N, // 6
NAL_UNIT_CODED_SLICE_RADL_R, // 7
NAL_UNIT_CODED_SLICE_RASL_N, // 8
NAL_UNIT_CODED_SLICE_RASL_R, // 9
NAL_UNIT_RESERVED_VCL_N10,
NAL_UNIT_RESERVED_VCL_R11,
NAL_UNIT_RESERVED_VCL_N12,
NAL_UNIT_RESERVED_VCL_R13,
NAL_UNIT_RESERVED_VCL_N14,
NAL_UNIT_RESERVED_VCL_R15,
NAL_UNIT_CODED_SLICE_BLA_W_LP, // 16
NAL_UNIT_CODED_SLICE_BLA_W_RADL, // 17
NAL_UNIT_CODED_SLICE_BLA_N_LP, // 18
NAL_UNIT_CODED_SLICE_IDR_W_RADL, // 19
NAL_UNIT_CODED_SLICE_IDR_N_LP, // 20
NAL_UNIT_CODED_SLICE_CRA, // 21
NAL_UNIT_RESERVED_IRAP_VCL22,
NAL_UNIT_RESERVED_IRAP_VCL23,
NAL_UNIT_RESERVED_VCL24,
NAL_UNIT_RESERVED_VCL25,
NAL_UNIT_RESERVED_VCL26,
NAL_UNIT_RESERVED_VCL27,
NAL_UNIT_RESERVED_VCL28,
NAL_UNIT_RESERVED_VCL29,
NAL_UNIT_RESERVED_VCL30,
NAL_UNIT_RESERVED_VCL31,
NAL_UNIT_VPS, // 32
NAL_UNIT_SPS, // 33
NAL_UNIT_PPS, // 34
NAL_UNIT_ACCESS_UNIT_DELIMITER, // 35
NAL_UNIT_EOS, // 36
NAL_UNIT_EOB, // 37
NAL_UNIT_FILLER_DATA, // 38
NAL_UNIT_PREFIX_SEI, // 39
NAL_UNIT_SUFFIX_SEI, // 40
NAL_UNIT_RESERVED_NVCL41,
NAL_UNIT_RESERVED_NVCL42,
NAL_UNIT_RESERVED_NVCL43,
NAL_UNIT_RESERVED_NVCL44,
NAL_UNIT_RESERVED_NVCL45,
NAL_UNIT_RESERVED_NVCL46,
NAL_UNIT_RESERVED_NVCL47,
NAL_UNIT_UNSPECIFIED_48,
NAL_UNIT_UNSPECIFIED_49,
NAL_UNIT_UNSPECIFIED_50,
NAL_UNIT_UNSPECIFIED_51,
NAL_UNIT_UNSPECIFIED_52,
NAL_UNIT_UNSPECIFIED_53,
NAL_UNIT_UNSPECIFIED_54,
NAL_UNIT_UNSPECIFIED_55,
NAL_UNIT_UNSPECIFIED_56,
NAL_UNIT_UNSPECIFIED_57,
NAL_UNIT_UNSPECIFIED_58,
NAL_UNIT_UNSPECIFIED_59,
NAL_UNIT_UNSPECIFIED_60,
NAL_UNIT_UNSPECIFIED_61,
NAL_UNIT_UNSPECIFIED_62,
NAL_UNIT_UNSPECIFIED_63,
NAL_UNIT_INVALID,
};
struct NalUnitHeader {
uint32_t forbidden_zero_bit;
uint32_t nal_unit_type;
uint32_t nuh_layer_id;
uint32_t nuh_temporal_id_plus1;
uint32_t num_emu_byte_removed;
};
enum H265ScalingListSize {
H265_SCALING_LIST_4x4 = 0,
H265_SCALING_LIST_8x8,
H265_SCALING_LIST_16x16,
H265_SCALING_LIST_32x32,
H265_SCALING_LIST_SIZE_NUM
};
typedef struct {
uint32_t general_profile_space; //u(2)
bool general_tier_flag; //u(1)
uint32_t general_profile_idc; //u(5)
bool general_profile_compatibility_flag[32]; //u(1)
bool general_progressive_source_flag; //u(1)
bool general_interlaced_source_flag; //u(1)
bool general_non_packed_constraint_flag; //u(1)
bool general_frame_only_constraint_flag; //u(1)
uint64_t general_reserved_zero_44bits; //u(44)
uint32_t general_level_idc; //u(8)
//max_num_sub_layers_minus1 max is 7 - 1 = 6
bool sub_layer_profile_present_flag[6]; //u(1)
bool sub_layer_level_present_flag[6]; //u(1)
uint32_t reserved_zero_2bits[8]; //u(2)
uint32_t sub_layer_profile_space[6]; //u(2)
bool sub_layer_tier_flag[6]; //u(1)
uint32_t sub_layer_profile_idc[6]; //u(5)
bool sub_layer_profile_compatibility_flag[6][32]; //u(1)
bool sub_layer_progressive_source_flag[6]; //u(1)
bool sub_layer_interlaced_source_flag[6]; //u(1)
bool sub_layer_non_packed_constraint_flag[6]; //u(1)
bool sub_layer_frame_only_constraint_flag[6]; //u(1)
uint64_t sub_layer_reserved_zero_44bits[6]; //u(44)
uint32_t sub_layer_level_idc[6]; //u(8)
} H265ProfileTierLevel;
#define H265_SCALING_LIST_NUM 6 ///< list number for quantization matrix
#define H265_SCALING_LIST_MAX_I 64
typedef struct {
bool scaling_list_pred_mode_flag[4][6]; //u(1)
uint32_t scaling_list_pred_matrix_id_delta[4][6]; //ue(v)
int32_t scaling_list_dc_coef_minus8[4][6]; //se(v)
int32_t scaling_list_delta_coef; //se(v) could have issues......
int32_t scaling_list[H265_SCALING_LIST_SIZE_NUM][H265_SCALING_LIST_NUM][H265_SCALING_LIST_MAX_I];
} H265ScalingListData;
typedef struct {
int32_t num_negative_pics;
int32_t num_positive_pics;
int32_t num_of_pics;
int32_t num_of_delta_poc;
int32_t delta_poc[16];
bool used_by_curr_pic[16];
} H265ShortTermRPS;
typedef struct {
int32_t num_of_pics;
int32_t POCs[32];
bool used_by_curr_pic[32];
} H265LongTermRPS;
typedef struct {
//CpbCnt = cpb_cnt_minus1
uint32_t bit_rate_value_minus1[32]; //ue(v)
uint32_t cpb_size_value_minus1[32]; //ue(v)
uint32_t cpb_size_du_value_minus1[32]; //ue(v)
uint32_t bit_rate_du_value_minus1[32]; //ue(v)
bool cbr_flag[32]; //u(1)
} H265SubLayerHrdParameters;
typedef struct {
bool nal_hrd_parameters_present_flag; //u(1)
bool vcl_hrd_parameters_present_flag; //u(1)
bool sub_pic_hrd_params_present_flag; //u(1)
uint32_t tick_divisor_minus2; //u(8)
uint32_t du_cpb_removal_delay_increment_length_minus1; //u(5)
bool sub_pic_cpb_params_in_pic_timing_sei_flag; //u(1)
uint32_t dpb_output_delay_du_length_minus1; //u(5)
uint32_t bit_rate_scale; //u(4)
uint32_t cpb_size_scale; //u(4)
uint32_t cpb_size_du_scale; //u(4)
uint32_t initial_cpb_removal_delay_length_minus1; //u(5)
uint32_t au_cpb_removal_delay_length_minus1; //u(5)
uint32_t dpb_output_delay_length_minus1; //u(5)
bool fixed_pic_rate_general_flag[7]; //u(1)
bool fixed_pic_rate_within_cvs_flag[7]; //u(1)
uint32_t elemental_duration_in_tc_minus1[7]; //ue(v)
bool low_delay_hrd_flag[7]; //u(1)
uint32_t cpb_cnt_minus1[7]; //ue(v)
//sub_layer_hrd_parameters()
H265SubLayerHrdParameters sub_layer_hrd_parameters_0[7];
//sub_layer_hrd_parameters()
H265SubLayerHrdParameters sub_layer_hrd_parameters_1[7];
} H265HrdParameters;
typedef struct {
bool aspect_ratio_info_present_flag; //u(1)
uint32_t aspect_ratio_idc; //u(8)
uint32_t sar_width; //u(16)
uint32_t sar_height; //u(16)
bool overscan_info_present_flag; //u(1)
bool overscan_appropriate_flag; //u(1)
bool video_signal_type_present_flag; //u(1)
uint32_t video_format; //u(3)
bool video_full_range_flag; //u(1)
bool colour_description_present_flag; //u(1)
uint32_t colour_primaries; //u(8)
uint32_t transfer_characteristics; //u(8)
uint32_t matrix_coeffs; //u(8)
bool chroma_loc_info_present_flag; //u(1)
uint32_t chroma_sample_loc_type_top_field; //ue(v)
uint32_t chroma_sample_loc_type_bottom_field; //ue(v)
bool neutral_chroma_indication_flag; //u(1)
bool field_seq_flag; //u(1)
bool frame_field_info_present_flag; //u(1)
bool default_display_window_flag; //u(1)
uint32_t def_disp_win_left_offset; //ue(v)
uint32_t def_disp_win_right_offset; //ue(v)
uint32_t def_disp_win_top_offset; //ue(v)
uint32_t def_disp_win_bottom_offset; //ue(v)
bool vui_timing_info_present_flag; //u(1)
uint32_t vui_num_units_in_tick; //u(32)
uint32_t vui_time_scale; //u(32)
bool vui_poc_proportional_to_timing_flag; //u(1)
uint32_t vui_num_ticks_poc_diff_one_minus1; //ue(v)
bool vui_hrd_parameters_present_flag; //u(1)
//hrd_parameters()
H265HrdParameters hrd_parameters;
bool bitstream_restriction_flag; //u(1)
bool tiles_fixed_structure_flag; //u(1)
bool motion_vectors_over_pic_boundaries_flag; //u(1)
bool restricted_ref_pic_lists_flag; //u(1)
uint32_t min_spatial_segmentation_idc; //ue(v)
uint32_t max_bytes_per_pic_denom; //ue(v)
uint32_t max_bits_per_min_cu_denom; //ue(v)
uint32_t log2_max_mv_length_horizontal; //ue(v)
uint32_t log2_max_mv_length_vertical; //ue(v)
} H265VuiParameters;
typedef struct {
uint32_t rbsp_stop_one_bit; /* equal to 1 */
uint32_t rbsp_alignment_zero_bit; /* equal to 0 */
} H265RbspTrailingBits;
struct SpsData {
uint32_t sps_video_parameter_set_id; //u(4)
uint32_t sps_max_sub_layers_minus1; //u(3)
bool sps_temporal_id_nesting_flag; //u(1)
//profile_tier_level( sps_max_sub_layers_minus1 )
H265ProfileTierLevel profile_tier_level;
uint32_t sps_seq_parameter_set_id; //ue(v)
uint32_t chroma_format_idc; //ue(v)
bool separate_colour_plane_flag; //u(1)
uint32_t pic_width_in_luma_samples; //ue(v)
uint32_t pic_height_in_luma_samples; //ue(v)
uint32_t max_cu_width;
uint32_t max_cu_height;
uint32_t max_cu_depth;
bool conformance_window_flag; //u(1)
uint32_t conf_win_left_offset; //ue(v)
uint32_t conf_win_right_offset; //ue(v)
uint32_t conf_win_top_offset; //ue(v)
uint32_t conf_win_bottom_offset; //ue(v)
uint32_t bit_depth_luma_minus8; //ue(v)
uint32_t bit_depth_chroma_minus8; //ue(v)
uint32_t log2_max_pic_order_cnt_lsb_minus4; //ue(v)
bool sps_sub_layer_ordering_info_present_flag; //u(1)
uint32_t sps_max_dec_pic_buffering_minus1[6]; //ue(v)
uint32_t sps_max_num_reorder_pics[6]; //ue(v)
uint32_t sps_max_latency_increase_plus1[6]; //ue(v)
uint32_t log2_min_luma_coding_block_size_minus3; //ue(v)
uint32_t log2_diff_max_min_luma_coding_block_size; //ue(v)
uint32_t log2_min_transform_block_size_minus2; //ue(v)
uint32_t log2_diff_max_min_transform_block_size; //ue(v)
uint32_t max_transform_hierarchy_depth_inter; //ue(v)
uint32_t max_transform_hierarchy_depth_intra; //ue(v)
bool scaling_list_enabled_flag; //u(1)
bool sps_scaling_list_data_present_flag; //u(1)
//scaling_list_data()
H265ScalingListData scaling_list_data;
bool amp_enabled_flag; //u(1)
bool sample_adaptive_offset_enabled_flag; //u(1)
bool pcm_enabled_flag; //u(1)
uint32_t pcm_sample_bit_depth_luma_minus1; //u(4)
uint32_t pcm_sample_bit_depth_chroma_minus1; //u(4)
uint32_t log2_min_pcm_luma_coding_block_size_minus3; //ue(v)
uint32_t log2_diff_max_min_pcm_luma_coding_block_size; //ue(v)
bool pcm_loop_filter_disabled_flag; //u(1)
uint32_t num_short_term_ref_pic_sets; //ue(v)
//short_term_ref_pic_set(i) max is 64
H265ShortTermRPS stRPS[64];
H265LongTermRPS ltRPS;
//H265_short_term_ref_pic_set_t short_term_ref_pic_set[64];
bool long_term_ref_pics_present_flag; //u(1)
uint32_t num_long_term_ref_pics_sps; //ue(v)
//max is 32
uint32_t lt_ref_pic_poc_lsb_sps[32]; //u(v)
bool used_by_curr_pic_lt_sps_flag[32]; //u(1)
bool sps_temporal_mvp_enabled_flag; //u(1)
bool strong_intra_smoothing_enabled_flag; //u(1)
bool vui_parameters_present_flag; //u(1)
//vui_parameters()
H265VuiParameters vui_parameters;
bool sps_extension_flag; //u(1)
bool sps_extension_data_flag; //u(1)
//rbsp_trailing_bits( )
H265RbspTrailingBits rbsp_trailing_bits;
SpsData(void) {
memset(this, 0, sizeof(*this));
}
bool Parse(uint8_t *data, size_t size);
void ParsePTL(H265ProfileTierLevel *ptl, bool profile_present_flag, uint32_t max_num_sub_layers_minus1, uint8_t *nalu, size_t size, size_t &offset);
void ParseSubLayerHrdParameters(H265SubLayerHrdParameters *sub_hrd, uint32_t CpbCnt, bool sub_pic_hrd_params_present_flag, uint8_t *nalu, size_t size, size_t &offset);
void ParseHrdParameters(H265HrdParameters *hrd, bool common_inf_present_flag, uint32_t max_num_sub_layers_minus1, uint8_t *nalu, size_t size, size_t &offset);
static void ParseScalingList(H265ScalingListData * s_data, uint8_t *data, size_t size,size_t &offset);
void ParseVUI(H265VuiParameters *vui, uint32_t max_num_sub_layers_minus1, uint8_t *data, size_t size,size_t &offset);
void ParseShortTermRefPicSet(H265ShortTermRPS *rps, int32_t st_rps_idx, uint32_t num_short_term_ref_pic_sets, H265ShortTermRPS rps_ref[], uint8_t *data, size_t size,size_t &offset);
};
struct PpsData {
uint32_t pps_pic_parameter_set_id; //ue(v)
uint32_t pps_seq_parameter_set_id; //ue(v)
bool dependent_slice_segments_enabled_flag; //u(1)
bool output_flag_present_flag; //u(1)
uint32_t num_extra_slice_header_bits; //u(3)
bool sign_data_hiding_enabled_flag; //u(1)
bool cabac_init_present_flag; //u(1)
uint32_t num_ref_idx_l0_default_active_minus1; //ue(v)
uint32_t num_ref_idx_l1_default_active_minus1; //ue(v)
int32_t init_qp_minus26; //se(v)
bool constrained_intra_pred_flag; //u(1)
bool transform_skip_enabled_flag; //u(1)
bool cu_qp_delta_enabled_flag; //u(1)
uint32_t diff_cu_qp_delta_depth; //ue(v)
int32_t pps_cb_qp_offset; //se(v)
int32_t pps_cr_qp_offset; //se(v)
bool pps_slice_chroma_qp_offsets_present_flag; //u(1)
bool weighted_pred_flag; //u(1)
bool weighted_bipred_flag; //u(1)
bool transquant_bypass_enabled_flag; //u(1)
bool tiles_enabled_flag; //u(1)
bool entropy_coding_sync_enabled_flag; //u(1)
uint32_t num_tile_columns_minus1; //ue(v)
uint32_t num_tile_rows_minus1; //ue(v)
bool uniform_spacing_flag; //u(1)
//PicWidthInCtbsY = Ceil( pic_width_in_luma_samples / CtbSizeY ) = 256 assume max width is 4096
//CtbSizeY = 1<<CtbLog2SizeY so min is 16
// 4 <= CtbLog2SizeY <= 6
uint32_t column_width_minus1[265]; //ue(v)
//2304/16=144 assume max height is 2304
uint32_t row_height_minus1[144]; //ue(v)
bool loop_filter_across_tiles_enabled_flag; //u(1)
bool pps_loop_filter_across_slices_enabled_flag; //u(1)
bool deblocking_filter_control_present_flag; //u(1)
bool deblocking_filter_override_enabled_flag; //u(1)
bool pps_deblocking_filter_disabled_flag; //u(1)
int32_t pps_beta_offset_div2; //se(v)
int32_t pps_tc_offset_div2; //se(v)
bool pps_scaling_list_data_present_flag; //u(1)
//scaling_list_data( )
H265ScalingListData scaling_list_data;
bool lists_modification_present_flag; //u(1)
uint32_t log2_parallel_merge_level_minus2; //ue(v)
bool slice_segment_header_extension_present_flag; //u(1)
bool pps_extension_flag; //u(1)
bool pps_extension_data_flag; //u(1)
//rbsp_trailing_bits( )
H265RbspTrailingBits rbsp_trailing_bits;
PpsData(void) {
memset(this, 0, sizeof(*this));
}
bool Parse(uint8_t *data, size_t size);
};
// See ITU-T Rec. H.264 (04/2013) Advanced video coding for generic audiovisual services, page 28, 91.
struct AccessUnitSigns {
bool b_new_picture;
AccessUnitSigns() : b_new_picture(false) {}
bool Parse(uint8_t *data, size_t size, std::map<uint32_t,SpsData> &sps_map, std::map<uint32_t,PpsData> &pps_map);
bool IsNewPicture();
};
class ExtraDataBuilder {
public:
ExtraDataBuilder() : m_sps_count_(0), m_pps_count_(0) {}
void AddSPS(uint8_t *sps, size_t size);
void AddPPS(uint8_t *pps, size_t size);
bool GetExtradata(ByteArray &extradata);
private:
ByteArray m_sps_;
ByteArray m_pps_;
int32_t m_sps_count_;
int32_t m_pps_count_;
};
friend struct AccessUnitSigns;
static const uint8_t nal_unit_length_size_ = 4U;
static const size_t m_read_size_ = 1024*4;
static const uint16_t max_sps_size_ = 0xFFFF;
static const uint16_t min_sps_size_ = 5;
static const uint16_t max_pps_size_ = 0xFFFF;
NalUnitHeader ReadNextNaluUnit(size_t *offset, size_t *nalu, size_t *size);
void FindSPSandPPS();
static inline NalUnitHeader GetNaluUnitType(uint8_t *nal_unit) {
NalUnitHeader nalu_header;
nalu_header.num_emu_byte_removed = 0;
//read nalu header
nalu_header.forbidden_zero_bit = (uint32_t) ((nal_unit[0] >> 7)&1);
nalu_header.nal_unit_type = (uint32_t) ((nal_unit[0] >> 1)&63);
nalu_header.nuh_layer_id = (uint32_t) (((nal_unit[0]&1) << 6) | ((nal_unit[1] & 248) >> 3));
nalu_header.nuh_temporal_id_plus1 = (uint32_t) (nal_unit[1] & 7);
return nalu_header;
}
size_t EBSPtoRBSP(uint8_t *streamBuffer,size_t begin_bytepos, size_t end_bytepos);
ByteArray m_read_data_;
ByteArray m_extra_data_;
ByteArray m_EBSP_to_RBSP_data_;
bool m_use_start_codes_;
int64_t m_current_frame_timestamp_;
std::map<uint32_t,SpsData> m_sps_map_;
std::map<uint32_t,PpsData> m_pps_map_;
size_t m_packet_count_;
bool m_eof_;
double m_fps_;
size_t m_max_frames_number_;
// data stream info
uint8_t* m_pmemory_;
size_t m_memory_size_;
size_t m_allocated_size_;
size_t m_pos_;
ParserResult Close();
ParserResult Read(void* p_data, size_t size, size_t* p_read);
ParserResult Write(const void* p_data, size_t size, size_t* p_written);
ParserResult Seek(ParserSeekOrigin e_origin, int64_t i_position, int64_t* p_new_position);
ParserResult GetSize(int64_t* p_size);
ParserResult Realloc(size_t size);
};
@@ -0,0 +1,108 @@
/*
Copyright (c) 2023 Advanced Micro Devices, Inc. All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.
*/
#include "parser_buffer.h"
ParserBuffer::ParserBuffer() :
m_buffer_(NULL),
m_packet_size_(0),
m_duration_(0),
m_current_timestamp_(0) {}
ParserBuffer::~ParserBuffer () {
if (m_buffer_) {
delete[] m_buffer_;
}
m_buffer_ = NULL;
m_packet_size_ = 0;
m_duration_ = 0;
m_current_timestamp_ = 0;
}
int64_t ParserBuffer::GetPts() const {
return m_current_timestamp_;
}
void ParserBuffer::SetPts(int64_t pts) {
if (pts == m_current_timestamp_) {
return;
}
m_current_timestamp_ = pts;
}
int64_t ParserBuffer::GetDuration() const {
return m_duration_;
}
void ParserBuffer::SetDuration(int64_t duration) {
m_duration_ = duration;
}
bool ParserBuffer::IsReusable() { return PARSER_NOT_IMPLEMENTED; }
ParserResult ParserBuffer::SetSize(size_t new_size) {
m_packet_size_ = new_size;
return PARSER_OK;
}
size_t ParserBuffer::GetSize() {
return m_packet_size_;
}
void* ParserBuffer::GetNative() {
return m_buffer_;
}
void ParserBuffer::SetNative(size_t size) {
m_buffer_ = new uint8_t[size];
}
ParserResult ParserBuffer::AllocBuffer(ParserMemoryType type, size_t size, ParserBuffer** pp_buffer) {
ParserResult res = PARSER_OK;
switch(type) {
case PARSER_MEMORY_HOST: {
ParserBuffer* p_new_buffer = new ParserBuffer;
if (p_new_buffer != NULL) {
p_new_buffer->SetNative(size);
res = p_new_buffer->SetSize(size);
if (res != PARSER_OK) {
return res;
}
*pp_buffer = p_new_buffer;
}
}
break;
case PARSER_MEMORY_HIP: {
res = PARSER_NOT_IMPLEMENTED;
}
break;
case PARSER_MEMORY_UNKNOWN:{
res = PARSER_NOT_IMPLEMENTED;
}
break;
default: {
res = PARSER_INVALID_ARG;
}
break;
}
return res;
}
@@ -0,0 +1,69 @@
/*
Copyright (c) 2023 Advanced Micro Devices, Inc. All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.
*/
#ifndef PARSERBUFFER_H
#define PARSERBUFFER_H
#pragma once
#include <cstdint>
#include <cstring>
#include <memory>
#include <ctime>
#include <chrono>
#include "roc_video_parser.h"
typedef enum ParserMemoryType {
PARSER_MEMORY_UNKNOWN = 0,
PARSER_MEMORY_HOST = 1,
PARSER_MEMORY_HIP = 2,
} ParserMemoryType;
class ParserBuffer {
public:
ParserBuffer();
virtual ~ParserBuffer();
virtual ParserResult SetSize(size_t new_size);
virtual size_t GetSize();
virtual void* GetNative();
virtual void SetNative(size_t size);
//parser data functions
virtual bool IsReusable();
virtual void SetPts(int64_t pts);
virtual int64_t GetPts() const;
virtual void SetDuration(int64_t duration);
virtual int64_t GetDuration() const;
static ParserResult AllocBuffer(ParserMemoryType type, size_t size, ParserBuffer** pp_buffer);
private:
int64_t m_current_timestamp_;
int64_t m_duration_;
size_t m_packet_size_;
uint8_t* m_buffer_;
};
// smart pointer
typedef std::shared_ptr<ParserBuffer> ParserBufferPtr;
#endif // PARSERBUFFER_H
@@ -51,3 +51,117 @@ protected:
PFNVIDDISPLAYCALLBACK pfn_display_picture_cb_; /**< Called whenever a picture is ready to be displayed (display order) */
PFNVIDSEIMSGCALLBACK pfn_get_sei_message_cb_; /**< Called when all SEI messages are parsed for particular frame */
};
enum ParserSeekOrigin {
PARSER_SEEK_BEGIN = 0,
PARSER_SEEK_CURRENT = 1,
PARSER_SEEK_END = 2,
};
typedef enum ParserResult {
PARSER_OK = 0,
PARSER_FAIL ,
// common errors
PARSER_UNEXPECTED ,
PARSER_ACCESS_DENIED ,
PARSER_INVALID_ARG ,
PARSER_OUT_OF_RANGE ,
PARSER_OUT_OF_MEMORY ,
PARSER_INVALID_POINTER ,
PARSER_NO_INTERFACE ,
PARSER_NOT_IMPLEMENTED ,
PARSER_NOT_SUPPORTED ,
PARSER_NOT_FOUND ,
PARSER_ALREADY_INITIALIZED ,
PARSER_NOT_INITIALIZED ,
PARSER_INVALID_FORMAT ,// invalid data format
PARSER_WRONG_STATE ,
PARSER_FILE_NOT_OPEN ,// cannot open file
PARSER_STREAM_NOT_ALLOCATED ,
// device common codes
PARSER_NO_DEVICE ,
//result codes
PARSER_EOF ,
PARSER_REPEAT ,
//error codes
PARSER_INVALID_DATA_TYPE ,//invalid data type
PARSER_INVALID_RESOLUTION ,//invalid resolution (width or height)
PARSER_CODEC_NOT_SUPPORTED ,//codec not supported
} ParserResult;
// helpers
namespace Parser {
inline char GetLowByte(uint16_t data) {
return (data >> 8);
}
inline char GetHiByte(uint16_t data) {
return (data & 0xFF);
}
inline bool GetBit(const uint8_t *data, size_t &bit_idx) {
bool ret = (data[bit_idx / 8] >> (7 - bit_idx % 8) & 1);
bit_idx++;
return ret;
}
inline uint32_t GetBitToUint32(const uint8_t *data, size_t &bit_idx) {
uint32_t ret = (data[bit_idx / 8] >> (7 - bit_idx % 8) & 1);
bit_idx++;
return ret;
}
inline uint32_t ReadBits(const uint8_t *data, size_t &start_bit_idx, size_t bits_to_read) {
if (bits_to_read > 32) {
return 0; // assert(0);
}
uint32_t result = 0;
for (size_t i = 0; i < bits_to_read; i++) {
result = result << 1;
result |= GetBitToUint32(data, start_bit_idx); // start_bit_idx incremented inside
}
return result;
}
inline size_t CountContiniusZeroBits(const uint8_t *data, size_t &start_bit_idx) {
size_t start_bit_idx_org = start_bit_idx;
while (GetBit(data, start_bit_idx) == false) {} // start_bit_idx incremented inside
start_bit_idx--; // remove non zero
return start_bit_idx - start_bit_idx_org;
}
namespace ExpGolomb {
inline uint32_t ReadUe(const uint8_t *data, size_t &start_bit_idx) {
size_t zero_bits_count = CountContiniusZeroBits(data, start_bit_idx); // start_bit_idx incremented inside
if (zero_bits_count > 30) {
return 0; // assert(0)
}
uint32_t left_part = (0x1 << zero_bits_count) - 1;
start_bit_idx++;
uint32_t rightPart = ReadBits(data, start_bit_idx, zero_bits_count);
return left_part + rightPart;
}
inline uint32_t ReadSe(const uint8_t *data, size_t &start_bit_idx) {
uint32_t ue = ReadUe(data, start_bit_idx);
// se From Ue
uint32_t mod2 = ue % 2;
uint32_t r = ue / 2 + mod2;
if (mod2 == 0) {
return r * -1;
}
return r;
}
}
}