// Copyright 2019 Fuzhou Rockchip Electronics Co., Ltd. All rights reserved.
|
// Use of this source code is governed by a BSD-style license that can be
|
// found in the LICENSE file.
|
|
#ifndef EASYMEDIA_MESSAGE_H_
|
#define EASYMEDIA_MESSAGE_H_
|
|
#include <stdint.h>
|
#include <string.h>
|
#include <sys/time.h>
|
|
#include <thread>
|
#include <vector>
|
|
#include "lock.h"
|
#include "message_type.h"
|
|
namespace easymedia
|
{
|
|
class EventMessage;
|
class Flow;
|
|
class EventParam
|
{
|
public:
|
EventParam() = delete;
|
EventParam(int id, int param = 0) : id_(id), param_(param), params_(nullptr)
|
{
|
}
|
~EventParam()
|
{
|
if (params_) {
|
free(params_);
|
params_ = nullptr;
|
}
|
}
|
int SetParams(void* params, int size)
|
{
|
if (params_) {
|
free(params_);
|
}
|
params_ = params;
|
params_size_ = size;
|
return 0;
|
}
|
int GetId()
|
{
|
return id_;
|
}
|
int GetParam()
|
{
|
return param_;
|
}
|
void* GetParams()
|
{
|
return params_;
|
}
|
int GetParamsSize()
|
{
|
return params_size_;
|
}
|
|
private:
|
int id_;
|
int param_;
|
void* params_;
|
int params_size_;
|
};
|
|
typedef std::shared_ptr<EventParam> EventParamPtr;
|
|
class EventMessage
|
{
|
public:
|
EventMessage();
|
EventMessage(void* sender, EventParamPtr param, int type = 0) : sender_(sender), param_(param), type_(type)
|
{
|
}
|
~EventMessage()
|
{
|
}
|
void* GetSender()
|
{
|
return sender_;
|
}
|
EventParamPtr GetEventParam()
|
{
|
return param_;
|
}
|
int GetType()
|
{
|
return type_;
|
}
|
|
private:
|
void* sender_;
|
EventParamPtr param_;
|
int type_;
|
};
|
|
typedef int (*EventHook)(std::shared_ptr<Flow> flow, bool& loop);
|
typedef std::shared_ptr<EventMessage> MessagePtr;
|
typedef std::vector<MessagePtr> MessagePtrQueue;
|
|
class EventHandler
|
{
|
public:
|
EventHandler()
|
{
|
}
|
virtual ~EventHandler()
|
{
|
}
|
|
void RegisterEventHook(std::shared_ptr<Flow> flow, EventHook proc);
|
void UnRegisterEventHook();
|
void EventHookWait();
|
void SignalEventHook();
|
|
void CleanRepeatMessage(MessagePtr msg);
|
void InsertMessage(MessagePtr msg, bool front = false);
|
MessagePtr GetEventMessage();
|
void NotifyToEventHandler(MessagePtr msg);
|
|
public:
|
private:
|
EventHook process_;
|
bool event_thread_loop_;
|
std::unique_ptr<std::thread> event_thread_;
|
MessagePtrQueue event_msgs_;
|
ConditionLockMutex event_cond_mtx_;
|
ReadWriteLockMutex event_queue_mtx_;
|
};
|
|
} // namespace easymedia
|
|
#endif // #ifndef EASYMEDIA_FLOW_H_
|
