1 #include <stdio.h>

2 #include <assert.h>

3 #include "datapath.h"

4 #include "logger.h"

5 #include "ovstream.h"

6

7 OggVorbisStream::OggVorbisStream()

8 {

9 vfopen = false;

10

11 pthread_mutex_init(&vflock, 0);

12 }

13

14 OggVorbisStream::~OggVorbisStream()

15 {

16 close();

17 }

18

19 bool OggVorbisStream::open(const char *fname)

20 {

21 close();

22

23 pthread_mutex_lock(&vflock);

24

25 std::string fpath = datafile_path(fname);

26 info_log("opening ogg/vorbis stream: %s -> %s\n", (fname && *fname) ? fname : "<not found>", (!fpath.empty()) ? fpath.c_str() : "<not found>");

27

28 if(fpath.empty() || ov_fopen(fpath.c_str(), &vf) != 0) {

29 error_log("failed to open ogg/vorbis stream: %s\n", fname ? fname : "<not found>");

30 pthread_mutex_unlock(&vflock);

31 return false;

32 }

33

34 vfopen = true;

35 pthread_mutex_unlock(&vflock);

36 return true;

37 }

38

39 void OggVorbisStream::close()

40 {

41 pthread_mutex_lock(&vflock);

42 if(vfopen) {

43 ov_clear(&vf);

44 vfopen = false;

45 }

46 pthread_mutex_unlock(&vflock);

47 }

48

49 void OggVorbisStream::play(AUDIO_PLAYMODE mode)

50 {

51 if (vfopen)

52 {

53 AudioStream::play(mode);

54 } else {

55 error_log("failed to play audio track.\n");

56 }

57 }

58

59 void OggVorbisStream::rewind()

60 {

61 pthread_mutex_lock(&vflock);

62 if(vfopen) {

63 ov_raw_seek(&vf, 0);

64 }

65 pthread_mutex_unlock(&vflock);

66 }

67

68 bool OggVorbisStream::more_samples(AudioStreamBuffer *buf)

69 {

70 pthread_mutex_lock(&vflock);

71

72 vorbis_info *vinfo = ov_info(&vf, -1);

73 buf->channels = vinfo->channels;

74 buf->sample_rate = vinfo->rate;

75 assert(buf->channels == 2);

76 assert(buf->sample_rate == 44100);

77

78 long bufsz = AUDIO_BUFFER_BYTES;

79 long total_read = 0;

80 while(total_read < bufsz) {

81 int bitstream;

82 long rd = ov_read(&vf, buf->samples + total_read, bufsz - total_read, 0, 2, 1, &bitstream);

83

84 if(!rd) {

85 bufsz = total_read;

86 } else {

87 total_read += rd;

88 }

89 }

90

91 if(!total_read) {

92 buf->num_samples = 0;

93 pthread_mutex_unlock(&vflock);

94 return false;

95 }

96

97 buf->num_samples = bufsz / vinfo->channels / 2;

98 pthread_mutex_unlock(&vflock);

99 return true;

100 }