|
Packit |
1fb8d4 |
/**
|
|
Packit |
1fb8d4 |
* FreeRDP: A Remote Desktop Protocol Implementation
|
|
Packit |
1fb8d4 |
* FreeRDP Mac OS X Server (Audio Output)
|
|
Packit |
1fb8d4 |
*
|
|
Packit |
1fb8d4 |
* Copyright 2012 Marc-Andre Moreau <marcandre.moreau@gmail.com>
|
|
Packit |
1fb8d4 |
* Copyright 2015 Thincast Technologies GmbH
|
|
Packit |
1fb8d4 |
* Copyright 2015 DI (FH) Martin Haimberger <martin.haimberger@thincast.com>
|
|
Packit |
1fb8d4 |
*
|
|
Packit |
1fb8d4 |
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
Packit |
1fb8d4 |
* you may not use this file except in compliance with the License.
|
|
Packit |
1fb8d4 |
* You may obtain a copy of the License at
|
|
Packit |
1fb8d4 |
*
|
|
Packit |
1fb8d4 |
* http://www.apache.org/licenses/LICENSE-2.0
|
|
Packit |
1fb8d4 |
*
|
|
Packit |
1fb8d4 |
* Unless required by applicable law or agreed to in writing, software
|
|
Packit |
1fb8d4 |
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
Packit |
1fb8d4 |
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
Packit |
1fb8d4 |
* See the License for the specific language governing permissions and
|
|
Packit |
1fb8d4 |
* limitations under the License.
|
|
Packit |
1fb8d4 |
*/
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
#ifdef HAVE_CONFIG_H
|
|
Packit |
1fb8d4 |
#include "config.h"
|
|
Packit |
1fb8d4 |
#endif
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
#include <freerdp/server/rdpsnd.h>
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
#include "mf_info.h"
|
|
Packit |
1fb8d4 |
#include "mf_rdpsnd.h"
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
#include <winpr/sysinfo.h>
|
|
Packit |
1fb8d4 |
#include <freerdp/server/server-common.h>
|
|
Packit |
1fb8d4 |
#include <freerdp/log.h>
|
|
Packit |
1fb8d4 |
#define TAG SERVER_TAG("mac")
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
AQRecorderState recorderState;
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
static void mf_peer_rdpsnd_activated(RdpsndServerContext* context)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
OSStatus status;
|
|
Packit |
1fb8d4 |
int i, j;
|
|
Packit |
1fb8d4 |
BOOL formatAgreed = FALSE;
|
|
Packit |
1fb8d4 |
AUDIO_FORMAT* agreedFormat = NULL;
|
|
Packit Service |
5a9772 |
// we should actually loop through the list of client formats here
|
|
Packit Service |
5a9772 |
// and see if we can send the client something that it supports...
|
|
Packit |
1fb8d4 |
WLog_DBG(TAG, "Client supports the following %d formats: ", context->num_client_formats);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
for (i = 0; i < context->num_client_formats; i++)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
/* TODO: improve the way we agree on a format */
|
|
Packit |
1fb8d4 |
for (j = 0; j < context->num_server_formats; j++)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
if ((context->client_formats[i].wFormatTag == context->server_formats[j].wFormatTag) &&
|
|
Packit |
1fb8d4 |
(context->client_formats[i].nChannels == context->server_formats[j].nChannels) &&
|
|
Packit Service |
5a9772 |
(context->client_formats[i].nSamplesPerSec ==
|
|
Packit Service |
5a9772 |
context->server_formats[j].nSamplesPerSec))
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
WLog_DBG(TAG, "agreed on format!");
|
|
Packit |
1fb8d4 |
formatAgreed = TRUE;
|
|
Packit |
1fb8d4 |
agreedFormat = (AUDIO_FORMAT*)&context->server_formats[j];
|
|
Packit |
1fb8d4 |
break;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (formatAgreed == TRUE)
|
|
Packit |
1fb8d4 |
break;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (formatAgreed == FALSE)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
WLog_DBG(TAG, "Could not agree on a audio format with the server");
|
|
Packit |
1fb8d4 |
return;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
context->SelectFormat(context, i);
|
|
Packit |
1fb8d4 |
context->SetVolume(context, 0x7FFF, 0x7FFF);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
switch (agreedFormat->wFormatTag)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
case WAVE_FORMAT_ALAW:
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mFormatID = kAudioFormatDVIIntelIMA;
|
|
Packit |
1fb8d4 |
break;
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
case WAVE_FORMAT_PCM:
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mFormatID = kAudioFormatLinearPCM;
|
|
Packit |
1fb8d4 |
break;
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
default:
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mFormatID = kAudioFormatLinearPCM;
|
|
Packit |
1fb8d4 |
break;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mSampleRate = agreedFormat->nSamplesPerSec;
|
|
Packit Service |
5a9772 |
recorderState.dataFormat.mFormatFlags =
|
|
Packit Service |
5a9772 |
kAudioFormatFlagIsSignedInteger | kAudioFormatFlagsNativeEndian | kAudioFormatFlagIsPacked;
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mBytesPerPacket = 4;
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mFramesPerPacket = 1;
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mBytesPerFrame = 4;
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mChannelsPerFrame = agreedFormat->nChannels;
|
|
Packit |
1fb8d4 |
recorderState.dataFormat.mBitsPerChannel = agreedFormat->wBitsPerSample;
|
|
Packit |
1fb8d4 |
recorderState.snd_context = context;
|
|
Packit Service |
5a9772 |
status =
|
|
Packit Service |
5a9772 |
AudioQueueNewInput(&recorderState.dataFormat, mf_peer_rdpsnd_input_callback, &recorderState,
|
|
Packit Service |
5a9772 |
NULL, kCFRunLoopCommonModes, 0, &recorderState.queue);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (status != noErr)
|
|
Packit |
1fb8d4 |
{
|
|
Packit Service |
5a9772 |
WLog_DBG(TAG, "Failed to create a new Audio Queue. Status code: %" PRId32 "", status);
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
UInt32 dataFormatSize = sizeof(recorderState.dataFormat);
|
|
Packit Service |
5a9772 |
AudioQueueGetProperty(recorderState.queue, kAudioConverterCurrentInputStreamDescription,
|
|
Packit Service |
5a9772 |
&recorderState.dataFormat, &dataFormatSize);
|
|
Packit |
1fb8d4 |
mf_rdpsnd_derive_buffer_size(recorderState.queue, &recorderState.dataFormat, 0.05,
|
|
Packit |
1fb8d4 |
&recorderState.bufferByteSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
for (i = 0; i < SND_NUMBUFFERS; ++i)
|
|
Packit |
1fb8d4 |
{
|
|
Packit Service |
5a9772 |
AudioQueueAllocateBuffer(recorderState.queue, recorderState.bufferByteSize,
|
|
Packit |
1fb8d4 |
&recorderState.buffers[i]);
|
|
Packit Service |
5a9772 |
AudioQueueEnqueueBuffer(recorderState.queue, recorderState.buffers[i], 0, NULL);
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
recorderState.currentPacket = 0;
|
|
Packit |
1fb8d4 |
recorderState.isRunning = true;
|
|
Packit |
1fb8d4 |
AudioQueueStart(recorderState.queue, NULL);
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
BOOL mf_peer_rdpsnd_init(mfPeerContext* context)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
context->rdpsnd = rdpsnd_server_context_new(context->vcm);
|
|
Packit |
1fb8d4 |
context->rdpsnd->rdpcontext = &context->_p;
|
|
Packit |
1fb8d4 |
context->rdpsnd->data = context;
|
|
Packit Service |
5a9772 |
context->rdpsnd->num_server_formats =
|
|
Packit Service |
5a9772 |
server_rdpsnd_get_formats(&context->rdpsnd->server_formats);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (context->rdpsnd->num_server_formats > 0)
|
|
Packit |
1fb8d4 |
context->rdpsnd->src_format = &context->rdpsnd->server_formats[0];
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
context->rdpsnd->Activated = mf_peer_rdpsnd_activated;
|
|
Packit |
1fb8d4 |
context->rdpsnd->Initialize(context->rdpsnd, TRUE);
|
|
Packit |
1fb8d4 |
return TRUE;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
BOOL mf_peer_rdpsnd_stop()
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
recorderState.isRunning = false;
|
|
Packit |
1fb8d4 |
AudioQueueStop(recorderState.queue, true);
|
|
Packit |
1fb8d4 |
return TRUE;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit Service |
5a9772 |
void mf_peer_rdpsnd_input_callback(void* inUserData, AudioQueueRef inAQ,
|
|
Packit Service |
5a9772 |
AudioQueueBufferRef inBuffer, const AudioTimeStamp* inStartTime,
|
|
Packit Service |
5a9772 |
UInt32 inNumberPacketDescriptions,
|
|
Packit Service |
5a9772 |
const AudioStreamPacketDescription* inPacketDescs)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
OSStatus status;
|
|
Packit |
1fb8d4 |
AQRecorderState* rState;
|
|
Packit |
1fb8d4 |
rState = inUserData;
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (inNumberPacketDescriptions == 0 && rState->dataFormat.mBytesPerPacket != 0)
|
|
Packit |
1fb8d4 |
{
|
|
Packit Service |
5a9772 |
inNumberPacketDescriptions =
|
|
Packit Service |
5a9772 |
inBuffer->mAudioDataByteSize / rState->dataFormat.mBytesPerPacket;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (rState->isRunning == 0)
|
|
Packit |
1fb8d4 |
{
|
|
Packit Service |
5a9772 |
return;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
rState->snd_context->SendSamples(rState->snd_context, inBuffer->mAudioData,
|
|
Packit Service |
5a9772 |
inBuffer->mAudioDataByteSize / 4,
|
|
Packit Service |
5a9772 |
(UINT16)(GetTickCount() & 0xffff));
|
|
Packit Service |
5a9772 |
status = AudioQueueEnqueueBuffer(rState->queue, inBuffer, 0, NULL);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (status != noErr)
|
|
Packit |
1fb8d4 |
{
|
|
Packit Service |
5a9772 |
WLog_DBG(TAG, "AudioQueueEnqueueBuffer() returned status = %" PRId32 "", status);
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit Service |
5a9772 |
void mf_rdpsnd_derive_buffer_size(AudioQueueRef audioQueue,
|
|
Packit Service |
5a9772 |
AudioStreamBasicDescription* ASBDescription, Float64 seconds,
|
|
Packit Service |
5a9772 |
UInt32* outBufferSize)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
static const int maxBufferSize = 0x50000;
|
|
Packit |
1fb8d4 |
int maxPacketSize = ASBDescription->mBytesPerPacket;
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
if (maxPacketSize == 0)
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
UInt32 maxVBRPacketSize = sizeof(maxPacketSize);
|
|
Packit Service |
5a9772 |
AudioQueueGetProperty(audioQueue, kAudioQueueProperty_MaximumOutputPacketSize,
|
|
Packit |
1fb8d4 |
// in Mac OS X v10.5, instead use
|
|
Packit |
1fb8d4 |
// kAudioConverterPropertyMaximumOutputPacketSize
|
|
Packit Service |
5a9772 |
&maxPacketSize, &maxVBRPacketSize);
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|
|
Packit Service |
5a9772 |
Float64 numBytesForTime = ASBDescription->mSampleRate * maxPacketSize * seconds;
|
|
Packit |
1fb8d4 |
*outBufferSize = (UInt32)(numBytesForTime < maxBufferSize ? numBytesForTime : maxBufferSize);
|
|
Packit |
1fb8d4 |
}
|