Skip to content

GitLab

Commit dd6ec7a0 authored by Ghislain MARY's avatar Ghislain MARY
Browse files

Rework C++/CX wrapper + implement simple demo application.

parent 7a8f34c9
Hide whitespace changes
Inline Side-by-side
Showing with 852 additions and 1516 deletions
Core/BackgroundModeLogger.cpp deleted 100644 → 0
View file @ 7a8f34c9
/*
BackgroundModeLogger.cpp
Copyright (C) 2015 Belledonne Communications, Grenoble, France
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.
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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#include "BackgroundModeLogger.h"
#include "Utils.h"
#include <ppltasks.h>
#include <iostream>
#include <fstream>
#include <cstring>
using namespace concurrency;
using namespace Windows::Networking;
using namespace Windows::Networking::Sockets;
using namespace Windows::Storage;
using namespace Windows::Storage::Streams;
using namespace Linphone::Core;
Linphone::Core::BackgroundModeLogger::BackgroundModeLogger()
{
}
Linphone::Core::BackgroundModeLogger::~BackgroundModeLogger()
{
}
void Linphone::Core::BackgroundModeLogger::OutputTrace(OutputTraceLevel level, Platform::String^ msg)
{
const char *cMsg = Utils::pstoccs(msg);
switch (level) {
case OutputTraceLevel::Debug:
ms_debug(cMsg);
break;
case OutputTraceLevel::Message:
ms_message(cMsg);
break;
case OutputTraceLevel::Warning:
ms_warning(cMsg);
break;
case OutputTraceLevel::Error:
ms_error(cMsg);
break;
}
}
Core/BackgroundModeLogger.h deleted 100644 → 0
View file @ 7a8f34c9
/*
BackgroundModeLogger.h
Copyright (C) 2015 Belledonne Communications, Grenoble, France
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.
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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#pragma once
#include "LinphoneCoreFactory.h"
#include <mutex>
// Do not treat doxygen documentation as XML
#pragma warning(push)
#pragma warning(disable : 4635)
#include "coreapi\linphonecore.h"
#pragma warning(pop)
namespace Linphone
{
namespace Core
{
ref class Globals;
/// <summary>
/// Object to log the application traces while in background mode.
/// </summary>
public ref class BackgroundModeLogger sealed : OutputTraceListener
{
public:
/// <summary>
/// Method called to output a trace to the logs.
/// </summary>
/// <param name="level">The level of the trace to output</param>
/// <param name="msg">The message to ouput</param>
virtual void OutputTrace(OutputTraceLevel level, Platform::String^ msg);
private:
friend ref class Linphone::Core::Globals;
BackgroundModeLogger();
~BackgroundModeLogger();
};
}
}
\ No newline at end of file
Core/Globals.cpp deleted 100644 → 0
View file @ 7a8f34c9
/*
Globals.cpp
Copyright (C) 2015 Belledonne Communications, Grenoble, France
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.
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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#include <hstring.h>
#include <memory>
#include <activation.h>
#include <wrl\module.h>
#include <crtdbg.h>
#include "Globals.h"
#include "ApiLock.h"
#include "LinphoneCoreFactory.h"
#include "LinphoneCore.h"
#include "BackgroundModeLogger.h"
#include "CallController.h"
using namespace Linphone::Core;
using namespace Windows::Foundation;
//using namespace Windows::Phone::Media::Capture;
// Maximum number of characters required to contain the string version of an unsigned integer
#define MAX_CHARS_IN_UINT_AS_STRING ((sizeof(unsigned int) * 4) + 1)
const LPCWSTR Globals::noOtherBackgroundProcessEventName = L"Linphone.noOtherBackgroundProcess";
const LPCWSTR Globals::uiDisconnectedEventName = L"Linphone.uiDisconnected.";
const LPCWSTR Globals::backgroundProcessReadyEventName = L"Linphone.backgroundProcessReady.";
Globals^ Globals::singleton = nullptr;
void Globals::StartServer(const Platform::Array<Platform::String^>^ outOfProcServerClassNames)
{
// Make sure only one API call is in progress at a time
API_LOCK;
std::unique_ptr<PFNGETACTIVATIONFACTORY[]> activationFactoryCallbacks;
std::unique_ptr<HSTRING[]> hOutOfProcServerClassNames;
if (outOfProcServerClassNames == nullptr)
{
throw ref new Platform::InvalidArgumentException(L"outOfProcServerClassNames cannot be null");
}
unsigned int numOutOfProcServerClassNames = outOfProcServerClassNames->Length;
if (this->started)
{
return; // Nothing more to be done
}
// Initialize the structures required to register the out-of-proc server classes
activationFactoryCallbacks.reset(new PFNGETACTIVATIONFACTORY[numOutOfProcServerClassNames]);
hOutOfProcServerClassNames.reset(new HSTRING[numOutOfProcServerClassNames]);
for(unsigned int index = 0; index < numOutOfProcServerClassNames; index++)
{
activationFactoryCallbacks[index] = &(Microsoft::WRL::Details::ActivationFactoryCallback<Microsoft::WRL::OutOfProcDisableCaching>);
hOutOfProcServerClassNames[index] = reinterpret_cast<HSTRING>(outOfProcServerClassNames[index]);
}
// Register the out-of-proc server classes
HRESULT hr = ::RoRegisterActivationFactories(
hOutOfProcServerClassNames.get(), activationFactoryCallbacks.get(), numOutOfProcServerClassNames, &this->serverRegistrationCookie);
if (FAILED(hr))
{
throw ref new Platform::COMException(hr, L"Unable to start server");
}
// Set an event that indicates that the background process is ready.
this->backgroundReadyEvent = ::CreateEventEx(
NULL,
Globals::GetBackgroundProcessReadyEventName(Globals::GetCurrentProcessId())->Data(),
CREATE_EVENT_INITIAL_SET | CREATE_EVENT_MANUAL_RESET,
EVENT_ALL_ACCESS);
if (this->backgroundReadyEvent == NULL)
{
// Something went wrong
DWORD dwErr = ::GetLastError();
hr = HRESULT_FROM_WIN32(dwErr);
throw ref new Platform::COMException(hr, L"An error occurred trying to create an event that indicates that the background process is ready");
}
// Set the event
BOOL success = ::SetEvent(this->backgroundReadyEvent);
if (success == FALSE)
{
DWORD dwErr = ::GetLastError();
hr = HRESULT_FROM_WIN32(dwErr);
throw ref new Platform::COMException(hr, L"An error occurred trying to set an event that indicates that the background process is ready");
}
this->started = true;
}
unsigned int Globals::GetCurrentProcessId()
{
return ::GetCurrentProcessId();
}
Platform::String^ Globals::GetUiDisconnectedEventName(unsigned int backgroundProcessId)
{
WCHAR backgroundProcessIdString[MAX_CHARS_IN_UINT_AS_STRING];
if (swprintf_s<_countof(backgroundProcessIdString)>(backgroundProcessIdString, L"%u", backgroundProcessId) < 0)
throw ref new Platform::FailureException(L"Could not create string version of background process id");
auto eventName = ref new Platform::String(Globals::uiDisconnectedEventName) + ref new Platform::String(backgroundProcessIdString);
return eventName;
}
Platform::String^ Globals::GetBackgroundProcessReadyEventName(unsigned int backgroundProcessId)
{
WCHAR backgroundProcessIdString[MAX_CHARS_IN_UINT_AS_STRING];
if (swprintf_s<_countof(backgroundProcessIdString)>(backgroundProcessIdString, L"%u", backgroundProcessId) < 0)
throw ref new Platform::FailureException(L"Could not create string version of background process id");
auto eventName = ref new Platform::String(Globals::backgroundProcessReadyEventName) + ref new Platform::String(backgroundProcessIdString);
return eventName;
}
Globals^ Globals::Instance::get()
{
if (Globals::singleton == nullptr)
{
// Make sure only one API call is in progress at a time
API_LOCK;
if (Globals::singleton == nullptr)
{
Globals::singleton = ref new Globals();
}
// else: some other thread has created an instance of the call controller
}
return Globals::singleton;
}
LinphoneCoreFactory^ Globals::LinphoneCoreFactory::get()
{
if (this->linphoneCoreFactory == nullptr)
{
// Make sure only one API call is in progress at a time
API_LOCK;
if (this->linphoneCoreFactory == nullptr)
{
this->linphoneCoreFactory = ref new Linphone::Core::LinphoneCoreFactory();
}
}
return this->linphoneCoreFactory;
}
Linphone::Core::LinphoneCore^ Globals::LinphoneCore::get()
{
return this->linphoneCoreFactory->LinphoneCore;
}
Linphone::Core::CallController^ Globals::CallController::get()
{
if (this->callController == nullptr)
{
// Make sure only one API call is in progress at a time
API_LOCK;
if (this->callController == nullptr)
{
this->callController = ref new Linphone::Core::CallController();
}
// else: some other thread has created an instance of the call controller
}
return this->callController;
}
Linphone::Core::BackgroundModeLogger^ Globals::BackgroundModeLogger::get()
{
if (this->backgroundModeLogger == nullptr)
{
// Make sure only one API call is in progress at a time
API_LOCK;
if (this->backgroundModeLogger == nullptr)
{
this->backgroundModeLogger = ref new Linphone::Core::BackgroundModeLogger();
}
}
return this->backgroundModeLogger;
}
#if 0
Mediastreamer2::WP8Video::IVideoRenderer^ Globals::VideoRenderer::get()
{
return this->videoRenderer;
}
void Globals::VideoRenderer::set(Mediastreamer2::WP8Video::IVideoRenderer^ value)
{
API_LOCK;
this->videoRenderer = value;
}
#endif
Globals::Globals() :
started(false),
serverRegistrationCookie(NULL),
linphoneCoreFactory(nullptr),
backgroundModeLogger(nullptr),
noOtherBackgroundProcessEvent(NULL),
backgroundReadyEvent(NULL)
{
{
WCHAR szBuffer[256];
swprintf_s<ARRAYSIZE(szBuffer)>(szBuffer, L"[Globals::Globals] => VoIP background process with id %d starting up\n", this->GetCurrentProcessId());
::OutputDebugString(szBuffer);
}
// Create an event that indicates if any other VoIP background exits or not
this->noOtherBackgroundProcessEvent = ::CreateEventEx(NULL, Globals::noOtherBackgroundProcessEventName, CREATE_EVENT_INITIAL_SET | CREATE_EVENT_MANUAL_RESET, EVENT_ALL_ACCESS);
if (this->noOtherBackgroundProcessEvent == NULL)
{
// Something went wrong
DWORD dwErr = ::GetLastError();
HRESULT hr = HRESULT_FROM_WIN32(dwErr);
throw ref new Platform::COMException(hr, L"An error occurred trying to create an event that indicates if the background process exists or not");
}
// Wait for up to 30 seconds for the event to become set - if another instance of this process exists, this event would be in the reset state
DWORD reason = ::WaitForSingleObjectEx(this->noOtherBackgroundProcessEvent, 30 * 1000, FALSE);
_ASSERT(reason != WAIT_FAILED); // We don't care about any of the other reasons why WaitForSingleObjectEx returned
if (reason == WAIT_TIMEOUT)
{
throw ref new Platform::FailureException(L"Another instance of the VoIP background process exists and that process did not exit within 30 seconds. Cannot continue.");
}
// Reset the event to indicate that there is a VoIP background process
BOOL success = ::ResetEvent(this->noOtherBackgroundProcessEvent);
if (success == FALSE)
{
// Something went wrong
DWORD dwErr = ::GetLastError();
HRESULT hr = HRESULT_FROM_WIN32(dwErr);
throw ref new Platform::COMException(hr, L"An error occurred trying to reset the event that indicates if the background process exists or not");
}
}
Globals::~Globals()
{
// The destructor of this singleton object is called when the process is shutting down.
// Before shutting down, make sure the UI process is not connected
HANDLE uiDisconnectedEvent = ::OpenEvent(EVENT_ALL_ACCESS, FALSE, Globals::GetUiDisconnectedEventName(Globals::GetCurrentProcessId())->Data());
if (uiDisconnectedEvent != NULL)
{
// The event exists - wait for it to get signaled (for a maximum of 30 seconds)
DWORD reason = ::WaitForSingleObjectEx(uiDisconnectedEvent, 3 * 1000, FALSE);
//_ASSERT(reason != WAIT_FAILED); // We don't care about any of the other reasons why WaitForSingleObjectEx returned
}
// At this point, the UI is no longer connected to the background process.
// It is possible that the UI now reconnects to the background process - this would be a bug,
// and we should exit the background process anyway.
// Unset the event that indicates that the background process is ready
BOOL success;
if (this->backgroundReadyEvent != NULL)
{
success = ::ResetEvent(this->backgroundReadyEvent);
_ASSERT(success);
::CloseHandle(this->backgroundReadyEvent);
this->backgroundReadyEvent = NULL;
}
// Unregister the activation factories for out-of-process objects hosted in this process
if (this->started)
{
RoRevokeActivationFactories(this->serverRegistrationCookie);
this->started = false;
}
// Set the event that indicates that no instance of the VoIP background process exists
if (this->noOtherBackgroundProcessEvent != NULL)
{
success = ::SetEvent(this->noOtherBackgroundProcessEvent);
_ASSERT(success);
::CloseHandle(this->noOtherBackgroundProcessEvent);
this->noOtherBackgroundProcessEvent = NULL;
}
{
WCHAR szBuffer[256];
swprintf_s<ARRAYSIZE(szBuffer)>(szBuffer, L"[Globals::~Globals] => VoIP background process with id %d shutting down\n", this->GetCurrentProcessId());
::OutputDebugString(szBuffer);
}
}
Core/Globals.h deleted 100644 → 0
View file @ 7a8f34c9
/*
Globals.h
Copyright (C) 2015 Belledonne Communications, Grenoble, France
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.
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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#pragma once
#include <roapi.h>
namespace Linphone
{
namespace Core
{
ref class CallController;
ref class LinphoneCoreFactory;
ref class LinphoneCore;
ref class BackgroundModeLogger;
/// <summary>
/// Singleton container used to hold global singletons and background process-wide objects.
/// Also used to start out of process server, allowing the UI process managed code to instantiate WinRT objects in this process.
/// </summary>
public ref class Globals sealed
{
public:
/// <summary>
/// Starts the out of process server, allowing the UI process to instantiate WinRT objects in this process.
/// </summary>
void StartServer(const Platform::Array<Platform::String^>^ outOfProcServerClassNames);
/// <summary>
///Returns the id of the background process (HeadlessHost)
/// </summary>
static unsigned int GetCurrentProcessId();
static Platform::String^ GetUiDisconnectedEventName(unsigned int backgroundProcessId);
static Platform::String^ GetBackgroundProcessReadyEventName(unsigned int backgroundProcessId);
/// <summary>
/// Gets the instance of the Globals class, used to directly access any C++/CX objects from C#
/// </summary>
static property Globals^ Instance
{
Globals^ get();
}
/// <summary>
/// Gets the current instance of LinphoneCoreFactory
/// </summary>
property LinphoneCoreFactory^ LinphoneCoreFactory
{
Linphone::Core::LinphoneCoreFactory^ get();
}
/// <summary>
/// Gets the current instance of LinphoneCore from LinphoneCoreFactory
/// </summary>
property LinphoneCore^ LinphoneCore
{
Linphone::Core::LinphoneCore^ get();
}
/// <summary>
/// Gets the current instance of the logger
/// </summary>
property BackgroundModeLogger^ BackgroundModeLogger
{
Linphone::Core::BackgroundModeLogger^ get();
}
/// <summary>
/// Gets the current instance of the native call controller
/// </summary>
property CallController^ CallController
{
Linphone::Core::CallController^ get();
}
#if 0
/// <summary>
/// Access the video renderer instance
/// </summary>
property Mediastreamer2::WP8Video::IVideoRenderer^ VideoRenderer
{
Mediastreamer2::WP8Video::IVideoRenderer^ get();
void set(Mediastreamer2::WP8Video::IVideoRenderer^ value);
}
#endif
private:
Globals();
~Globals();
static const LPCWSTR noOtherBackgroundProcessEventName;
static const LPCWSTR uiDisconnectedEventName;
static const LPCWSTR backgroundProcessReadyEventName;
static Globals^ singleton;
bool started;
// A cookie that is used to unregister remotely activatable objects in this process
RO_REGISTRATION_COOKIE serverRegistrationCookie;
HANDLE noOtherBackgroundProcessEvent;
HANDLE backgroundReadyEvent;
Linphone::Core::LinphoneCoreFactory^ linphoneCoreFactory;
Linphone::Core::BackgroundModeLogger^ backgroundModeLogger;
Linphone::Core::CallController^ callController;
//Mediastreamer2::WP8Video::IVideoRenderer^ videoRenderer;
};
}
}
Core/LinphoneCoreFactory.cpp deleted 100644 → 0
View file @ 7a8f34c9
/*
LinphoneCoreFactory.cpp
Copyright (C) 2015 Belledonne Communications, Grenoble, France
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.
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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#include "LinphoneAuthInfo.h"
#include "LinphoneCoreFactory.h"
#include "LinphoneCore.h"
#include "LinphoneCoreListener.h"
#include "LinphoneAddress.h"
#include "LpConfig.h"
#include "Server.h"
#include "Transports.h"
#include "VideoPolicy.h"
#include "VideoSize.h"
using namespace Linphone::Core;
using namespace Platform;
#define MAX_TRACE_SIZE 2048
#define MAX_SUITE_NAME_SIZE 128
void LinphoneCoreFactory::CreateLinphoneCore(Linphone::Core::LinphoneCoreListener^ listener)
{
CreateLinphoneCore(listener, nullptr);
}
void LinphoneCoreFactory::CreateLinphoneCore(Linphone::Core::LinphoneCoreListener^ listener, Linphone::Core::LpConfig^ config)
{
if (this->linphoneCore == nullptr) {
API_LOCK;
if (this->linphoneCore == nullptr) {
Utils::LinphoneCoreEnableLogCollection(true);
this->linphoneCore = ref new Linphone::Core::LinphoneCore(listener, config);
this->linphoneCore->Init();
}
}
}
Linphone::Core::LpConfig^ LinphoneCoreFactory::CreateLpConfig(Platform::String^ configPath, Platform::String^ factoryConfigPath)
{
API_LOCK;
return dynamic_cast<Linphone::Core::LpConfig^>(Utils::CreateLpConfig(configPath, factoryConfigPath));
}
Linphone::Core::LinphoneAuthInfo^ LinphoneCoreFactory::CreateAuthInfo(Platform::String^ username, Platform::String^ userid, Platform::String^ password, Platform::String^ ha1, Platform::String^ realm, Platform::String^ domain)
{
API_LOCK;
return dynamic_cast<Linphone::Core::LinphoneAuthInfo^>(Utils::CreateLinphoneAuthInfo(username, userid, password, ha1, realm, domain));