-
Notifications
You must be signed in to change notification settings - Fork 33
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into aa/update-submodule
- Loading branch information
Showing
45 changed files
with
3,602 additions
and
1,890 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,7 @@ | ||
| #pragma once | ||
| #include "APErrorObject.h" | ||
| #include "APHealthObject.h" | ||
| #include <functional> | ||
|
|
||
| using APErrorCallback = std::function<void(const APErrorObject &)>; | ||
| using APHealthCallback = std::function<void(const APHealthObject &)>; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,28 @@ | ||
| #pragma once | ||
| #include <string> | ||
|
|
||
| class APErrorObject { | ||
| private: | ||
| int mErrorCode; | ||
| std::string mErrorMessage; | ||
| std::string mModuleName; | ||
| std::string mModuleId; | ||
| std::string mTimestamp; | ||
|
|
||
| std::string getCurrentTimestamp() const; | ||
|
|
||
| public: | ||
| APErrorObject(int errCode, const std::string &errorMsg); | ||
|
|
||
| int getErrorCode() const; | ||
| std::string getErrorMessage() const; | ||
| std::string getModuleName() const; | ||
| std::string getModuleId() const; | ||
| std::string getTimestamp() const; | ||
|
|
||
| void displayError() const; | ||
| void setErrorCode(int errCode); | ||
| void setErrorMessage(const std::string &errorMsg); | ||
| void setModuleName(const std::string &modName); | ||
| void setModuleId(const std::string &modId); | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,19 @@ | ||
| #pragma once | ||
| #include <string> | ||
|
|
||
| class APHealthObject | ||
| { | ||
| private: | ||
| std::string mModuleId; | ||
| std::string mTimestamp; | ||
|
|
||
| std::string getCurrentTimestamp() const; | ||
|
|
||
| public: | ||
| APHealthObject(const std::string &modId); | ||
|
|
||
| std::string getModuleId() const; | ||
| std::string getTimestamp() const; | ||
|
|
||
| void setModuleId(const std::string &modId); | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,40 +1,53 @@ | ||
| #pragma once | ||
| #include "APCallback.h" | ||
| #include "Command.h" | ||
| #include "Module.h" | ||
| #include <map> | ||
|
|
||
| class PipeLine; | ||
| class AbsControlModuleProps : public ModuleProps { | ||
| public: | ||
| AbsControlModuleProps() {} | ||
| AbsControlModuleProps() {} | ||
| }; | ||
|
|
||
| class AbsControlModule : public Module { | ||
| public: | ||
| AbsControlModule(AbsControlModuleProps _props); | ||
| ~AbsControlModule(); | ||
| bool init(); | ||
| bool term(); | ||
| std::string enrollModule(boost::shared_ptr<PipeLine> p, std::string role, | ||
| boost::shared_ptr<Module> module); | ||
| std::pair<bool, boost::shared_ptr<Module>> getModuleofRole(PipeLine p, | ||
| std::string role); | ||
| virtual void handleMp4MissingVideotrack(std::string previousVideoFile, std::string nextVideoFile) {} | ||
| virtual void handleMMQExport(Command cmd, bool priority = false) {} | ||
| virtual void handleMMQExportView(uint64_t startTS, uint64_t endTS = 9999999999999, bool playabckDirection = true, bool Mp4ReaderExport = false, bool priority = false) {} | ||
| virtual void handleSendMMQTSCmd(uint64_t mmqBeginTS, uint64_t mmqEndTS, bool priority = false) {} | ||
| virtual void handleLastGtkGLRenderTS(uint64_t latestGtkGlRenderTS, bool priority) {} | ||
| virtual void handleGoLive(bool goLive, bool priority) {} | ||
| virtual void handleDecoderSpeed(DecoderPlaybackSpeed cmd, bool priority) {} | ||
| boost::container::deque<boost::shared_ptr<Module>> pipelineModules; | ||
| std::map<std::string, boost::shared_ptr<Module>> moduleRoles; | ||
|
|
||
| AbsControlModule(AbsControlModuleProps _props); | ||
| ~AbsControlModule(); | ||
| bool init(); | ||
| bool term(); | ||
| bool enrollModule(std::string role, boost::shared_ptr<Module> module); | ||
| boost::shared_ptr<Module> getModuleofRole(std::string role); | ||
| std::string printStatus(); | ||
| virtual void handleMp4MissingVideotrack(std::string previousVideoFile, std::string nextVideoFile) {} | ||
| virtual void handleMMQExport(Command cmd, bool priority = false) {} | ||
| virtual void handleMMQExportView(uint64_t startTS, uint64_t endTS = 9999999999999, bool playabckDirection = true, bool Mp4ReaderExport = false, bool priority = false) {} | ||
| virtual void handleSendMMQTSCmd(uint64_t mmqBeginTS, uint64_t mmqEndTS, bool priority = false) {} | ||
| virtual void handleLastGtkGLRenderTS(uint64_t latestGtkGlRenderTS, bool priority) {} | ||
| virtual void handleGoLive(bool goLive, bool priority) {} | ||
| virtual void handleDecoderSpeed(DecoderPlaybackSpeed cmd, bool priority) {} | ||
| // Note: weak pointers to avoid cyclic dependency and mem leaks | ||
| std::map<std::string, boost::weak_ptr<Module>> moduleRoles; | ||
| virtual void handleError(const APErrorObject &error) {} | ||
| virtual void handleHealthCallback(const APHealthObject& healthObj); | ||
| /** | ||
| * @brief Register external function to be triggered on every health callBack that control modules recieves from the modules. | ||
| * For eg. In SimpleControlModule, this extention is called at the end of handleHealthCallback function. | ||
| * @param function with signature void f(const APHealthObject*, unsigned short) | ||
| * @return nothing. | ||
| */ | ||
| void registerHealthCallbackExtention( | ||
| boost::function<void(const APHealthObject*, unsigned short)> callbackFunction); | ||
| protected: | ||
| bool process(frame_container &frames); | ||
| bool handleCommand(Command::CommandType type, frame_sp &frame); | ||
| bool handlePropsChange(frame_sp &frame); | ||
|
|
||
| bool process(frame_container& frames); | ||
| bool handleCommand(Command::CommandType type, frame_sp& frame); | ||
| bool handlePropsChange(frame_sp& frame); | ||
| virtual void sendEOS() {} | ||
| virtual void sendEOS(frame_sp& frame) {} | ||
| virtual void sendEOPFrame() {} | ||
| std::vector<std::string> serializeControlModule(); | ||
| boost::function<void(const APHealthObject*, unsigned short)> healthCallbackExtention; | ||
| private: | ||
| class Detail; | ||
| boost::shared_ptr<Detail> mDetail; | ||
| class Detail; | ||
| boost::shared_ptr<Detail> mDetail; | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.