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
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
|
#include "api__in_mod.h"
#include "../Winamp/wa_ipc.h"
#include "MODPlayer.h"
#include <libopenmpt/libopenmpt_stream_callbacks_file.h>
#include <nx/nxuri.h>
#include <nx/nxstring.h>
#include <nx/nxfile.h>
#include "../nsutil/pcm.h"
openmpt_module *OpenMod(const wchar_t *filename);
extern int g_duration;
extern In_Module plugin;
// {B6CB4A7C-A8D0-4c55-8E60-9F7A7A23DA0F}
static const GUID playbackConfigGroupGUID =
{
0xb6cb4a7c, 0xa8d0, 0x4c55, { 0x8e, 0x60, 0x9f, 0x7a, 0x7a, 0x23, 0xda, 0xf }
};
static const size_t kModBufferSize = 512;
static const unsigned int kModSampleRate = 44100; // TODO(benski) configurable!
void MODPlayer::MODWait::Wait_SetEvents(HANDLE killswitch, HANDLE seek_event)
{
handles[0]=killswitch;
handles[1]=seek_event;
}
int MODPlayer::MODWait::WaitOrAbort(int time_in_ms)
{
switch(WaitForMultipleObjects(2, handles, FALSE, time_in_ms))
{
case WAIT_TIMEOUT: // all good, wait successful
return 0;
case WAIT_OBJECT_0: // killswitch
return MODPlayer::MOD_STOP;
case WAIT_OBJECT_0+1: // seek event
return MODPlayer::MOD_ABORT;
default: // some OS error?
return MODPlayer::MOD_ERROR;
}
}
MODPlayer::MODPlayer(const wchar_t *_filename) : audio_output(&plugin)
{
filename = _wcsdup(_filename);
m_needseek = -1;
killswitch = CreateEvent(NULL, TRUE, FALSE, NULL);
seek_event = CreateEvent(NULL, TRUE, FALSE, NULL);
audio_output.Wait_SetEvents(killswitch, seek_event);
}
MODPlayer::~MODPlayer()
{
CloseHandle(killswitch);
CloseHandle(seek_event);
free(filename);
}
void MODPlayer::Kill()
{
SetEvent(killswitch);
}
void MODPlayer::Seek(int seek_pos)
{
m_needseek = seek_pos;
SetEvent(seek_event);
}
int MODPlayer::GetOutputTime() const
{
if (m_needseek != -1)
return m_needseek;
else
return plugin.outMod->GetOutputTime();
}
DWORD CALLBACK MODThread(LPVOID param)
{
MODPlayer *player = (MODPlayer *)param;
DWORD ret = player->ThreadFunction();
return ret;
}
DWORD CALLBACK MODPlayer::ThreadFunction()
{
float *float_buffer = 0;
void *int_buffer = 0;
HANDLE handles[] = {killswitch, seek_event};
size_t count = 0;
size_t (*openmpt_read)(openmpt_module * mod, int32_t samplerate, size_t count, float *interleaved_stereo)=openmpt_module_read_interleaved_float_stereo;
int channels = 2;
bool force_mono = AGAVE_API_CONFIG->GetBool(playbackConfigGroupGUID, L"mono", false);
bool surround = AGAVE_API_CONFIG->GetBool(playbackConfigGroupGUID, L"surround", true);
int bits = (int)AGAVE_API_CONFIG->GetUnsigned(playbackConfigGroupGUID, L"bits", 16);
if (force_mono) {
channels = 1;
openmpt_read = openmpt_module_read_float_mono;
} else if (surround) {
channels = 4;
openmpt_read = openmpt_module_read_interleaved_float_quad;
}
// ===== tell audio output helper object about the output plugin =====
audio_output.Init(plugin.outMod);
openmpt_module * mod = OpenMod(filename);
if (!mod) {
goto btfo;
}
openmpt_module_ctl_set(mod, "seek.sync_sample", "1");
g_duration = (int)(openmpt_module_get_duration_seconds(mod) * 1000);
audio_output.Open(0, channels, kModSampleRate, bits);
float_buffer = (float *)malloc(sizeof(float) * kModBufferSize * channels);
int_buffer = malloc(kModBufferSize * channels * bits/8);
while (WaitForMultipleObjects(2, handles, FALSE, 0) != WAIT_OBJECT_0) {
count = openmpt_read(mod, kModSampleRate, kModBufferSize, float_buffer);
if (count == 0) {
break;
}
nsutil_pcm_FloatToInt_Interleaved(int_buffer, float_buffer, bits, channels*count);
int ret = audio_output.Write((char *)int_buffer, channels*count*bits/8);
if (ret == MOD_STOP) {
break;
} else if (ret == MOD_ABORT) {
ResetEvent(seek_event);
openmpt_module_set_position_seconds(mod, m_needseek/1000.0);
audio_output.Flush(m_needseek);
m_needseek = -1;
} else if (ret != MOD_CONTINUE) {
ret = ret;
}
}
if (WaitForSingleObject(killswitch, 0) != WAIT_OBJECT_0) {
audio_output.Write(0,0);
audio_output.WaitWhilePlaying();
if (WaitForSingleObject(killswitch, 0) != WAIT_OBJECT_0) {
PostMessage(plugin.hMainWindow, WM_WA_MPEG_EOF, 0, 0);
}
}
audio_output.Close();
openmpt_module_destroy(mod);
free(float_buffer);
free(int_buffer);
return 0;
btfo: // bail the fuck out
if (WaitForSingleObject(killswitch, 0) != WAIT_OBJECT_0) {
PostMessage(plugin.hMainWindow, WM_WA_MPEG_EOF, 0, 0);
}
audio_output.Close();
openmpt_module_destroy(mod);
free(float_buffer);
free(int_buffer);
return 1;
}
|
