summaryrefslogtreecommitdiff
path: root/decoders/mpg123_decoder.cpp
blob: 0618320decd5f4d39e541827fabab0d97223fc36 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
#include "mpg123_decoder.h"

#include <boost/format.hpp>

#include <iostream>
#include <stdexcept>

DecoderMpg123::DecoderMpg123() {
	int error;
	handle = mpg123_new("generic", &error);
	if(error) {
		throw std::runtime_error(mpg123_plain_strerror(error));
	}

	error = mpg123_open_feed(handle);
	if(error) {
		throw std::runtime_error(mpg123_plain_strerror(error));
	}

	mpg123_format_none(handle);
	mpg123_format(handle, 44100, 2, MPG123_ENC_SIGNED_16);
}

DecoderMpg123::~DecoderMpg123() {
	mpg123_close(handle);
	mpg123_delete(handle);
}

size_t DecoderMpg123::decode(const uint8_t *input, size_t input_size, uint8_t *output, size_t output_size) {
	if(mpg123_feed(handle, input, input_size) != MPG123_OK) {
		throw std::runtime_error(mpg123_strerror(handle));
	}

	size_t output_written;
	int error = mpg123_read(handle, output, output_size, &output_written);

	if(error == MPG123_NEW_FORMAT) {
		long rate;
		int channels, enc;
		mpg123_getformat(handle, &rate, &channels, &enc);
		std::cout << boost::format("mpg123: New format: %li Hz, %i channels, encoding value %i") % rate % channels % enc << std::endl;
		error = mpg123_read(handle, output, output_size, &output_written);
	}

	if(error != MPG123_OK && error != MPG123_DONE && error != MPG123_NEED_MORE) {
		throw std::runtime_error(mpg123_plain_strerror(error));
	}

	return output_written;
}

size_t DecoderMpg123::decode(ReadFunc read, uint8_t *output, size_t output_size) {
	char src_data[0x2000];
	std::streamsize src_read = read(src_data, 0x2000);
	if(src_read < 0)
		src_read = 0;
	return decode((const uint8_t*)src_data, src_read, (uint8_t*)output, output_size);
}