//
// Created by pansen on 2017/8/4.
//

#ifndef RTSPNATIVECODEC_REMOTEFUNC_H
#define RTSPNATIVECODEC_REMOTEFUNC_H

#include <iostream>
#include <capnp/ez-rpc.h>
#include <logger.h>

template<class T>
class RemoteServer
{
public:
	RemoteServer(std::string host, int port) : host(host), port(port) {};

	~RemoteServer() {};

	bool start()
	{
		LOG_INFO << "server_thd::start" << LOG_ENDL;

		if (running == true)
		{
			LOG_INFO << "The server_thd is already running" << LOG_ENDL;
			return false;
		}
		running = true;
		pthread_mutex_init(&mutexSerevr, NULL); // 初始化互斥对象,动态加锁，用于server

		int retServer = pthread_create(&server_thid, NULL, RemoteServer::rServer_thd, this);

		if (retServer != 0)
		{
			LOGP(ERROR, "server_thd_create: %s/n", strerror(retServer));
			running = false;
			return false;
		}
		return true;
	}

	void stop()
	{
//    LOG_INFO << "server_thd::stop" << LOG_ENDL;
//    if (!running)
//        return;
//    running = false;
//    pthread_mutex_destroy(&mutexSerevr);
		//#todo
	}

	bool running;
private:
	std::string host;
	int port;

	static void *rServer_thd(void *arg)
	{
		try
		{
			RemoteServer &rs = *(RemoteServer *) arg;
			capnp::EzRpcServer trpcServer(kj::heap<T>(), rs.host, rs.port);
			auto &serverLoop = trpcServer.getWaitScope();
			kj::NEVER_DONE.wait(serverLoop);
		}
		catch (kj::Exception e){
			LOG_ERROR<<e.getLine()<<LOG_ENDL;
		}

	}

	pthread_t server_thid;
	pthread_mutex_t mutexSerevr;
};

#endif //RTSPNATIVECODEC_REMOTEFUNC_H