CCECProcessor::CCECProcessor(CLibCEC *controller, CAdapterCommunication *serComm, const char *strDeviceName, cec_logical_address iLogicalAddress /* = CECDEVICE_PLAYBACKDEVICE1 */, uint16_t iPhysicalAddress /* = CEC_DEFAULT_PHYSICAL_ADDRESS*/) :
m_bStarted(false),
+ m_iHDMIPort(CEC_DEFAULT_HDMI_PORT),
m_strDeviceName(strDeviceName),
m_communication(serComm),
m_controller(controller),
CCECProcessor::CCECProcessor(CLibCEC *controller, CAdapterCommunication *serComm, const char *strDeviceName, const cec_device_type_list &types) :
m_bStarted(false),
+ m_iHDMIPort(CEC_DEFAULT_HDMI_PORT),
m_strDeviceName(strDeviceName),
m_types(types),
m_communication(serComm),
m_busDevices[address]->m_bActiveSource = true;
}
m_logicalAddresses.Set(address);
-
- // TODO
- m_busDevices[address]->SetPhysicalAddress((uint16_t)CEC_DEFAULT_PHYSICAL_ADDRESS);
-
return true;
}
if (m_logicalAddresses.IsEmpty() && !FindLogicalAddresses())
{
CLockObject lock(&m_mutex);
- m_controller->AddLog(CEC_LOG_ERROR, "could not detect our logical addressed");
+ m_controller->AddLog(CEC_LOG_ERROR, "could not detect our logical addresses");
m_startCondition.Signal();
return NULL;
}
{
CLockObject lock(&m_mutex);
- m_controller->AddLog(CEC_LOG_DEBUG, "processor thread started");
m_bStarted = true;
+ lock.Leave();
+
+ SetHDMIPort(m_iHDMIPort);
+
+ lock.Lock();
+ m_controller->AddLog(CEC_LOG_DEBUG, "processor thread started");
m_startCondition.Signal();
}
}
}
}
- return SetStreamPath(m_busDevices[addr]->GetPhysicalAddress()) &&
+ return SetStreamPath(m_busDevices[addr]->GetPhysicalAddress(false)) &&
m_busDevices[addr]->TransmitActiveSource();
}
+bool CCECProcessor::SetActiveSource(cec_logical_address iAddress)
+{
+ return SetStreamPath(m_busDevices[iAddress]->GetPhysicalAddress(false));
+}
+
bool CCECProcessor::SetActiveView(void)
{
return SetActiveSource(m_types.IsEmpty() ? CEC_DEVICE_TYPE_RESERVED : m_types[0]);
return bReturn;
}
+bool CCECProcessor::SetHDMIPort(uint8_t iPort)
+{
+ bool bReturn(false);
+
+ CStdString strLog;
+ strLog.Format("setting HDMI port to %d", iPort);
+ AddLog(CEC_LOG_DEBUG, strLog);
+
+ m_iHDMIPort = iPort;
+ if (!m_bStarted)
+ return true;
+
+ uint16_t iPhysicalAddress(0);
+ int iPos = 3;
+ while(!bReturn && iPos >= 0)
+ {
+ iPhysicalAddress += ((uint16_t)iPort * (0x1 << iPos*4));
+ strLog.Format("checking physical address %4x", iPhysicalAddress);
+ AddLog(CEC_LOG_DEBUG, strLog);
+ if (CheckPhysicalAddress(iPhysicalAddress))
+ {
+ strLog.Format("physical address %4x is in use", iPhysicalAddress);
+ AddLog(CEC_LOG_DEBUG, strLog);
+ iPos--;
+ }
+ else
+ {
+ SetPhysicalAddress(iPhysicalAddress);
+ bReturn = true;
+ }
+ }
+
+ return bReturn;
+}
+
+bool CCECProcessor::CheckPhysicalAddress(uint16_t iPhysicalAddress)
+{
+ for (unsigned int iPtr = 0; iPtr < 16; iPtr++)
+ {
+ if (m_busDevices[iPtr]->GetPhysicalAddress(false) == iPhysicalAddress)
+ return true;
+ }
+ return false;
+}
+
bool CCECProcessor::SetStreamPath(uint16_t iStreamPath)
{
bool bReturn(false);
bool CCECProcessor::SetPhysicalAddress(uint16_t iPhysicalAddress)
{
- if (!m_logicalAddresses.IsEmpty() && m_busDevices[m_logicalAddresses.primary])
+ if (!m_logicalAddresses.IsEmpty())
{
- m_busDevices[m_logicalAddresses.primary]->SetPhysicalAddress(iPhysicalAddress);
+ for (uint8_t iPtr = 0; iPtr < 15; iPtr++)
+ if (m_logicalAddresses[iPtr])
+ m_busDevices[iPtr]->SetPhysicalAddress(iPhysicalAddress);
return SetActiveView();
}
return false;
return false;
}
-CCECBusDevice *CCECProcessor::GetDeviceByPhysicalAddress(uint16_t iPhysicalAddress) const
+uint8_t CCECProcessor::VolumeUp(bool bWait /* = true */)
{
- if (m_busDevices[m_logicalAddresses.primary]->GetPhysicalAddress() == iPhysicalAddress)
+ uint8_t status = 0;
+ if (IsActiveDevice(CECDEVICE_AUDIOSYSTEM))
+ status = ((CCECAudioSystem *)m_busDevices[CECDEVICE_AUDIOSYSTEM])->VolumeUp(bWait);
+
+ return status;
+}
+
+uint8_t CCECProcessor::VolumeDown(bool bWait /* = true */)
+{
+ uint8_t status = 0;
+ if (IsActiveDevice(CECDEVICE_AUDIOSYSTEM))
+ status = ((CCECAudioSystem *)m_busDevices[CECDEVICE_AUDIOSYSTEM])->VolumeDown(bWait);
+
+ return status;
+}
+
+uint8_t CCECProcessor::MuteAudio(bool bWait /* = true */)
+{
+ uint8_t status = 0;
+ if (IsActiveDevice(CECDEVICE_AUDIOSYSTEM))
+ status = ((CCECAudioSystem *)m_busDevices[CECDEVICE_AUDIOSYSTEM])->MuteAudio(bWait);
+
+ return status;
+}
+
+CCECBusDevice *CCECProcessor::GetDeviceByPhysicalAddress(uint16_t iPhysicalAddress, bool bRefresh /* = false */) const
+{
+ if (m_busDevices[m_logicalAddresses.primary]->GetPhysicalAddress(false) == iPhysicalAddress)
return m_busDevices[m_logicalAddresses.primary];
CCECBusDevice *device = NULL;
for (unsigned int iPtr = 0; iPtr < 16; iPtr++)
{
- if (m_busDevices[iPtr]->GetPhysicalAddress() == iPhysicalAddress)
+ if (m_busDevices[iPtr]->GetPhysicalAddress(bRefresh) == iPhysicalAddress)
{
device = m_busDevices[iPtr];
break;
bool CCECProcessor::IsActiveDeviceType(cec_device_type type)
{
- cec_logical_addresses activeDevices = GetActiveDevices();
for (unsigned int iPtr = 0; iPtr < 15; iPtr++)
- if (activeDevices.IsSet((cec_logical_address) iPtr) && m_busDevices[iPtr]->GetType() == type)
+ {
+ if (m_busDevices[iPtr]->GetType() == type && m_busDevices[iPtr]->GetStatus() == CEC_DEVICE_STATUS_PRESENT)
return true;
+ }
+
return false;
}
uint16_t CCECProcessor::GetPhysicalAddress(void) const
{
if (!m_logicalAddresses.IsEmpty() && m_busDevices[m_logicalAddresses.primary])
- return m_busDevices[m_logicalAddresses.primary]->GetPhysicalAddress();
+ return m_busDevices[m_logicalAddresses.primary]->GetPhysicalAddress(false);
return false;
}
return bReturn;
}
+
+bool CCECProcessor::SendKeypress(cec_logical_address iDestination, cec_user_control_code key, bool bWait /* = false */)
+{
+ return m_busDevices[iDestination]->SendKeypress(key, bWait);
+}
+
+bool CCECProcessor::SendKeyRelease(cec_logical_address iDestination, bool bWait /* = false */)
+{
+ return m_busDevices[iDestination]->SendKeyRelease(bWait);
+}