blob: 4d7d189a49474253e636dd46795269b28e8d3860 (
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
#ifndef OPENALPLAYER_H_3PORVJDU
#define OPENALPLAYER_H_3PORVJDU
#include <iostream>
#include <string.h>
#include <stdlib.h>
#include <sstream>
#include <uscxml/concurrency/tinythread.h>
#include <al.h>
#include <alc.h>
// sometimes the stream drops if this is less than 5000 bytes
#define ALPLAY_NR_AUDIO_BUFFERS 3
#define ALPLAY_AUDIO_BUFFER_SIZE 2048
//#define ALPLAYER_FORMAT_MONO16 0x1101
class OpenALPlayer;
class OpenALPlayerCallback {
public:
virtual ~OpenALPlayerCallback() {}
/*
* Returning an OpenALPlayerCallback is a hack to be able to provide a typemap for SWIG.
* We cannot use SWIG directors with byte arrays otherwise. Posted to swig-ML already.
*/
virtual OpenALPlayerCallback* getSamples(char* buffer, int size, OpenALPlayer* player) = 0;
};
class OpenALPlayer {
private:
ALCcontext* _context;
ALuint _alId;
ALfloat _position[3];
ALfloat _velocity[3];
ALfloat _direction[3];
ALfloat _pitch;
ALfloat _gain;
ALfloat _referenceDistance;
ALboolean _isLooping;
// OpenAL is not really thread safe
static tthread::recursive_mutex _alMutex;
ALenum _format;
ALsizei _freq;
int _msForBuffer;
int _initialSleep;
int _bufferSleep;
int _repollSleep;
int _bufferSize;
int _nrBuffers;
ALuint* _bufferIds;
char** _buffers;
OpenALPlayerCallback* _audioCallback;
void* _userData;
tthread::thread* _thread;
bool _isStarted;
bool _isInitialized;
void updateBuffers();
void init();
void checkOpenALError(int line);
// static wrapper as an entry point for pthreads
static void updateBuffersWrapper(void *obj);
// get the index in _buffers for a buffer ID
int inline bufferIndex(int bufferId);
public:
OpenALPlayer(ALCcontext*, OpenALPlayerCallback*, ALenum, ALsizei);
virtual ~OpenALPlayer();
unsigned int isPlaying();
ALfloat* getPosition();
void setPosition(ALfloat[3]);
ALfloat* getVelocity();
void setVelocity(ALfloat[3]);
ALfloat* getDirection();
void setDirection(ALfloat[3]);
void setBufferSize(int bufferSize);
int getBufferSize();
void setNrBuffers(int nrBuffers);
int getNrBuffers();
// callback interface for pull
OpenALPlayerCallback* getCallback();
void setCallback(OpenALPlayerCallback* callback);
// stream interface for push
int write(char* buffer, int size, int* repollAt, bool blocking = false);
void* getUserData();
void setUserData(void* userData);
void start();
void stop();
};
#endif /* end of include guard: OPENALPLAYER_H_3PORVJDU */
|
