X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2FLibCEC.cpp;h=c24b4ed96e7d2ffcd8cb93fdbc7051d3325a0d30;hb=d9de2aae6b2f47b8e1faacc69adba7406b9d85f0;hp=1646041da0dd9759ee91f22674a587611d877d87;hpb=205057410e723e23ab0f4ac910c497b3ecd319bd;p=deb_libcec.git diff --git a/src/lib/LibCEC.cpp b/src/lib/LibCEC.cpp index 1646041..c24b4ed 100644 --- a/src/lib/LibCEC.cpp +++ b/src/lib/LibCEC.cpp @@ -1,7 +1,7 @@ /* * This file is part of the libCEC(R) library. * - * libCEC(R) is Copyright (C) 2011-2012 Pulse-Eight Limited. All rights reserved. + * 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. @@ -30,10 +30,11 @@ * http://www.pulse-eight.net/ */ +#include "env.h" #include "LibCEC.h" -#include "adapter/USBCECAdapterDetection.h" -#include "adapter/USBCECAdapterCommunication.h" +#include "adapter/AdapterFactory.h" +#include "adapter/AdapterCommunication.h" #include "CECProcessor.h" #include "devices/CECAudioSystem.h" #include "devices/CECBusDevice.h" @@ -41,6 +42,7 @@ #include "devices/CECTV.h" #include "platform/util/timeutils.h" #include "platform/util/StdString.h" +#include "platform/util/util.h" #include "CECClient.h" @@ -48,14 +50,7 @@ using namespace std; using namespace CEC; using namespace PLATFORM; -CLibCEC::CLibCEC(const char *UNUSED(strDeviceName), cec_device_type_list UNUSED(types), uint16_t UNUSED(iPhysicalAddress) /* = 0 */) : - m_iStartTime(GetTimeMs()), - m_client(NULL) -{ - m_cec = new CCECProcessor(this); -} - -CLibCEC::CLibCEC(libcec_configuration *UNUSED(configuration)) : +CLibCEC::CLibCEC(void) : m_iStartTime(GetTimeMs()), m_client(NULL) { @@ -64,29 +59,26 @@ CLibCEC::CLibCEC(libcec_configuration *UNUSED(configuration)) : CLibCEC::~CLibCEC(void) { - delete m_client; - m_client = NULL; - delete m_cec; - m_cec = NULL; + // unregister all clients client + UnregisterClients(); + + // delete the adapter connection + DELETE_AND_NULL(m_cec); } bool CLibCEC::Open(const char *strPort, uint32_t iTimeoutMs /* = CEC_DEFAULT_CONNECT_TIMEOUT */) { - if (!m_cec) + if (!m_cec || !strPort) return false; - if (m_cec->IsRunning()) - { - AddLog(CEC_LOG_ERROR, "connection already open"); - return false; - } - + // open a new connection if (!m_cec->Start(strPort, CEC_SERIAL_DEFAULT_BAUDRATE, iTimeoutMs)) { AddLog(CEC_LOG_ERROR, "could not start CEC communications"); return false; } + // register all clients for (vector::iterator it = m_clients.begin(); it != m_clients.end(); it++) { if (!m_cec->RegisterClient(*it)) @@ -101,24 +93,19 @@ bool CLibCEC::Open(const char *strPort, uint32_t iTimeoutMs /* = CEC_DEFAULT_CON void CLibCEC::Close(void) { - if (m_cec) - m_cec->Close(); + if (!m_cec) + return; - for (vector::iterator it = m_clients.begin(); it != m_clients.end(); it++) - { - (*it)->SetRegistered(false); - (*it)->SetInitialised(false); - } -} + // unregister all clients + m_cec->UnregisterClients(); -int8_t CLibCEC::FindAdapters(cec_adapter *deviceList, uint8_t iBufSize, const char *strDevicePath /* = NULL */) -{ - return CUSBCECAdapterDetection::FindAdapters(deviceList, iBufSize, strDevicePath); + // close the connection + m_cec->Close(); } -bool CLibCEC::PingAdapter(void) +int8_t CLibCEC::FindAdapters(cec_adapter *deviceList, uint8_t iBufSize, const char *strDevicePath /* = NULL */) { - return m_cec ? m_cec->PingAdapter() : false; + return CAdapterFactory(this).FindAdapters(deviceList, iBufSize, strDevicePath); } bool CLibCEC::StartBootloader(void) @@ -126,108 +113,50 @@ bool CLibCEC::StartBootloader(void) return m_cec ? m_cec->StartBootloader() : false; } -bool CLibCEC::SwitchMonitoring(bool bEnable) -{ - return m_cec ? m_cec->SwitchMonitoring(bEnable) : false; -} - -cec_logical_address CLibCEC::GetActiveSource(void) -{ - return m_cec ? m_cec->GetActiveSource() : CECDEVICE_UNKNOWN; -} - -bool CLibCEC::IsActiveSource(cec_logical_address iAddress) -{ - return m_cec ? m_cec->IsActiveSource(iAddress) : false; -} - -bool CLibCEC::PollDevice(cec_logical_address iAddress) -{ - return m_cec ? m_cec->PollDevice(iAddress) : false; -} - -cec_logical_addresses CLibCEC::GetActiveDevices(void) -{ - CECDEVICEVEC activeDevices; - if (m_cec) - m_cec->GetDevices()->GetActive(activeDevices); - return CCECDeviceMap::ToLogicalAddresses(activeDevices); -} - -bool CLibCEC::IsActiveDevice(cec_logical_address iAddress) -{ - cec_logical_addresses activeDevices = GetActiveDevices(); - return activeDevices.IsSet(iAddress); -} - -bool CLibCEC::IsActiveDeviceType(cec_device_type type) +bool CLibCEC::PingAdapter(void) { - CECDEVICEVEC activeDevices; - if (m_cec) - m_cec->GetDevices()->GetActive(activeDevices); - CCECDeviceMap::FilterType(type, activeDevices); - return !activeDevices.empty(); + return m_client ? m_client->PingAdapter() : false; } -bool CLibCEC::SetStreamPath(cec_logical_address iAddress) +bool CLibCEC::EnableCallbacks(void *cbParam, ICECCallbacks *callbacks) { - uint16_t iPhysicalAddress = GetDevicePhysicalAddress(iAddress); - if (iPhysicalAddress != CEC_INVALID_PHYSICAL_ADDRESS) - return SetStreamPath(iPhysicalAddress); - return false; + return m_client ? m_client->EnableCallbacks(cbParam, callbacks) : false; } -bool CLibCEC::SetStreamPath(uint16_t iPhysicalAddress) +bool CLibCEC::GetCurrentConfiguration(libcec_configuration *configuration) { - return m_cec->SetStreamPath(iPhysicalAddress); + return m_client ? m_client->GetCurrentConfiguration(*configuration) : false; } -bool CLibCEC::IsLibCECActiveSource(void) +bool CLibCEC::SetConfiguration(const libcec_configuration *configuration) { - bool bReturn(false); - if (m_cec) - { - cec_logical_address activeSource = m_cec->GetActiveSource(); - CCECBusDevice *device = m_cec->GetDevice(activeSource); - if (device) - bReturn = device->IsHandledByLibCEC(); - } - return bReturn; + return m_client ? m_client->SetConfiguration(*configuration) : false; } bool CLibCEC::CanPersistConfiguration(void) { - return m_cec->CanPersistConfiguration(); + return m_client ? m_client->CanPersistConfiguration() : false; } bool CLibCEC::PersistConfiguration(libcec_configuration *configuration) { - return m_cec->PersistConfiguration(configuration); + return m_client ? m_client->PersistConfiguration(*configuration) : false; } void CLibCEC::RescanActiveDevices(void) { - return m_cec->RescanActiveDevices(); -} - -bool CLibCEC::EnableCallbacks(void *cbParam, ICECCallbacks *callbacks) -{ - return m_client ? m_client->EnableCallbacks(cbParam, callbacks) : false; -} - -bool CLibCEC::GetCurrentConfiguration(libcec_configuration *configuration) -{ - return m_client ? m_client->GetCurrentConfiguration(configuration) : false; + if (m_client) + m_client->RescanActiveDevices(); } -bool CLibCEC::SetConfiguration(const libcec_configuration *configuration) +bool CLibCEC::IsLibCECActiveSource(void) { - return m_client ? m_client->SetConfiguration(configuration) : false; + return m_client ? m_client->IsLibCECActiveSource() : false; } bool CLibCEC::Transmit(const cec_command &data) { - return m_client ? m_client->Transmit(data) : false; + return m_client ? m_client->Transmit(data, false) : false; } bool CLibCEC::SetLogicalAddress(cec_logical_address iLogicalAddress) @@ -285,6 +214,11 @@ bool CLibCEC::SetOSDString(cec_logical_address iLogicalAddress, cec_display_cont return m_client ? m_client->SendSetOSDString(iLogicalAddress, duration, strMessage) : false; } +bool CLibCEC::SwitchMonitoring(bool bEnable) +{ + return m_client ? m_client->SwitchMonitoring(bEnable) : false; +} + cec_version CLibCEC::GetDeviceCecVersion(cec_logical_address iAddress) { return m_client ? m_client->GetDeviceCecVersion(iAddress) : CEC_VERSION_UNKNOWN; @@ -292,7 +226,7 @@ cec_version CLibCEC::GetDeviceCecVersion(cec_logical_address iAddress) bool CLibCEC::GetDeviceMenuLanguage(cec_logical_address iAddress, cec_menu_language *language) { - return m_client ? m_client->GetDeviceMenuLanguage(iAddress, language) : false; + return m_client ? m_client->GetDeviceMenuLanguage(iAddress, *language) : false; } uint64_t CLibCEC::GetDeviceVendorId(cec_logical_address iAddress) @@ -310,6 +244,30 @@ cec_power_status CLibCEC::GetDevicePowerStatus(cec_logical_address iAddress) return m_client ? m_client->GetDevicePowerStatus(iAddress) : CEC_POWER_STATUS_UNKNOWN; } +bool CLibCEC::PollDevice(cec_logical_address iAddress) +{ + return m_client ? m_client->PollDevice(iAddress) : false; +} + +cec_logical_addresses CLibCEC::GetActiveDevices(void) +{ + cec_logical_addresses addresses; + addresses.Clear(); + if (m_client) + addresses = m_client->GetActiveDevices(); + return addresses; +} + +bool CLibCEC::IsActiveDevice(cec_logical_address iAddress) +{ + return m_client ? m_client->IsActiveDevice(iAddress) : false; +} + +bool CLibCEC::IsActiveDeviceType(cec_device_type type) +{ + return m_client ? m_client->IsActiveDeviceType(type) : false; +} + uint8_t CLibCEC::VolumeUp(bool bSendRelease /* = true */) { return m_client ? m_client->SendVolumeUp(bSendRelease) : (uint8_t)CEC_AUDIO_VOLUME_STATUS_UNKNOWN; @@ -322,6 +280,7 @@ uint8_t CLibCEC::VolumeDown(bool bSendRelease /* = true */) uint8_t CLibCEC::MuteAudio(bool UNUSED(bSendRelease) /* = true */) { + AddLog(CEC_LOG_WARNING, "deprecated function called: %s", __FUNCTION__); return m_client ? m_client->SendMuteAudio() : (uint8_t)CEC_AUDIO_VOLUME_STATUS_UNKNOWN; } @@ -346,110 +305,47 @@ cec_osd_name CLibCEC::GetDeviceOSDName(cec_logical_address iAddress) return retVal; } -cec_logical_addresses CLibCEC::GetLogicalAddresses(void) +cec_logical_address CLibCEC::GetActiveSource(void) { - cec_logical_addresses addresses; - addresses.Clear(); - if (m_cec) - addresses = m_cec->GetLogicalAddresses(); - return addresses; + return m_client ? m_client->GetActiveSource() : CECDEVICE_UNKNOWN; } -bool CLibCEC::GetNextLogMessage(cec_log_message *message) +bool CLibCEC::IsActiveSource(cec_logical_address iAddress) { - return m_client ? m_client->GetNextLogMessage(message) : false; + return m_client ? m_client->IsActiveSource(iAddress) : false; +} +bool CLibCEC::SetStreamPath(cec_logical_address iAddress) +{ + return m_client ? m_client->SetStreamPath(iAddress) : false; } -bool CLibCEC::GetNextKeypress(cec_keypress *key) +bool CLibCEC::SetStreamPath(uint16_t iPhysicalAddress) { - return m_client ? m_client->GetNextKeypress(key) : false; + return m_client ? m_client->SetStreamPath(iPhysicalAddress) : false; } -bool CLibCEC::GetNextCommand(cec_command *command) +cec_logical_addresses CLibCEC::GetLogicalAddresses(void) { - return m_client ? m_client->GetNextCommand(command) : false; + cec_logical_addresses addresses; + addresses.Clear(); + if (m_client) + addresses = m_client->GetLogicalAddresses(); + return addresses; } cec_device_type CLibCEC::GetType(cec_logical_address address) { - switch (address) - { - case CECDEVICE_AUDIOSYSTEM: - return CEC_DEVICE_TYPE_AUDIO_SYSTEM; - case CECDEVICE_PLAYBACKDEVICE1: - case CECDEVICE_PLAYBACKDEVICE2: - case CECDEVICE_PLAYBACKDEVICE3: - return CEC_DEVICE_TYPE_PLAYBACK_DEVICE; - case CECDEVICE_RECORDINGDEVICE1: - case CECDEVICE_RECORDINGDEVICE2: - case CECDEVICE_RECORDINGDEVICE3: - return CEC_DEVICE_TYPE_RECORDING_DEVICE; - case CECDEVICE_TUNER1: - case CECDEVICE_TUNER2: - case CECDEVICE_TUNER3: - case CECDEVICE_TUNER4: - return CEC_DEVICE_TYPE_TUNER; - case CECDEVICE_TV: - return CEC_DEVICE_TYPE_TV; - default: - return CEC_DEVICE_TYPE_RESERVED; - } + return CCECTypeUtils::GetType(address); } uint16_t CLibCEC::GetMaskForType(cec_logical_address address) { - return GetMaskForType(GetType(address)); + return CCECTypeUtils::GetMaskForType(address); } uint16_t CLibCEC::GetMaskForType(cec_device_type type) { - switch (type) - { - case CEC_DEVICE_TYPE_AUDIO_SYSTEM: - { - cec_logical_addresses addr; - addr.Clear(); - addr.Set(CECDEVICE_AUDIOSYSTEM); - return addr.AckMask(); - } - case CEC_DEVICE_TYPE_PLAYBACK_DEVICE: - { - cec_logical_addresses addr; - addr.Clear(); - addr.Set(CECDEVICE_PLAYBACKDEVICE1); - addr.Set(CECDEVICE_PLAYBACKDEVICE2); - addr.Set(CECDEVICE_PLAYBACKDEVICE3); - return addr.AckMask(); - } - case CEC_DEVICE_TYPE_RECORDING_DEVICE: - { - cec_logical_addresses addr; - addr.Clear(); - addr.Set(CECDEVICE_RECORDINGDEVICE1); - addr.Set(CECDEVICE_RECORDINGDEVICE2); - addr.Set(CECDEVICE_RECORDINGDEVICE3); - return addr.AckMask(); - } - case CEC_DEVICE_TYPE_TUNER: - { - cec_logical_addresses addr; - addr.Clear(); - addr.Set(CECDEVICE_TUNER1); - addr.Set(CECDEVICE_TUNER2); - addr.Set(CECDEVICE_TUNER3); - addr.Set(CECDEVICE_TUNER4); - return addr.AckMask(); - } - case CEC_DEVICE_TYPE_TV: - { - cec_logical_addresses addr; - addr.Clear(); - addr.Set(CECDEVICE_TV); - return addr.AckMask(); - } - default: - return 0; - } + return CCECTypeUtils::GetMaskForType(type); } bool CLibCEC::IsValidPhysicalAddress(uint16_t iPhysicalAddress) @@ -458,420 +354,6 @@ bool CLibCEC::IsValidPhysicalAddress(uint16_t iPhysicalAddress) iPhysicalAddress <= CEC_MAX_PHYSICAL_ADDRESS; } -const char *CLibCEC::ToString(const cec_device_type type) -{ - switch (type) - { - case CEC_DEVICE_TYPE_AUDIO_SYSTEM: - return "audio system"; - case CEC_DEVICE_TYPE_PLAYBACK_DEVICE: - return "playback device"; - case CEC_DEVICE_TYPE_RECORDING_DEVICE: - return "recording device"; - case CEC_DEVICE_TYPE_RESERVED: - return "reserved"; - case CEC_DEVICE_TYPE_TUNER: - return "tuner"; - case CEC_DEVICE_TYPE_TV: - return "TV"; - default: - return "unknown"; - } -} - -const char *CLibCEC::ToString(const cec_menu_state state) -{ - switch (state) - { - case CEC_MENU_STATE_ACTIVATED: - return "activated"; - case CEC_MENU_STATE_DEACTIVATED: - return "deactivated"; - default: - return "unknown"; - } -} - -const char *CLibCEC::ToString(const cec_version version) -{ - switch (version) - { - case CEC_VERSION_1_2: - return "1.2"; - case CEC_VERSION_1_2A: - return "1.2a"; - case CEC_VERSION_1_3: - return "1.3"; - case CEC_VERSION_1_3A: - return "1.3a"; - case CEC_VERSION_1_4: - return "1.4"; - default: - return "unknown"; - } -} - -const char *CLibCEC::ToString(const cec_power_status status) -{ - switch (status) - { - case CEC_POWER_STATUS_ON: - return "on"; - case CEC_POWER_STATUS_STANDBY: - return "standby"; - case CEC_POWER_STATUS_IN_TRANSITION_ON_TO_STANDBY: - return "in transition from on to standby"; - case CEC_POWER_STATUS_IN_TRANSITION_STANDBY_TO_ON: - return "in transition from standby to on"; - default: - return "unknown"; - } -} - -const char *CLibCEC::ToString(const cec_logical_address address) -{ - switch(address) - { - case CECDEVICE_AUDIOSYSTEM: - return "Audio"; - case CECDEVICE_BROADCAST: - return "Broadcast"; - case CECDEVICE_FREEUSE: - return "Free use"; - case CECDEVICE_PLAYBACKDEVICE1: - return "Playback 1"; - case CECDEVICE_PLAYBACKDEVICE2: - return "Playback 2"; - case CECDEVICE_PLAYBACKDEVICE3: - return "Playback 3"; - case CECDEVICE_RECORDINGDEVICE1: - return "Recorder 1"; - case CECDEVICE_RECORDINGDEVICE2: - return "Recorder 2"; - case CECDEVICE_RECORDINGDEVICE3: - return "Recorder 3"; - case CECDEVICE_RESERVED1: - return "Reserved 1"; - case CECDEVICE_RESERVED2: - return "Reserved 2"; - case CECDEVICE_TUNER1: - return "Tuner 1"; - case CECDEVICE_TUNER2: - return "Tuner 2"; - case CECDEVICE_TUNER3: - return "Tuner 3"; - case CECDEVICE_TUNER4: - return "Tuner 4"; - case CECDEVICE_TV: - return "TV"; - default: - return "unknown"; - } -} - -const char *CLibCEC::ToString(const cec_deck_control_mode mode) -{ - switch (mode) - { - case CEC_DECK_CONTROL_MODE_SKIP_FORWARD_WIND: - return "skip forward wind"; - case CEC_DECK_CONTROL_MODE_EJECT: - return "eject"; - case CEC_DECK_CONTROL_MODE_SKIP_REVERSE_REWIND: - return "reverse rewind"; - case CEC_DECK_CONTROL_MODE_STOP: - return "stop"; - default: - return "unknown"; - } -} - -const char *CLibCEC::ToString(const cec_deck_info status) -{ - switch (status) - { - case CEC_DECK_INFO_PLAY: - return "play"; - case CEC_DECK_INFO_RECORD: - return "record"; - case CEC_DECK_INFO_PLAY_REVERSE: - return "play reverse"; - case CEC_DECK_INFO_STILL: - return "still"; - case CEC_DECK_INFO_SLOW: - return "slow"; - case CEC_DECK_INFO_SLOW_REVERSE: - return "slow reverse"; - case CEC_DECK_INFO_FAST_FORWARD: - return "fast forward"; - case CEC_DECK_INFO_FAST_REVERSE: - return "fast reverse"; - case CEC_DECK_INFO_NO_MEDIA: - return "no media"; - case CEC_DECK_INFO_STOP: - return "stop"; - case CEC_DECK_INFO_SKIP_FORWARD_WIND: - return "info skip forward wind"; - case CEC_DECK_INFO_SKIP_REVERSE_REWIND: - return "info skip reverse rewind"; - case CEC_DECK_INFO_INDEX_SEARCH_FORWARD: - return "info index search forward"; - case CEC_DECK_INFO_INDEX_SEARCH_REVERSE: - return "info index search reverse"; - case CEC_DECK_INFO_OTHER_STATUS: - return "other"; - case CEC_DECK_INFO_OTHER_STATUS_LG: - return "LG other"; - default: - return "unknown"; - } -} - -const char *CLibCEC::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"; - case CEC_OPCODE_START_ARC: - return "start ARC"; - case CEC_OPCODE_REPORT_ARC_STARTED: - return "report ARC started"; - case CEC_OPCODE_REPORT_ARC_ENDED: - return "report ARC ended"; - case CEC_OPCODE_REQUEST_ARC_START: - return "request ARC start"; - case CEC_OPCODE_REQUEST_ARC_END: - return "request ARC end"; - case CEC_OPCODE_END_ARC: - return "end ARC"; - case CEC_OPCODE_CDC: - return "CDC"; - case CEC_OPCODE_NONE: - return "poll"; - default: - return "UNKNOWN"; - } -} - -const char *CLibCEC::ToString(const cec_system_audio_status mode) -{ - switch(mode) - { - case CEC_SYSTEM_AUDIO_STATUS_ON: - return "on"; - case CEC_SYSTEM_AUDIO_STATUS_OFF: - return "off"; - default: - return "unknown"; - } -} - -const char *CLibCEC::ToString(const cec_audio_status UNUSED(status)) -{ - // TODO this is a mask - return "TODO"; -} - -const char *CLibCEC::ToString(const cec_vendor_id vendor) -{ - switch (vendor) - { - case CEC_VENDOR_SAMSUNG: - return "Samsung"; - case CEC_VENDOR_LG: - return "LG"; - case CEC_VENDOR_PANASONIC: - return "Panasonic"; - case CEC_VENDOR_PIONEER: - return "Pioneer"; - case CEC_VENDOR_ONKYO: - return "Onkyo"; - case CEC_VENDOR_YAMAHA: - return "Yamaha"; - case CEC_VENDOR_PHILIPS: - return "Philips"; - case CEC_VENDOR_SONY: - return "Sony"; - case CEC_VENDOR_TOSHIBA: - return "Toshiba"; - default: - return "Unknown"; - } -} - -const char *CLibCEC::ToString(const cec_client_version version) -{ - switch (version) - { - case CEC_CLIENT_VERSION_PRE_1_5: - return "pre-1.5"; - case CEC_CLIENT_VERSION_1_5_0: - return "1.5.0"; - case CEC_CLIENT_VERSION_1_5_1: - return "1.5.1"; - case CEC_CLIENT_VERSION_1_5_2: - return "1.5.2"; - case CEC_CLIENT_VERSION_1_5_3: - return "1.5.3"; - case CEC_CLIENT_VERSION_1_6_0: - return "1.6.0"; - case CEC_CLIENT_VERSION_1_6_1: - return "1.6.1"; - case CEC_CLIENT_VERSION_1_6_2: - return "1.6.2"; - default: - return "Unknown"; - } -} - -const char *CLibCEC::ToString(const cec_server_version version) -{ - switch (version) - { - case CEC_SERVER_VERSION_PRE_1_5: - return "pre-1.5"; - case CEC_SERVER_VERSION_1_5_0: - return "1.5.0"; - case CEC_SERVER_VERSION_1_5_1: - return "1.5.1"; - case CEC_SERVER_VERSION_1_5_2: - return "1.5.2"; - case CEC_SERVER_VERSION_1_5_3: - return "1.5.3"; - case CEC_SERVER_VERSION_1_6_0: - return "1.6.0"; - case CEC_SERVER_VERSION_1_6_1: - return "1.6.1"; - case CEC_SERVER_VERSION_1_6_2: - return "1.6.2"; - default: - return "Unknown"; - } -} - void CLibCEC::CheckKeypressTimeout(void) { // check all clients @@ -883,6 +365,7 @@ void CLibCEC::AddLog(const cec_log_level level, const char *strFormat, ...) { CStdString strLog; + // format the message va_list argList; va_start(argList, strFormat); strLog.FormatV(strFormat, argList); @@ -898,39 +381,37 @@ void CLibCEC::AddLog(const cec_log_level level, const char *strFormat, ...) (*it)->AddLog(message); } -void CLibCEC::Alert(const libcec_alert type, const libcec_parameter ¶m) +void CLibCEC::AddCommand(const cec_command &command) { - // send the alert to all clients + // send the command to all clients for (vector::iterator it = m_clients.begin(); it != m_clients.end(); it++) - (*it)->Alert(type, param); + (*it)->AddCommand(command); } -bool CLibCEC::SetActiveView(void) -{ - AddLog(CEC_LOG_WARNING, "deprecated method %s called", __FUNCTION__); - return SetActiveSource(); -} - -bool CLibCEC::EnablePhysicalAddressDetection(void) +void CLibCEC::Alert(const libcec_alert type, const libcec_parameter ¶m) { - AddLog(CEC_LOG_WARNING, "deprecated method %s called", __FUNCTION__); - return true; + // send the alert to all clients + for (vector::iterator it = m_clients.begin(); it != m_clients.end(); it++) + (*it)->Alert(type, param); } -CCECClient *CLibCEC::RegisterClient(libcec_configuration *configuration) +CCECClient *CLibCEC::RegisterClient(libcec_configuration &configuration) { if (!m_cec) return NULL; + // create a new client instance CCECClient *newClient = new CCECClient(m_cec, configuration); if (!newClient) return NULL; - m_clients.push_back(newClient); + + // if the default client isn't set, set it if (!m_client) m_client = newClient; - if (m_cec->IsRunning()) + // register the new client + if (m_cec->CECInitialised()) m_cec->RegisterClient(newClient); return newClient; @@ -938,9 +419,12 @@ CCECClient *CLibCEC::RegisterClient(libcec_configuration *configuration) void CLibCEC::UnregisterClients(void) { + if (m_cec && m_cec->IsRunning()) + m_cec->UnregisterClients(); + m_clients.clear(); - delete m_client; - m_client = NULL; + + DELETE_AND_NULL(m_client); } void * CECInitialise(libcec_configuration *configuration) @@ -948,13 +432,17 @@ void * CECInitialise(libcec_configuration *configuration) if (!configuration) return NULL; - CLibCEC *lib = new CLibCEC(NULL); + // create a new libCEC instance + CLibCEC *lib = new CLibCEC; + + // register a new client CCECClient *client(NULL); - if (lib) - client = lib->RegisterClient(configuration); + if (lib && configuration) + client = lib->RegisterClient(*configuration); + // update the current configuration if (client) - client->GetCurrentConfiguration(configuration); + client->GetCurrentConfiguration(*configuration); // ensure that the correct server version is set configuration->serverVersion = LIBCEC_VERSION_CURRENT; @@ -962,14 +450,14 @@ void * CECInitialise(libcec_configuration *configuration) return static_cast< void* > (lib); } -void * CECInit(const char *strDeviceName, CEC::cec_device_type_list types, uint16_t iPhysicalAddress /* = 0 */) +void * CECInit(const char *strDeviceName, CEC::cec_device_type_list types) { - libcec_configuration configuration; + libcec_configuration configuration; configuration.Clear(); // client version < 1.5.0 snprintf(configuration.strDeviceName, 13, "%s", strDeviceName); configuration.deviceTypes = types; - configuration.iPhysicalAddress = iPhysicalAddress; + configuration.iPhysicalAddress = CEC_INVALID_PHYSICAL_ADDRESS; if (configuration.deviceTypes.IsEmpty()) configuration.deviceTypes.Add(CEC_DEVICE_TYPE_RECORDING_DEVICE); @@ -981,17 +469,24 @@ bool CECStartBootloader(void) { bool bReturn(false); cec_adapter deviceList[1]; - if (CUSBCECAdapterDetection::FindAdapters(deviceList, 1) > 0) + if (CAdapterFactory(NULL).FindAdapters(deviceList, 1, 0) > 0) { - CUSBCECAdapterCommunication comm(NULL, deviceList[0].comm); - CTimeout timeout(CEC_DEFAULT_CONNECT_TIMEOUT); - while (timeout.TimeLeft() > 0 && (bReturn = comm.Open(timeout.TimeLeft() / CEC_CONNECT_TRIES, true)) == false) + CAdapterFactory factory(NULL); + IAdapterCommunication *comm = factory.GetInstance(deviceList[0].comm); + if (comm) { - comm.Close(); - CEvent::Sleep(500); + CTimeout timeout(CEC_DEFAULT_CONNECT_TIMEOUT); + while (timeout.TimeLeft() > 0 && + (bReturn = comm->Open(timeout.TimeLeft() / CEC_CONNECT_TRIES, true)) == false) + { + comm->Close(); + CEvent::Sleep(500); + } + if (comm->IsOpen()) + bReturn = comm->StartBootloader(); + + delete comm; } - if (comm.IsOpen()) - bReturn = comm.StartBootloader(); } return bReturn; @@ -999,7 +494,7 @@ bool CECStartBootloader(void) void CECDestroy(CEC::ICECAdapter *instance) { - delete instance; + DELETE_AND_NULL(instance); } bool CLibCEC::GetDeviceInformation(const char *strPort, libcec_configuration *config, uint32_t iTimeoutMs /* = CEC_DEFAULT_CONNECT_TIMEOUT */) @@ -1010,9 +505,75 @@ bool CLibCEC::GetDeviceInformation(const char *strPort, libcec_configuration *co return m_cec->GetDeviceInformation(strPort, config, iTimeoutMs); } -void CLibCEC::AddKey(const cec_keypress &UNUSED(key)) {} -void CLibCEC::AddCommand(const cec_command &UNUSED(command)) {} -void CLibCEC::ConfigurationChanged(const libcec_configuration &UNUSED(config)) {} -void CLibCEC::SetCurrentButton(cec_user_control_code UNUSED(iButtonCode)) {} -CLibCEC *CLibCEC::GetInstance(void) { return NULL; } -void CLibCEC::SetInstance(CLibCEC *UNUSED(instance)) {} +const char *CLibCEC::GetLibInfo(void) +{ +#ifndef LIB_INFO +#ifdef _WIN32 +#define FEATURES "'P8 USB' 'P8 USB detect'" +#ifdef _WIN64 +#define HOST_TYPE "Windows (x64)" +#else +#define HOST_TYPE "Windows (x86)" +#endif +#else +#define HOST_TYPE "unknown" +#define FEATURES "unknown" +#endif + + return "host: " HOST_TYPE ", features: " FEATURES ", compiled: " __DATE__; +#else + return LIB_INFO; +#endif +} + +void CLibCEC::InitVideoStandalone(void) +{ + CAdapterFactory::InitVideoStandalone(); +} +uint16_t CLibCEC::GetAdapterVendorId(void) const +{ + return m_cec && m_cec->IsRunning() ? m_cec->GetAdapterVendorId() : 0; +} + +uint16_t CLibCEC::GetAdapterProductId(void) const +{ + return m_cec && m_cec->IsRunning() ? m_cec->GetAdapterProductId() : 0; +} + +uint8_t CLibCEC::AudioToggleMute(void) +{ + return m_client ? m_client->AudioToggleMute() : (uint8_t)CEC_AUDIO_VOLUME_STATUS_UNKNOWN; +} + +uint8_t CLibCEC::AudioMute(void) +{ + return m_client ? m_client->AudioMute() : (uint8_t)CEC_AUDIO_VOLUME_STATUS_UNKNOWN; +} + +uint8_t CLibCEC::AudioUnmute(void) +{ + return m_client ? m_client->AudioUnmute() : (uint8_t)CEC_AUDIO_VOLUME_STATUS_UNKNOWN; +} + +uint8_t CLibCEC::AudioStatus(void) +{ + return m_client ? m_client->AudioStatus() : (uint8_t)CEC_AUDIO_VOLUME_STATUS_UNKNOWN; +} + +int8_t CLibCEC::DetectAdapters(cec_adapter_descriptor *deviceList, uint8_t iBufSize, const char *strDevicePath /* = NULL */, bool bQuickScan /* = false */) +{ + int8_t iAdaptersFound = CAdapterFactory(this).DetectAdapters(deviceList, iBufSize, strDevicePath); + if (!bQuickScan) + { + for (int8_t iPtr = 0; iPtr < iAdaptersFound; iPtr++) + { + libcec_configuration config; + GetDeviceInformation(deviceList[iPtr].strComName, &config); + deviceList[iPtr].iFirmwareVersion = config.iFirmwareVersion; + deviceList[iPtr].iPhysicalAddress = config.iPhysicalAddress; + deviceList[iPtr].iFirmwareBuildDate = config.iFirmwareBuildDate; + deviceList[iPtr].adapterType = config.adapterType; + } + } + return iAdaptersFound; +}