#include "CECCommandHandler.h"
#include "../devices/CECBusDevice.h"
+#include "../devices/CECAudioSystem.h"
#include "../CECProcessor.h"
using namespace CEC;
{
bool bHandled(true);
- if (command.destination == m_busDevice->GetMyLogicalAddress())
+ CStdString strLog;
+ strLog.Format(">> %x -> %x: %s (%2x)", command.initiator, command.destination, ToString(command.opcode), command.opcode);
+ m_busDevice->AddLog(CEC_LOG_NOTICE, strLog);
+
+ if (m_busDevice->MyLogicalAddressContains(command.destination))
{
switch(command.opcode)
{
+ case CEC_OPCODE_REPORT_POWER_STATUS:
+ HandleReportPowerStatus(command);
+ break;
+ case CEC_OPCODE_CEC_VERSION:
+ HandleDeviceCecVersion(command);
+ break;
+ case CEC_OPCODE_SET_MENU_LANGUAGE:
+ HandleSetMenuLanguage(command);
+ m_busDevice->GetProcessor()->AddCommand(command);
+ break;
case CEC_OPCODE_GIVE_PHYSICAL_ADDRESS:
HandleGivePhysicalAddress(command);
break;
case CEC_OPCODE_USER_CONTROL_RELEASE:
HandleUserControlRelease(command);
break;
+ case CEC_OPCODE_GIVE_AUDIO_STATUS:
+ HandleGiveAudioStatus(command);
+ break;
+ case CEC_OPCODE_GIVE_SYSTEM_AUDIO_MODE_STATUS:
+ HandleGiveSystemAudioModeStatus(command);
+ break;
+ case CEC_OPCODE_SYSTEM_AUDIO_MODE_REQUEST:
+ HandleSetSystemAudioModeRequest(command);
+ break;
default:
UnhandledCommand(command);
+ m_busDevice->GetProcessor()->AddCommand(command);
bHandled = false;
break;
}
CStdString strLog;
switch (command.opcode)
{
+ case CEC_OPCODE_SET_MENU_LANGUAGE:
+ HandleSetMenuLanguage(command);
+ m_busDevice->GetProcessor()->AddCommand(command);
+ break;
case CEC_OPCODE_REQUEST_ACTIVE_SOURCE:
HandleRequestActiveSource(command);
break;
case CEC_OPCODE_SET_STREAM_PATH:
HandleSetStreamPath(command);
+ m_busDevice->GetProcessor()->AddCommand(command);
break;
case CEC_OPCODE_ROUTING_CHANGE:
HandleRoutingChange(command);
+ m_busDevice->GetProcessor()->AddCommand(command);
break;
case CEC_OPCODE_DEVICE_VENDOR_ID:
HandleDeviceVendorId(command);
break;
default:
UnhandledCommand(command);
+ m_busDevice->GetProcessor()->AddCommand(command);
bHandled = false;
break;
}
else
{
CStdString strLog;
- strLog.Format("ignoring frame: destination: %u != %u", command.destination, (uint8_t)m_busDevice->GetMyLogicalAddress());
+ strLog.Format("ignoring frame: we're not at destination %x", command.destination);
m_busDevice->AddLog(CEC_LOG_DEBUG, strLog.c_str());
bHandled = false;
}
return bHandled;
}
+bool CCECCommandHandler::HandleDeviceCecVersion(const cec_command &command)
+{
+ if (command.parameters.size == 1)
+ {
+ CCECBusDevice *device = GetDevice(command.initiator);
+ if (device)
+ device->SetCecVersion((cec_version) command.parameters[0]);
+ }
+
+ return true;
+}
+
bool CCECCommandHandler::HandleDeviceVendorCommandWithId(const cec_command &command)
{
- m_busDevice->GetProcessor()->ParseVendorId(command.initiator, command.parameters);
+ SetVendorId(command);
return true;
}
bool CCECCommandHandler::HandleDeviceVendorId(const cec_command &command)
{
- m_busDevice->GetProcessor()->ParseVendorId(command.initiator, command.parameters);
+ SetVendorId(command);
return true;
}
bool CCECCommandHandler::HandleGetCecVersion(const cec_command &command)
{
- m_busDevice->GetProcessor()->ReportCECVersion(command.initiator);
- return true;
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device)
+ return device->TransmitCECVersion(command.initiator);
+
+ return false;
+}
+
+bool CCECCommandHandler::HandleGiveAudioStatus(const cec_command &command)
+{
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device && device->GetType() == CEC_DEVICE_TYPE_AUDIO_SYSTEM)
+ return ((CCECAudioSystem *) device)->TransmitAudioStatus(command.initiator);
+
+ return false;
}
bool CCECCommandHandler::HandleGiveDeckStatus(const cec_command &command)
{
- // need to support opcodes play and deck control before doing anything with this
- m_busDevice->GetProcessor()->TransmitAbort(command.initiator, CEC_OPCODE_GIVE_DECK_STATUS);
- return true;
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device)
+ return device->TransmitDeckStatus(command.initiator);
+
+ return false;
}
bool CCECCommandHandler::HandleGiveDevicePowerStatus(const cec_command &command)
{
- m_busDevice->GetProcessor()->ReportPowerState(command.initiator);
- return true;
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device)
+ return device->TransmitPowerState(command.initiator);
+
+ return false;
}
bool CCECCommandHandler::HandleGiveDeviceVendorId(const cec_command &command)
{
- m_busDevice->GetProcessor()->ReportVendorID(command.initiator);
- return true;
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device)
+ return device->TransmitVendorID(command.initiator);
+
+ return false;
}
bool CCECCommandHandler::HandleGiveOSDName(const cec_command &command)
{
- m_busDevice->GetProcessor()->ReportOSDName(command.initiator);
- return true;
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device)
+ return device->TransmitOSDName(command.initiator);
+
+ return false;
}
bool CCECCommandHandler::HandleGivePhysicalAddress(const cec_command &command)
{
- m_busDevice->GetProcessor()->ReportPhysicalAddress();
- return true;
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device)
+ return device->TransmitPhysicalAddress();
+
+ return false;
}
bool CCECCommandHandler::HandleMenuRequest(const cec_command &command)
{
if (command.parameters[0] == CEC_MENU_REQUEST_TYPE_QUERY)
- m_busDevice->GetProcessor()->ReportMenuState(command.initiator);
+ {
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device)
+ return device->TransmitMenuState(command.initiator);
+ }
+ return false;
+}
+
+bool CCECCommandHandler::HandleReportPowerStatus(const cec_command &command)
+{
+ if (command.parameters.size == 1)
+ {
+ CCECBusDevice *device = GetDevice(command.initiator);
+ if (device)
+ device->SetPowerStatus((cec_power_status) command.parameters[0]);
+ }
return true;
}
CStdString strLog;
strLog.Format(">> %i requests active source", (uint8_t) command.initiator);
m_busDevice->AddLog(CEC_LOG_DEBUG, strLog.c_str());
- m_busDevice->GetProcessor()->BroadcastActiveSource();
- return true;
+ CCECBusDevice *device = m_busDevice->GetProcessor()->m_busDevices[m_busDevice->GetMyLogicalAddress()];
+ if (device)
+ return device->TransmitActiveSource();
+ return false;
}
bool CCECCommandHandler::HandleRoutingChange(const cec_command &command)
uint16_t iOldAddress = ((uint16_t)command.parameters[0] << 8) | ((uint16_t)command.parameters[1]);
uint16_t iNewAddress = ((uint16_t)command.parameters[2] << 8) | ((uint16_t)command.parameters[3]);
- m_busDevice->SetPhysicalAddress(iNewAddress, iOldAddress);
+ CCECBusDevice *device = GetDevice(command.initiator);
+ if (device)
+ device->SetStreamPath(iNewAddress, iOldAddress);
+ }
+ return true;
+}
+
+bool CCECCommandHandler::HandleSetMenuLanguage(const cec_command &command)
+{
+ if (command.parameters.size == 3)
+ {
+ CCECBusDevice *device = GetDevice(command.initiator);
+ if (device)
+ {
+ cec_menu_language language;
+ language.device = command.initiator;
+ for (uint8_t iPtr = 0; iPtr < 4; iPtr++)
+ language.language[iPtr] = command.parameters[iPtr];
+ language.language[3] = 0;
+ device->SetMenuLanguage(language);
+ }
}
return true;
}
CStdString strLog;
strLog.Format(">> %i requests stream path from physical address %04x", command.initiator, streamaddr);
m_busDevice->AddLog(CEC_LOG_DEBUG, strLog.c_str());
- if (streamaddr == m_busDevice->GetMyPhysicalAddress())
- m_busDevice->GetProcessor()->BroadcastActiveSource();
+ CCECBusDevice *device = GetDeviceByPhysicalAddress(streamaddr);
+ if (device)
+ return device->TransmitActiveSource();
+ }
+ return true;
+}
+
+bool CCECCommandHandler::HandleSetSystemAudioModeRequest(const cec_command &command)
+{
+ if (command.parameters.size >= 1)
+ {
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device&& device->GetType() == CEC_DEVICE_TYPE_AUDIO_SYSTEM)
+ return ((CCECAudioSystem *) device)->SetSystemAudioMode(command);
}
return true;
}
+bool CCECCommandHandler::HandleGiveSystemAudioModeStatus(const cec_command &command)
+{
+ CCECBusDevice *device = GetDevice(command.destination);
+ if (device && device->GetType() == CEC_DEVICE_TYPE_AUDIO_SYSTEM)
+ return ((CCECAudioSystem *) device)->TransmitSystemAudioModeStatus(command.initiator);
+
+ return false;
+}
+
bool CCECCommandHandler::HandleUserControlPressed(const cec_command &command)
{
if (command.parameters.size > 0)
void CCECCommandHandler::UnhandledCommand(const cec_command &command)
{
- m_busDevice->GetProcessor()->AddCommand(command);;
+ CStdString strLog;
+ strLog.Format("unhandled command with opcode %02x from address %d", command.opcode, command.initiator);
+ m_busDevice->AddLog(CEC_LOG_DEBUG, strLog);
+}
+
+CCECBusDevice *CCECCommandHandler::GetDevice(cec_logical_address iLogicalAddress) const
+{
+ CCECBusDevice *device = NULL;
+
+ if (iLogicalAddress >= CECDEVICE_TV && iLogicalAddress <= CECDEVICE_BROADCAST)
+ device = m_busDevice->GetProcessor()->m_busDevices[iLogicalAddress];
+
+ return device;
+}
+
+CCECBusDevice *CCECCommandHandler::GetDeviceByPhysicalAddress(uint16_t iPhysicalAddress) const
+{
+ CCECBusDevice *device = NULL;
+
+ for (unsigned int iPtr = 0; iPtr < 16; iPtr++)
+ {
+ if (m_busDevice->GetProcessor()->m_busDevices[iPtr]->GetPhysicalAddress() == iPhysicalAddress)
+ {
+ device = m_busDevice->GetProcessor()->m_busDevices[iPtr];
+ break;
+ }
+ }
+
+ return device;
+}
+
+void CCECCommandHandler::SetVendorId(const cec_command &command)
+{
+ if (command.parameters.size < 3)
+ {
+ m_busDevice->AddLog(CEC_LOG_WARNING, "invalid vendor ID received");
+ return;
+ }
+
+ uint64_t iVendorId = ((uint64_t)command.parameters[0] << 16) +
+ ((uint64_t)command.parameters[1] << 8) +
+ (uint64_t)command.parameters[2];
+
+ CCECBusDevice *device = GetDevice((cec_logical_address) command.initiator);
+ if (device)
+ device->SetVendorId(iVendorId, command.parameters.size > 3 ? command.parameters[3] : 0);
+}
+
+const char *CCECCommandHandler::ToString(const cec_opcode opcode)
+{
+ switch (opcode)
+ {
+ case CEC_OPCODE_ACTIVE_SOURCE:
+ return "active source";
+ case CEC_OPCODE_IMAGE_VIEW_ON:
+ return "image view on";
+ case CEC_OPCODE_TEXT_VIEW_ON:
+ return "text view on";
+ case CEC_OPCODE_INACTIVE_SOURCE:
+ return "inactive source";
+ case CEC_OPCODE_REQUEST_ACTIVE_SOURCE:
+ return "request active source";
+ case CEC_OPCODE_ROUTING_CHANGE:
+ return "routing change";
+ case CEC_OPCODE_ROUTING_INFORMATION:
+ return "routing information";
+ case CEC_OPCODE_SET_STREAM_PATH:
+ return "set stream path";
+ case CEC_OPCODE_STANDBY:
+ return "standby";
+ case CEC_OPCODE_RECORD_OFF:
+ return "record off";
+ case CEC_OPCODE_RECORD_ON:
+ return "record on";
+ case CEC_OPCODE_RECORD_STATUS:
+ return "record status";
+ case CEC_OPCODE_RECORD_TV_SCREEN:
+ return "record tv screen";
+ case CEC_OPCODE_CLEAR_ANALOGUE_TIMER:
+ return "clear analogue timer";
+ case CEC_OPCODE_CLEAR_DIGITAL_TIMER:
+ return "clear digital timer";
+ case CEC_OPCODE_CLEAR_EXTERNAL_TIMER:
+ return "clear external timer";
+ case CEC_OPCODE_SET_ANALOGUE_TIMER:
+ return "set analogue timer";
+ case CEC_OPCODE_SET_DIGITAL_TIMER:
+ return "set digital timer";
+ case CEC_OPCODE_SET_EXTERNAL_TIMER:
+ return "set external timer";
+ case CEC_OPCODE_SET_TIMER_PROGRAM_TITLE:
+ return "set timer program title";
+ case CEC_OPCODE_TIMER_CLEARED_STATUS:
+ return "timer cleared status";
+ case CEC_OPCODE_TIMER_STATUS:
+ return "timer status";
+ case CEC_OPCODE_CEC_VERSION:
+ return "cec version";
+ case CEC_OPCODE_GET_CEC_VERSION:
+ return "get cec version";
+ case CEC_OPCODE_GIVE_PHYSICAL_ADDRESS:
+ return "give physical address";
+ case CEC_OPCODE_GET_MENU_LANGUAGE:
+ return "get menu language";
+ case CEC_OPCODE_REPORT_PHYSICAL_ADDRESS:
+ return "report physical address";
+ case CEC_OPCODE_SET_MENU_LANGUAGE:
+ return "set menu language";
+ case CEC_OPCODE_DECK_CONTROL:
+ return "deck control";
+ case CEC_OPCODE_DECK_STATUS:
+ return "deck status";
+ case CEC_OPCODE_GIVE_DECK_STATUS:
+ return "give deck status";
+ case CEC_OPCODE_PLAY:
+ return "play";
+ case CEC_OPCODE_GIVE_TUNER_DEVICE_STATUS:
+ return "give tuner status";
+ case CEC_OPCODE_SELECT_ANALOGUE_SERVICE:
+ return "select analogue service";
+ case CEC_OPCODE_SELECT_DIGITAL_SERVICE:
+ return "set digital service";
+ case CEC_OPCODE_TUNER_DEVICE_STATUS:
+ return "tuner device status";
+ case CEC_OPCODE_TUNER_STEP_DECREMENT:
+ return "tuner step decrement";
+ case CEC_OPCODE_TUNER_STEP_INCREMENT:
+ return "tuner step increment";
+ case CEC_OPCODE_DEVICE_VENDOR_ID:
+ return "device vendor id";
+ case CEC_OPCODE_GIVE_DEVICE_VENDOR_ID:
+ return "give device vendor id";
+ case CEC_OPCODE_VENDOR_COMMAND:
+ return "vendor command";
+ case CEC_OPCODE_VENDOR_COMMAND_WITH_ID:
+ return "vendor command with id";
+ case CEC_OPCODE_VENDOR_REMOTE_BUTTON_DOWN:
+ return "vendor remote button down";
+ case CEC_OPCODE_VENDOR_REMOTE_BUTTON_UP:
+ return "vendor remote button up";
+ case CEC_OPCODE_SET_OSD_STRING:
+ return "set osd string";
+ case CEC_OPCODE_GIVE_OSD_NAME:
+ return "give osd name";
+ case CEC_OPCODE_SET_OSD_NAME:
+ return "set osd name";
+ case CEC_OPCODE_MENU_REQUEST:
+ return "menu request";
+ case CEC_OPCODE_MENU_STATUS:
+ return "menu status";
+ case CEC_OPCODE_USER_CONTROL_PRESSED:
+ return "user control pressed";
+ case CEC_OPCODE_USER_CONTROL_RELEASE:
+ return "user control release";
+ case CEC_OPCODE_GIVE_DEVICE_POWER_STATUS:
+ return "give device power status";
+ case CEC_OPCODE_REPORT_POWER_STATUS:
+ return "report power status";
+ case CEC_OPCODE_FEATURE_ABORT:
+ return "feature abort";
+ case CEC_OPCODE_ABORT:
+ return "abort";
+ case CEC_OPCODE_GIVE_AUDIO_STATUS:
+ return "give audio status";
+ case CEC_OPCODE_GIVE_SYSTEM_AUDIO_MODE_STATUS:
+ return "give audio mode status";
+ case CEC_OPCODE_REPORT_AUDIO_STATUS:
+ return "report audio status";
+ case CEC_OPCODE_SET_SYSTEM_AUDIO_MODE:
+ return "set system audio mode";
+ case CEC_OPCODE_SYSTEM_AUDIO_MODE_REQUEST:
+ return "system audio mode request";
+ case CEC_OPCODE_SYSTEM_AUDIO_MODE_STATUS:
+ return "system audio mode status";
+ case CEC_OPCODE_SET_AUDIO_RATE:
+ return "set audio rate";
+ default:
+ return "UNKNOWN";
+ }
}
repositories / deb_libcec.git / blobdiff