vgmstream/src/meta/opus_interleave_streamfile.h
2020-03-09 00:58:50 +01:00

48 lines
1.5 KiB
C

#ifndef _OPUS_INTERLEAVE_STREAMFILE_H_
#define _OPUS_INTERLEAVE_STREAMFILE_H_
#include "deblock_streamfile.h"
static void block_callback(STREAMFILE* sf, deblock_io_data* data) {
uint32_t chunk_size = read_u32be(data->physical_offset, sf);
//todo not ok if offset between 0 and header_size
if (chunk_size == 0x01000080) /* header */
chunk_size = read_u32le(data->physical_offset + 0x10, sf) + 0x08;
else
chunk_size += 0x08;
data->block_size = chunk_size;
data->data_size = data->block_size;
}
/* Deblocks NXOPUS streams that interleave 1 packet per stream */
static STREAMFILE* setup_opus_interleave_streamfile(STREAMFILE* sf, off_t start_offset, int stream_number, int stream_count) {
STREAMFILE* new_sf = NULL;
deblock_config_t cfg = {0};
cfg.stream_start = start_offset;
cfg.step_start = stream_number;
cfg.step_count = stream_count;
{
int i;
off_t offset = start_offset;
/* read full size from NXOPUS header N */
for (i = 0; i < stream_number + 1; i++) {
off_t start = read_s32le(offset + 0x10, sf);
off_t size = read_s32le(offset + start + 0x04, sf);
if (i == stream_number)
cfg.logical_size = 0x08 + start + size;
offset += 0x08 + start;
}
}
cfg.block_callback = block_callback;
new_sf = open_wrap_streamfile(sf);
new_sf = open_io_deblock_streamfile_f(new_sf, &cfg);
//new_sf = open_buffer_streamfile_f(new_sf, 0);
return new_sf;
}
#endif /* _OPUS_INTERLEAVE_STREAMFILE_H_ */