-
Notifications
You must be signed in to change notification settings - Fork 294
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
The original implementation was done by https://github.com/BuzzBumbleBee/libcec
- Loading branch information
Showing
13 changed files
with
722 additions
and
2 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -26,6 +26,8 @@ AssemblyInfo.cs | |
| AssemblyInfo.cpp | ||
|
|
||
| *~ | ||
| tags | ||
| cscope.* | ||
|
|
||
| /support/private | ||
|
|
||
|
|
||
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,134 @@ | ||
| #pragma once | ||
| /* | ||
| * This file is part of the libCEC(R) library. | ||
| * | ||
| * libCEC(R) is Copyright (C) 2011-2013 Pulse-Eight Limited. All rights reserved. | ||
| * libCEC(R) is an original work, containing original code. | ||
| * | ||
| * libCEC(R) is a trademark of Pulse-Eight Limited. | ||
| * | ||
| * This program is dual-licensed; 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. | ||
| * | ||
| * | ||
| * Alternatively, you can license this library under a commercial license, | ||
| * please contact Pulse-Eight Licensing for more information. | ||
| * | ||
| * For more information contact: | ||
| * Pulse-Eight Licensing <[email protected]> | ||
| * http://www.pulse-eight.com/ | ||
| * http://www.pulse-eight.net/ | ||
| */ | ||
|
|
||
| #include "p8-platform/threads/mutex.h" | ||
|
|
||
| namespace CEC | ||
| { | ||
| using namespace P8PLATFORM; | ||
|
|
||
| class CAdapterMessageQueueEntry | ||
| { | ||
| public: | ||
| CAdapterMessageQueueEntry(const cec_command &command) | ||
| : m_bWaiting(true), m_retval((uint32_t)-1), m_bSucceeded(false) | ||
| { | ||
| m_hash = hashValue( | ||
| uint32_t(command.opcode_set ? command.opcode : CEC_OPCODE_NONE), | ||
| command.initiator, command.destination); | ||
| } | ||
|
|
||
| virtual ~CAdapterMessageQueueEntry(void) {} | ||
|
|
||
| /*! | ||
| * @brief Query result from worker thread | ||
| */ | ||
| uint32_t Result() const | ||
| { | ||
| return m_retval; | ||
| } | ||
|
|
||
| /*! | ||
| * @brief Signal waiting threads | ||
| */ | ||
| void Broadcast(void) | ||
| { | ||
| CLockObject lock(m_mutex); | ||
| m_condition.Broadcast(); | ||
| } | ||
|
|
||
| /*! | ||
| * @brief Signal waiting thread(s) when message matches this entry | ||
| */ | ||
| bool CheckMatch(uint32_t opcode, cec_logical_address initiator, | ||
| cec_logical_address destination, uint32_t response) | ||
| { | ||
| uint32_t hash = hashValue(opcode, initiator, destination); | ||
|
|
||
| if (hash == m_hash) | ||
| { | ||
| CLockObject lock(m_mutex); | ||
|
|
||
| m_retval = response; | ||
| m_bSucceeded = true; | ||
| m_condition.Signal(); | ||
| return true; | ||
| } | ||
|
|
||
| return false; | ||
| } | ||
|
|
||
| /*! | ||
| * @brief Wait for a response to this command. | ||
| * @param iTimeout The timeout to use while waiting. | ||
| * @return True when a response was received before the timeout passed, false otherwise. | ||
| */ | ||
| bool Wait(uint32_t iTimeout) | ||
| { | ||
| CLockObject lock(m_mutex); | ||
|
|
||
| bool bReturn = m_bSucceeded ? true : m_condition.Wait(m_mutex, m_bSucceeded, iTimeout); | ||
| m_bWaiting = false; | ||
| return bReturn; | ||
| } | ||
|
|
||
| /*! | ||
| * @return True while a thread is waiting for a signal or isn't waiting yet, false otherwise. | ||
| */ | ||
| bool IsWaiting(void) | ||
| { | ||
| CLockObject lock(m_mutex); | ||
| return m_bWaiting; | ||
| } | ||
|
|
||
| /*! | ||
| * @return Hash value for given cec_command | ||
| */ | ||
| static uint32_t hashValue(uint32_t opcode, | ||
| cec_logical_address initiator, | ||
| cec_logical_address destination) | ||
| { | ||
| return 1 | ((uint32_t)initiator << 8) | | ||
| ((uint32_t)destination << 16) | ((uint32_t)opcode << 16); | ||
| } | ||
|
|
||
| private: | ||
| bool m_bWaiting; /**< true while a thread is waiting or when it hasn't started waiting yet */ | ||
| P8PLATFORM::CCondition<bool> m_condition; /**< the condition to wait on */ | ||
| P8PLATFORM::CMutex m_mutex; /**< mutex for changes to this class */ | ||
| uint32_t m_hash; | ||
| uint32_t m_retval; | ||
| bool m_bSucceeded; | ||
| }; | ||
|
|
||
| }; |
Oops, something went wrong.