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
|
//=============================================================================
// MusE
// Linux Music Editor
// $Id:$
//
// Copyright (C) 2002-2006 by Werner Schweer and others
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License version 2.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
//=============================================================================
#include <poll.h>
#include "audiowriteback.h"
#include "globals.h"
#include "audio.h"
#include "song.h"
AudioWriteback* audioWriteback;
//---------------------------------------------------------
// AudioWriteback
//---------------------------------------------------------
AudioWriteback::AudioWriteback(const char* name)
: Thread(name)
{
counter = 0;
}
//---------------------------------------------------------
// readMsg
//---------------------------------------------------------
static void readMsgP(void* p, void*)
{
AudioWriteback* at = (AudioWriteback*)p;
at->readMsg1(1);
}
//---------------------------------------------------------
// start
//---------------------------------------------------------
void AudioWriteback::start(int priority)
{
clearPollFd();
addPollFd(toThreadFdr, POLLIN, ::readMsgP, this, 0);
Thread::start(priority);
}
//---------------------------------------------------------
// processMsg
//---------------------------------------------------------
void AudioWriteback::processMsg1(const void*)
{
while (counter) {
//q_atomic_decrement(&counter);
--counter;
OutputList* ol = song->outputs();
if (!ol->empty()) {
AudioOutput* ao = ol->front();
if (ao->recordFlag())
ao->record();
}
WaveTrackList* tl = song->waves();
for (iWaveTrack t = tl->begin(); t != tl->end(); ++t) {
WaveTrack* track = *t;
if (track->recordFlag())
track->record();
}
}
}
//---------------------------------------------------------
// trigger
// trigger audio writeback loop
//---------------------------------------------------------
void AudioWriteback::trigger()
{
// q_atomic_increment(&counter);
++counter;
if (counter < 2) {
if (sendMsg1("0", 1)) {
printf("AudioWriteback::msgTick(): send failed!\n");
}
}
}
|
