Skip to content

Commit

Permalink
feat: change MediasoupEngine to Mediasoup
Browse files Browse the repository at this point in the history
Change-Id: Ib13c6f6e6a85d26a961d966566e378f59bc2227a
  • Loading branch information
rankun committed Jul 18, 2020
1 parent 3aa1386 commit 17ab327
Show file tree
Hide file tree
Showing 5 changed files with 37 additions and 37 deletions.
12 changes: 6 additions & 6 deletions demo/main.cpp
Original file line number Diff line number Diff line change
@@ -1,17 +1,17 @@
#include <stdio.h>

#include "IMediasoupEngine.hpp"
#include "IMediasoup.hpp"

int main(int argc, char *argv[])
{
mediasoup::IMediasoupEngine* engine = mediasoup::CreateMediasoupEngine();
engine->Init();
engine->Test();
mediasoup::IMediasoup* mediasoup = mediasoup::CreateMediasoup();
mediasoup->Init();
mediasoup->Test();

getchar();

engine->Destroy();
mediasoup::DestroyMediasoupEngine(engine);
mediasoup->Destroy();
mediasoup::DestroyMediasoup(mediasoup);

getchar();
}
6 changes: 3 additions & 3 deletions mediasoup/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -5,15 +5,15 @@ project(${PROJECT_NAME})

set(mediasoup_headers
Logger.hpp
IMediasoupEngine.hpp
MediasoupEngine.hpp
IMediasoup.hpp
Mediasoup.hpp
EventEmitter.hpp
Promise.hpp
Worker.hpp
)
set(mediasoup_sources
Logger.cpp
MediasoupEngine.cpp
Mediasoup.cpp
EventEmitter.cpp
Worker.cpp
)
Expand Down
8 changes: 4 additions & 4 deletions mediasoup/IMediasoupEngine.hpp → mediasoup/IMediasoup.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
namespace mediasoup
{

class IMediasoupEngine {
class IMediasoup {
public:
virtual ~IMediasoupEngine() {}
virtual ~IMediasoup() {}

virtual void Test() = 0;
virtual bool Init() = 0;
Expand All @@ -14,8 +14,8 @@ class IMediasoupEngine {
virtual IWorker* CreateWorker() = 0;
};

mediasoup::IMediasoupEngine* CreateMediasoupEngine();
mediasoup::IMediasoup* CreateMediasoup();

void DestroyMediasoupEngine(mediasoup::IMediasoupEngine *engine);
void DestroyMediasoup(mediasoup::IMediasoup* mediasoup);

}
38 changes: 19 additions & 19 deletions mediasoup/MediasoupEngine.cpp → mediasoup/Mediasoup.cpp
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
#include "MediasoupEngine.hpp"
#include "Mediasoup.hpp"
#include "Logger.hpp"
#include "EventEmitter.hpp"
#include "Promise.hpp"
Expand All @@ -9,27 +9,27 @@ using namespace promise;
namespace mediasoup
{

mediasoup::IMediasoupEngine* CreateMediasoupEngine() {
MS_lOGGERI("CreateMediasoupEngine");
return &mediasoup::MediasoupEngine::GetInstance();
mediasoup::IMediasoup* CreateMediasoup() {
MS_lOGGERI("CreateMediasoup");
return &mediasoup::Mediasoup::GetInstance();
}

void DestroyMediasoupEngine(mediasoup::IMediasoupEngine *engine) {
if (!engine) {
void DestroyMediasoup(mediasoup::IMediasoup* mediasoup) {
if (!mediasoup) {
return;
}
MS_lOGGERI("DestroyMediasoupEngine");
MS_lOGGERI("DestroyMediasoup");
}

MediasoupEngine::MediasoupEngine() {
Mediasoup::Mediasoup() {

}

MediasoupEngine::~MediasoupEngine() {
Mediasoup::~Mediasoup() {

}

void MediasoupEngine::Test() {
void Mediasoup::Test() {
return;
MS_lOGGERD("Support for int: {0:d}; hex: {0:x}; oct: {0:o}; bin: {0:b}", 42);
MS_lOGGERW("Some error message with arg: {}", 1);
Expand Down Expand Up @@ -79,15 +79,15 @@ void MediasoupEngine::Test() {
});
}

void StaticWorkerFun(void *arg) {
static_cast<MediasoupEngine*>(arg)->WorkerFun();
void StaticWorkerFun(void* arg) {
static_cast<Mediasoup*>(arg)->WorkerFun();
}

void StaticAsync(uv_async_t *handle) {
static_cast<MediasoupEngine*>(handle->loop->data)->Async(handle);
void StaticAsync(uv_async_t* handle) {
static_cast<Mediasoup*>(handle->loop->data)->Async(handle);
}

bool MediasoupEngine::Init() {
bool Mediasoup::Init() {
if (m_workThreadCreated) {
MS_lOGGERI("already Init");
return true;
Expand All @@ -104,7 +104,7 @@ bool MediasoupEngine::Init() {
return true;
}

void MediasoupEngine::Destroy() {
void Mediasoup::Destroy() {
if (!m_workThreadCreated) {
MS_lOGGERI("need Init first");
return;
Expand All @@ -119,11 +119,11 @@ void MediasoupEngine::Destroy() {
MS_lOGGERI("work thread quit");
}

IWorker* MediasoupEngine::CreateWorker() {
IWorker* Mediasoup::CreateWorker() {
return new Worker();
}

void MediasoupEngine::WorkerFun() {
void Mediasoup::WorkerFun() {
MS_lOGGERI("WorkerFun begine");

uv_loop_t* loop = new uv_loop_t;
Expand All @@ -150,7 +150,7 @@ void MediasoupEngine::WorkerFun() {
MS_lOGGERI("WorkerFun end");
}

void MediasoupEngine::Async(uv_async_t *handle) {
void Mediasoup::Async(uv_async_t* handle) {
MS_lOGGERI("async stop");
uv_stop(handle->loop);
}
Expand Down
10 changes: 5 additions & 5 deletions mediasoup/MediasoupEngine.hpp → mediasoup/Mediasoup.hpp
Original file line number Diff line number Diff line change
@@ -1,15 +1,15 @@
#pragma once
#include "IMediasoupEngine.hpp"
#include "IMediasoup.hpp"
#include "common/Singleton.hpp"
#include "uv.h"

namespace mediasoup
{

class MediasoupEngine : public IMediasoupEngine, public mediasoup::Singleton<MediasoupEngine> {
class Mediasoup : public IMediasoup, public mediasoup::Singleton<Mediasoup> {
public:
MediasoupEngine();
virtual ~MediasoupEngine();
Mediasoup();
virtual ~Mediasoup();

virtual void Test() override;
virtual bool Init() override;
Expand All @@ -18,7 +18,7 @@ class MediasoupEngine : public IMediasoupEngine, public mediasoup::Singleton<Med

public:
void WorkerFun();
void Async(uv_async_t *handle);
void Async(uv_async_t* handle);

private:
uv_thread_t m_workThread;
Expand Down

0 comments on commit 17ab327

Please sign in to comment.