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
107
108
109
110
111
112
|
#ifndef INCLUDED_AUDIOIO_DB_SERVER_H
#define INCLUDED_AUDIOIO_DB_SERVER_H
#include <map>
#include "audioio.h"
#include "audioio-db-buffer.h"
class AUDIO_IO_DB_SERVER_impl;
/**
* Audio i/o engine. Meant for serving all double-buffered client
* audio objects (AUDIO_IO_DB_CLIENT).
*
* @author Kai Vehmanen
*/
class AUDIO_IO_DB_SERVER {
friend void* start_db_server_io_thread(void *ptr);
public:
/** @name Constructors and dtors */
/*@{*/
AUDIO_IO_DB_SERVER (void);
~AUDIO_IO_DB_SERVER(void);
/*@}*/
/** @name Public functions for acquiring status information */
/*@{*/
bool is_running(void) const;
bool is_full(void) const;
/*@}*/
/** @name Public functions for transport control */
/*@{*/
void start(void);
void stop(void);
void flush(void);
/*@}*/
/** @name Public functions for reporting client activity */
/*@{*/
void signal_client_activity(void);
/*@}*/
/** @name Public functions for waiting on server conditions */
/*@{*/
void wait_for_full(void);
void wait_for_stop(void);
void wait_for_flush(void);
/*@}*/
/** @name Public functions for configuration */
/*@{*/
void set_buffer_defaults(int buffers, long int buffersize);
void register_client(AUDIO_IO* abject);
void unregister_client(AUDIO_IO* abject);
AUDIO_IO_DB_BUFFER* get_client_buffer(AUDIO_IO* abject);
/*@}*/
private:
static const int buffercount_default;
static const long int buffersize_default;
std::vector<AUDIO_IO_DB_BUFFER*> buffers_rep;
std::vector<AUDIO_IO*> clients_rep;
std::map<AUDIO_IO*, int> client_map_rep;
AUDIO_IO_DB_SERVER_impl* impl_repp;
bool thread_running_rep;
ATOMIC_INTEGER exit_ok_rep;
ATOMIC_INTEGER exit_request_rep;
ATOMIC_INTEGER stop_request_rep;
ATOMIC_INTEGER running_rep;
ATOMIC_INTEGER full_rep;
int buffercount_rep;
long int buffersize_rep;
int schedpriority_rep;
AUDIO_IO_DB_SERVER& operator=(const AUDIO_IO_DB_SERVER& x) { return *this; }
AUDIO_IO_DB_SERVER (const AUDIO_IO_DB_SERVER& x) { }
void io_thread(void);
void wait_for_client_activity(void);
void signal_full(void);
void signal_stop(void);
void signal_flush(void);
void dump_profile_counters(void);
};
#endif
|
