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
|
#include "common.h"
void CToxProto::OnAvInvite(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvRinging(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvStart(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvEnd(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvReject(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvCancel(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvCsChange(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvRequestTimeout(void*, int32_t callId, void *arg) { }
void CToxProto::OnAvPeerTimeout(void*, int32_t callId, void *arg) { }
void CToxProto::OnFriendAudio(void*, int32_t callId, const int16_t *PCM, uint16_t size, void *arg)
{
CToxProto *proto = (CToxProto*)arg;
ToxAvCSettings dest;
if (toxav_get_peer_csettings(proto->toxAv, callId, 0, &dest) != av_ErrorNone)
{
proto->debugLogA(__FUNCTION__": failed to get codec settings");
toxav_stop_call(proto->toxAv, callId);
return;
}
if (dest.call_type != av_TypeAudio)
{
proto->debugLogA(__FUNCTION__": failed to play video");
toxav_stop_call(proto->toxAv, callId);
return;
}
WAVEFORMATEX wfx = { 0 };
wfx.wFormatTag = WAVE_FORMAT_PCM;
wfx.nChannels = dest.audio_channels;
wfx.wBitsPerSample = dest.audio_bitrate;
wfx.nSamplesPerSec = dest.audio_sample_rate;
wfx.nBlockAlign = (wfx.nChannels * wfx.wBitsPerSample) / 8;
wfx.nAvgBytesPerSec = wfx.nSamplesPerSec * wfx.nBlockAlign;
DWORD deviceId = proto->getDword("AudioOutputDeviceID", -1);
if (deviceId != av_ErrorNone)
{
proto->debugLogA(__FUNCTION__": failed to get device id");
toxav_stop_call(proto->toxAv, callId);
return;
}
HWAVEOUT hDevice;
MMRESULT result = waveOutOpen(&hDevice, deviceId, &wfx, 0, 0, CALLBACK_NULL | WAVE_FORMAT_DIRECT);
if (result != MMSYSERR_NOERROR)
{
proto->debugLogA(__FUNCTION__": failed to open audio device");
toxav_stop_call(proto->toxAv, callId);
return;
}
WAVEHDR header;// = { 0 };
ZeroMemory(&header, sizeof(WAVEHDR));
header.lpData = (LPSTR)PCM;
header.dwBufferLength = size;
result = waveOutPrepareHeader(hDevice, &header, sizeof(WAVEHDR));
if (result != MMSYSERR_NOERROR)
{
proto->debugLogA(__FUNCTION__": failed to prepare audio device header");
toxav_stop_call(proto->toxAv, callId);
return;
}
result = waveOutWrite(hDevice, &header, sizeof(WAVEHDR));
if (result != MMSYSERR_NOERROR)
{
proto->debugLogA(__FUNCTION__": failed to write to audio device");
toxav_stop_call(proto->toxAv, callId);
return;
}
do
{
Sleep(100);
result = waveOutUnprepareHeader(hDevice, &header, sizeof(WAVEHDR));
} while (result == WAVERR_STILLPLAYING);
if (result != MMSYSERR_NOERROR)
{
proto->debugLogA(__FUNCTION__": failed to unprepare audio device header");
toxav_stop_call(proto->toxAv, callId);
return;
}
waveOutClose(hDevice);
}
|
